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