javascript - 发生错误时尝试连接到 redux-saga 中的套接字

Question

我使用以下渠道准备了 saga：

function* createEventChannel(socket, dataItem) {
  const stompClient = Stomp.over(socket);
  const token = yield select(makeSelectToken);
  return eventChannel(emit => {
    stompClient.connect(
      getAuthorization(token),
      frame => {
        stompClient.subscribe('/queue/data', message => {
          const response = JSON.parse(message.body);
          emit(response);
        });
        stompClient.subscribe('/queue/error', message => {
          const error = JSON.parse(message.body);
          emit(error);
        });
        stompClient.send(
          '/register',
          {},
          JSON.stringify({
            request: {
              type: dataItem,
            },
          })
        );
      },
      error => emit({ error: 'Lost connection' })
    );
    return () => {
      socket.close();
      console.log('return close: ');
    };
  });
}

export function* initializeChannel(
  actionNames,
  requestParam
) {
  const mySocket = new SockJS('/ws');
  const channel = yield call(createEventChannel, mySocket, requestParam);
  while (true) {
    const { unmount, response } = yield race({
      unmount: take(UNMNOUT),
      response: take(channel),
    });
    if (unmount) {
      channel.close();
    } else {
      if (response) {
        yield put({
          type: FETCH_SUCCESS,
          payload: response.data,
        });
      }
      if (response.error) {
        yield put({
          type: actionNames.FETCH_ERROR,
          payload: response.error,
        });
      }
    }
  }
}

我知道这是一段相当长的代码，但这就是我设法准备的。现在我面临三个问题：

• 当发生错误时，例如“连接丢失”，我想尝试重新连接 saga，例如每 30 秒。如何做到这一点？
• 在stompClient.send我将 dataItem 注册到队列的部分中。现在每次我再次创建套接字。我怎样才能做到这一点，我可以一个接一个地注册 dataItem ，只加入现有的队列和套接字？
• 当套接字在线时，它不会对互联网丢失做出反应，我搜索了许多关于它的已打开问题，但我仍然不知道 - 有没有办法在 websocket 工作期间检查连接？

标签： javascriptreactjsreduxwebsocketredux-saga