前一阵子正在学angular2，并且需要用websocket实时接收数据，那时候刚开始学angular2没多久，在网上找资料都是使用组件ng2websocket的，翻墙找了一些资料之后做了一些整理。以下代码没有用的ng2websocket，而是直接写的websocket。

话不多说，直接上代码：

chart.service.ts:

import { Injectable } from '@angular/core';
import { WebSocketService } from './websocket.service';
import 'rxjs/add/operator/map';
@Injectable()
export class ChatService{public ddd=[]; //收集websocket传递过来的值
  constructor(private wsService01: WebSocketService) {}onAAA(a01):void{const URL01 = 'ws://--websocket地址--jsessionid=?id='+a01;
    const NODEID01 = '{id:' + a01 + '}';
    this.wsService01
    .create(URL01,NODEID01)
    .map((response: MessageEvent): string => {        
        let data = response.data;        
        return data;      
    })      
    .subscribe(msg => {        
        let data=eval('('+msg+')');        
        this.ddd.push(data);      
    });  
  }
}

websocket.service.ts:

import {Injectable} from '@angular/core';
import {Observable} from 'rxjs/Observable';
import {Subject} from 'rxjs/Subject';
import {Observer} from "rxjs/Observer";
@Injectable()
export class WebSocketService {public a01:any;
  public create(url: string,nodeid:string): Subject<MessageEvent> {let ws = new WebSocket(url);
    ws.onopen = function() {ws.send(nodeid);
  };
    // 如果想要断开websocket连接，调用websocket.service.ts的a01函数即可。
    // this.a01 = function() {
    //   ws.close();
    //   console.log("websocket01已经断开连接");
    // };
    let observable = Observable.create((obs: Observer<MessageEvent>) => {ws.onmessage = obs.next.bind(obs);
        ws.onerror   = obs.error.bind(obs);
        ws.onclose   = obs.complete.bind(obs);
        return ws.close.bind(ws);
      });
    let observer = {next: (data: Object) => {if (ws.readyState === WebSocket.OPEN) {ws.send(data);
        }}};
    return Subject.create(observer, observable);
  }
}