我在后端初始化了WebSocket。
然后使用rxjs/webSocket连接并在浏览器上接收以下错误:
connection to 'ws://localhost:3000/' failed: Connection closed before receiving a handshake response
server.js相关代码:
const { app, onServerInitialized } = require('./app');
const port = normalizePort(process.env.PORT);
console.log('Server is running on port ' + process.env.PORT);
app.set('port', port);
const server = http.createServer(app);
onServerInitialized(server);
app.js相关代码:
const app = express();
const onServerInitialized = server => {
const io = socketio(server);
io.on('connection', socket => {
console.log('subscrie');
});
};
module.exports = { app, onServerInitialized };
WebSocketService
import { webSocket, WebSocketSubject } from 'rxjs/webSocket';
export class WebSocketService {
private ws$: WebSocketSubject<any> = webSocket('ws://localhost:3000');
public getWSListener() {
return this.ws$.asObservable().pipe();
}
public sendMessage(message: string) {
this.ws$.next({ message });
}
}
app.component.ts
constructor(
private webSocketService: WebSocketService,
) {}
ngOnInit() {
this.webSocketService.getWSListener().subscribe(() => {
console.log('event')
});
}
发布于 2020-05-05 11:25:01
您正在使用socket.io
包,并且该包已经在/socket.io
路径上设置了服务器。所以试试这个uri:ws://localhost:3000/socket.io/?EIO=3&transport=websocket
还要确保在onServerInitialized
函数中,不需要在底部添加这一行
io.listen(+process.env.PORT);
编辑:
更好地将ngx-socket-io
软件包应用于角度工程
https://stackoverflow.com/questions/61571898
复制相似问题