MsgWebSocketClient.java 1.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546
  1. package com.goafanti.common.webSocket;
  2. import java.net.URI;
  3. import java.net.URISyntaxException;
  4. import java.util.Iterator;
  5. import org.java_websocket.client.WebSocketClient;
  6. import org.java_websocket.handshake.ServerHandshake;
  7. public class MsgWebSocketClient extends WebSocketClient{
  8. public MsgWebSocketClient(String url) throws URISyntaxException {
  9. super(new URI(url));
  10. // TODO Auto-generated constructor stub
  11. }
  12. @Override
  13. public void onOpen(ServerHandshake shake) {
  14. // TODO Auto-generated method stub
  15. System.out.println("握手...");
  16. for(Iterator<String> it=shake.iterateHttpFields();it.hasNext();) {
  17. String key = it.next();
  18. System.out.println(key+":"+shake.getFieldValue(key));
  19. }
  20. }
  21. @Override
  22. public void onMessage(String paramString) {
  23. // TODO Auto-generated method stub
  24. System.out.println("接收到消息:"+paramString);
  25. }
  26. @Override
  27. public void onClose(int paramInt, String paramString, boolean paramBoolean) {
  28. // TODO Auto-generated method stub
  29. System.out.println("关闭...");
  30. }
  31. @Override
  32. public void onError(Exception e) {
  33. // TODO Auto-generated method stub
  34. System.out.println("异常"+e);
  35. }
  36. }