使用express从POST请求处理程序发送WebSocket消息

npm install express websocket

const express = require('express');
const app = express();

app.use(express.json());

app.post('/postRoute', (req, res) => {
  // 处理 POST 请求
  // ...

  // 向 WebSocket 客户端发送消息
  // ...
});

app.listen(3000, () => {
  console.log('Server is running on port 3000');
});

const WebSocket = require('websocket').server;

const server = require('http').createServer();
const wsServer = new WebSocket({
  httpServer: server,
});

wsServer.on('request', (request) => {
  const connection = request.accept(null, request.origin);

  // 接收客户端的消息
  connection.on('message', (message) => {
    console.log('Received message:', message.utf8Data);
  });

  // 发送消息给客户端
  connection.send('Hello, client!');
});

server.listen(8080, () => {
  console.log('WebSocket server is running on port 8080');
});

const WebSocket = require('websocket').client;
const client = new WebSocket();

client.on('connect', (connection) => {
  console.log('Connected to WebSocket server');

  // 发送消息给 WebSocket 服务器
  connection.send('Hello, WebSocket server!');
});

client.connect('ws://localhost:8080/', '', 'http://localhost:3000');