From 7e4ca1a61388d209dddf76e954777e2886bc2ce4 Mon Sep 17 00:00:00 2001 From: "zh.sqy" Date: Wed, 20 Jan 2016 09:40:15 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9Ejava=E7=89=88=E7=9A=84websock?= =?UTF-8?q?et=E5=AE=A2=E6=88=B7=E7=AB=AF=E6=B5=8B=E8=AF=95=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../hsweb/web/socket/WebSocketClientTest.java | 35 +++++++++++++++++++ 1 file changed, 35 insertions(+) create mode 100644 hsweb-web-websocket/src/test/java/org/hsweb/web/socket/WebSocketClientTest.java diff --git a/hsweb-web-websocket/src/test/java/org/hsweb/web/socket/WebSocketClientTest.java b/hsweb-web-websocket/src/test/java/org/hsweb/web/socket/WebSocketClientTest.java new file mode 100644 index 000000000..e58abb50a --- /dev/null +++ b/hsweb-web-websocket/src/test/java/org/hsweb/web/socket/WebSocketClientTest.java @@ -0,0 +1,35 @@ +package org.hsweb.web.socket; + +import org.springframework.web.socket.TextMessage; +import org.springframework.web.socket.WebSocketMessage; +import org.springframework.web.socket.WebSocketSession; +import org.springframework.web.socket.client.WebSocketClient; +import org.springframework.web.socket.client.standard.StandardWebSocketClient; +import org.springframework.web.socket.handler.AbstractWebSocketHandler; + +import java.io.IOException; + +/** + * 使用java模拟websocket客户端 + * Created by 浩 on 2016-01-20 0020. + */ +public class WebSocketClientTest { + + public static void main(String[] args) throws IOException { + WebSocketClient client = new StandardWebSocketClient(); + String url = "ws://localhost:8080/socket"; + client.doHandshake(new AbstractWebSocketHandler() { + @Override + public void afterConnectionEstablished(WebSocketSession session) throws Exception { + //链接成功后发送消息 + session.sendMessage(new TextMessage("{\"cmd\":\"test\"}")); + } + + @Override + public void handleMessage(WebSocketSession session, WebSocketMessage message) throws Exception { + System.out.println(message.getPayload()); + } + }, url); + System.in.read(); + } +}