WebClientEnum.java 1.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. package com.goafanti.common.webSocket;
  2. import org.apache.commons.lang3.ObjectUtils;
  3. import org.java_websocket.WebSocket;
  4. import org.java_websocket.enums.ReadyState;
  5. import java.net.URI;
  6. import java.net.URISyntaxException;
  7. public enum WebClientEnum {
  8. CLIENT;
  9. private static MsgWebSocketClient socketClient = null;
  10. public static void initClient(MsgWebSocketClient client) {
  11. socketClient = client;
  12. if(socketClient!=null) {
  13. socketClient.connect();
  14. while (socketClient.getReadyState().equals(ReadyState.OPEN)){
  15. socketClient.send("测试websocket。。。");
  16. }
  17. }
  18. boolean flag = true;
  19. int i=1000;
  20. while(flag) {
  21. while (!socketClient.getReadyState().equals(ReadyState.OPEN)){
  22. }
  23. socketClient.send("测试websocket。。。"+(i--));
  24. try {
  25. Thread.sleep(1000);
  26. } catch (InterruptedException e) {
  27. // TODO Auto-generated catch block
  28. e.printStackTrace();
  29. }
  30. if(i == 0) {
  31. flag = false;
  32. }
  33. }
  34. }
  35. }