一、用python快速启动一个websocker服务器
import tornado.ioloopimport tornado.webimport tornado.websocketclass WebSocketHandler(tornado.websocket.WebSocketHandler): def open(self): print("WebSocket 连接已建立") def on_message(self, message): print("收到消息：", message) self.write_message("收到了你的消息：" + message) def on_close(self): print("WebSocket 连接已关闭")def make_app(): return tornado.web.Application([ (r"/websocket", WebSocketHandler), ])if __name__ == "__main__": app = make_app() app.listen(8080) print("WebSocket 服务器已启动，端口号：8080") tornado.ioloop.IOLoop.current().start()二、使用java连接并发送消息
package com.ciih.iot.common.util;import javax.websocket.*;import java.net.URI;@ClientEndpointpublic class WebSocketClient { @OnOpen public void onOpen(Session session) { System.out.println("Connection established"); try { // 发送一条消息到服务器 session.getBasicRemote().sendText("Hello, WebSocket Server!"); System.out.println("建立连接"); } catch (Exception e) { e.printStackTrace(); } } @OnMessage public void onMessage(String message) { System.out.println("Received message: " + message); } @OnClose public void onClose(Session session, CloseReason reason) { System.out.println("Connection closed: " + reason.getReasonPhrase()); } public static void pushMessage(String url, String message) { try { WebSocketContainer container = ContainerProvider.getWebSocketContainer(); Session session = container.connectToServer(WebSocketClient.class, new URI(url)); session.getBasicRemote().sendText(message); } catch (Exception e) { e.printStackTrace(); } } public static void main(String[] args) { WebSocketClient.pushMessage("ws://localhost:8080/websocket","来自火星"); }}来源地址：https://blog.csdn.net/wenxingchen/article/details/131580885
