Соединение закрыто до получения ответа на рукопожатие в угловых - PullRequest
0 голосов
/ 12 ноября 2018

Я пытаюсь подключиться через сокет. Но я получаю вышеуказанную ошибку. Я пытаюсь реализовать https://tutorialedge.net/typescript/angular/angular-websockets-tutorial/ с другой конечной точкой.

socket.service.ts

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

@Injectable({
providedIn: 'root'
})
export class SocketService {

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);
}
}

chat.service.ts

import { Injectable } from '@angular/core';
import { Observable, Subject } from 'rxjs/Rx';
import {SocketService} from '../services/socket.service';

let ws_scheme = window.location.protocol == "https:" ? "wss" : "ws";
let ws_path = ws_scheme + '://' + window.location.host + 
"/api/chat/stream/";
const CHAT_URL = ws_path;

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

@Injectable({
providedIn: 'root'
})

export class UploadSocketService {

public messages: Subject<Message>;

constructor(wsService: SocketService) { 
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
            }
        });
}
}

Я получаю сообщение об ошибке в socket.service.ts , где разрешен код ws = новый WebSocket (url);

Как решить эту проблему?

1 Ответ

0 голосов
/ 12 ноября 2018

Если вы используете угловой прокси-сервер для получения / api / для перехода к своему бэкэнду, вам нужно добавить ws: true в конфигурацию прокси-сервера, иначе он не сможет создать соединение через веб-сокет.

{
  "/api/": {
    "target": "http://localhost:8080",
    "secure": false
    "ws":true
  }
}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...