| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546 |
- package com.goafanti.common.webSocket;
- import java.net.URI;
- import java.net.URISyntaxException;
- import java.util.Iterator;
- import org.java_websocket.client.WebSocketClient;
- import org.java_websocket.handshake.ServerHandshake;
- public class MsgWebSocketClient extends WebSocketClient{
- public MsgWebSocketClient(String url) throws URISyntaxException {
- super(new URI(url));
- // TODO Auto-generated constructor stub
- }
- @Override
- public void onOpen(ServerHandshake shake) {
- // TODO Auto-generated method stub
- System.out.println("握手...");
- for(Iterator<String> it=shake.iterateHttpFields();it.hasNext();) {
- String key = it.next();
- System.out.println(key+":"+shake.getFieldValue(key));
- }
- }
- @Override
- public void onMessage(String paramString) {
- // TODO Auto-generated method stub
- System.out.println("接收到消息:"+paramString);
- }
- @Override
- public void onClose(int paramInt, String paramString, boolean paramBoolean) {
- // TODO Auto-generated method stub
- System.out.println("关闭...");
- }
- @Override
- public void onError(Exception e) {
- // TODO Auto-generated method stub
- System.out.println("异常"+e);
- }
- }
|