import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.URI; import java.net.URISyntaxException; import net.sf.json.JSONObject; import org.java_websocket.client.WebSocketClient; import org.java_websocket.drafts.Draft; import org.java_websocket.drafts.Draft_17; import org.java_websocket.framing.Framedata; import org.java_websocket.handshake.ServerHandshake; import t9.core.util.T9Utility; public class WebSocketUtils extends WebSocketClient { public WebSocketUtils( URI serverUri , Draft draft ) { super( serverUri, draft ); } public WebSocketUtils( URI serverURI ) { super( serverURI ); } @Override public void onOpen( ServerHandshake handshakedata ) { System.out.println( "开流--opened connection" ); } @Override public void onMessage( String message ) { System.out.println( "接收--received: " + message ); } @Override public void onFragment( Framedata fragment ) { System.out.println( "片段--received fragment: " + new String( fragment.getPayloadData().array() ) ); } @Override public void onClose( int code, String reason, boolean remote ) { System.out.println( "关流--Connection closed by " + ( remote ? "remote peer" : "us" ) ); } @Override public void onError( Exception ex ) { ex.printStackTrace(); } public static void main(String[] args) { try { WebSocketUtils c = new WebSocketUtils( new URI( "ws://localhost:9989/update" ), new Draft_17() ); c.connect(); // c.send("测试"); BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); String input = ""; try { do { input = br.readLine(); if (!input.equals("exit")) c.send(input); } while (!input.equals("exit")); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } catch (URISyntaxException e) { e.printStackTrace(); } } }jar包 点击打开链接
Java测试websoket接口
猜你喜欢
转载自blog.csdn.net/shfei10100/article/details/69392500
今日推荐
周排行