webSocketConnection.js 5.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174
  1. const cleanPeriod = 60*1000;//1 минута
  2. class WebSocketConnection {
  3. //messageLifeTime в минутах (cleanPeriod)
  4. constructor(messageLifeTime = 5) {
  5. this.ws = null;
  6. this.timer = null;
  7. this.listeners = [];
  8. this.messageQueue = [];
  9. this.messageLifeTime = messageLifeTime;
  10. this.requestId = 0;
  11. }
  12. addListener(listener) {
  13. if (this.listeners.indexOf(listener) < 0)
  14. this.listeners.push(Object.assign({regTime: Date.now()}, listener));
  15. }
  16. //рассылаем сообщение и удаляем те обработчики, которые его получили
  17. emit(mes, isError) {
  18. const len = this.listeners.length;
  19. if (len > 0) {
  20. let newListeners = [];
  21. for (const listener of this.listeners) {
  22. let emitted = false;
  23. if (isError) {
  24. if (listener.onError)
  25. listener.onError(mes);
  26. emitted = true;
  27. } else {
  28. if (listener.onMessage) {
  29. if (listener.requestId) {
  30. if (listener.requestId === mes.requestId) {
  31. listener.onMessage(mes);
  32. emitted = true;
  33. }
  34. } else {
  35. listener.onMessage(mes);
  36. emitted = true;
  37. }
  38. } else {
  39. emitted = true;
  40. }
  41. }
  42. if (!emitted)
  43. newListeners.push(listener);
  44. }
  45. this.listeners = newListeners;
  46. }
  47. return this.listeners.length != len;
  48. }
  49. open(url) {
  50. return new Promise((resolve, reject) => {
  51. if (this.ws && this.ws.readyState == WebSocket.OPEN) {
  52. resolve(this.ws);
  53. } else {
  54. let protocol = 'ws:';
  55. if (window.location.protocol == 'https:') {
  56. protocol = 'wss:'
  57. }
  58. url = url || `${protocol}//${window.location.host}/ws`;
  59. console.log('new connection');
  60. this.ws = new WebSocket(url);
  61. if (this.timer) {
  62. clearTimeout(this.timer);
  63. }
  64. this.timer = setTimeout(() => { this.periodicClean(); }, cleanPeriod);
  65. let resolved = false;
  66. this.ws.onopen = (e) => {
  67. console.log(this.ws.readyState);
  68. resolved = true;
  69. resolve(e);
  70. };
  71. this.ws.onmessage = (e) => {
  72. try {
  73. const mes = JSON.parse(e.data);
  74. this.messageQueue.push({regTime: Date.now(), mes});
  75. let newMessageQueue = [];
  76. for (const message of this.messageQueue) {
  77. if (!this.emit(message.mes)) {
  78. newMessageQueue.push(message);
  79. }
  80. }
  81. this.messageQueue = newMessageQueue;
  82. } catch (e) {
  83. this.emit(e.message, true);
  84. }
  85. };
  86. this.ws.onerror = (e) => {
  87. this.emit(e.message, true);
  88. if (!resolved)
  89. reject(e);
  90. };
  91. }
  92. });
  93. }
  94. //timeout в минутах (cleanPeriod)
  95. message(requestId, timeout = 2) {
  96. return new Promise((resolve, reject) => {
  97. this.addListener({
  98. requestId,
  99. timeout,
  100. onMessage: (mes) => {
  101. resolve(mes);
  102. },
  103. onError: (e) => {
  104. reject(e);
  105. }
  106. });
  107. });
  108. }
  109. send(req) {
  110. if (this.ws && this.ws.readyState == WebSocket.OPEN) {
  111. const requestId = ++this.requestId;
  112. this.ws.send(JSON.stringify(Object.assign({requestId}, req)));
  113. return requestId;
  114. } else {
  115. throw new Error('WebSocket connection is not ready');
  116. }
  117. }
  118. close() {
  119. if (this.ws && this.ws.readyState == WebSocket.OPEN) {
  120. this.ws.close();
  121. }
  122. }
  123. periodicClean() {
  124. try {
  125. this.timer = null;
  126. const now = Date.now();
  127. //чистка listeners
  128. let newListeners = [];
  129. for (const listener of this.listeners) {
  130. if (now - listener.regTime < listener.timeout*cleanPeriod - 50) {
  131. newListeners.push(listener);
  132. } else {
  133. if (listener.onError)
  134. listener.onError('Время ожидания ответа истекло');
  135. }
  136. }
  137. this.listeners = newListeners;
  138. //чистка messageQueue
  139. let newMessageQueue = [];
  140. for (const message of this.messageQueue) {
  141. if (now - message.regTime < this.messageLifeTime*cleanPeriod - 50) {
  142. newMessageQueue.push(message);
  143. }
  144. }
  145. this.messageQueue = newMessageQueue;
  146. } finally {
  147. if (this.ws.readyState == WebSocket.OPEN) {
  148. this.timer = setTimeout(() => { this.periodicClean(); }, cleanPeriod);
  149. }
  150. }
  151. }
  152. }
  153. export default new WebSocketConnection();