Websocket trong Angular 4 và RxJS nhầm lẫn

Question

Tôi đang cố gắng tìm hiểu RxJS với websockets và Angular 4, và tìm thấy một ví dụ tốt here. Tôi hy vọng ai đó có thể giúp giải thích ví dụ như một vài điều khó hiểu.

Họ đã tạo ra 2 dịch vụ kiễu góc, Sở WebSocket:

import { Injectable } from '@angular/core'; 
import * as Rx from 'rxjs/Rx'; 

@Injectable() 
export class WebsocketService { 
    constructor() { } 

    private subject: Rx.Subject<MessageEvent>; 

    public connect(url): Rx.Subject<MessageEvent> { 
    if (!this.subject) { 
     this.subject = this.create(url); 
     console.log("Successfully connected: " + url); 
    } 
    return this.subject; 
    } 

    private create(url): Rx.Subject<MessageEvent> { 
    let ws = new WebSocket(url); 

    let observable = Rx.Observable.create(
    (obs: Rx.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(JSON.stringify(data)); 
      } 
     } 
    } 
    return Rx.Subject.create(observer, observable); 
    } 

} 

và các dịch vụ Chat:

import { Injectable } from '@angular/core'; 
import { Observable, Subject } from 'rxjs/Rx'; 
import { WebsocketService } from './websocket.service'; 

const CHAT_URL = 'ws://echo.websocket.org/'; 

export interface Message { 
    author: string, 
    message: string 
} 

@Injectable() 
export class ChatService { 
    public messages: Subject<Message>; 

    constructor(wsService: WebsocketService) { 
     this.messages = <Subject<Message>>wsService 
      .connect(CHAT_URL) 
      .map((response: MessageEvent): Message => { 
       let data = JSON.parse(response.data); 
       return { 
        author: data.author, 
        message: data.message 
       } 
      }); 
    } 
} 

Tôi đã có một số câu hỏi về vấn đề này:

1. Tại sao cần tạo 2 dịch vụ? Subject không thể là một người quan sát và có thể quan sát được (vì vậy nó có thể chuyển tiếp các tin nhắn trực tiếp mà không cần một dịch vụ Chat thứ hai)? Vấn đề gì là giải quyết việc tạo ra 2 dịch vụ?
2. Trong dịch vụ Websocket, tại sao dòng cuối cùng của hàm gọi hàm .create trả về ws.close.bind (ws)? Cái đó làm cái gì?
3. Cách ngắt kết nối của websocket được xử lý? Có cách nào để kết nối lại không?
4. Các dịch vụ nên đóng/hủy bỏ websocket như thế nào?

Answer 1

1. Reuseability
2. vì vậy bạn có thể hủy đăng ký từ quan sát được do đó đóng kết nối

3. trong ví dụ bạn đưa nó có lẽ sẽ là một cái gì đó tương tự (khi bạn có một thể hiện của chatService)

   let sub = chatService.messages.subscribe(()=>{ 
   // do your stuff 
   }); 
   
   // some where in your code 
   sub.unsubscribe() // this will close the connection 
   

4. đã trả lời trong 3