当关联对象“陈旧”时清除Redisson pub/sub侦听器

Question

private static RedissonClient redisson = RedissonRedisServer.createRedisConnectionWithConfig();
public static final RTopic subcriberTopic = redisson.getTopic("clientsMapTopic");

public static boolean sendToPubSub(ConnectedClient q, String message) {
        boolean[] success = {true};
        MessageListener<Message> listener = new MessageListener<Message>() {
            @Override
            public void onMessage(CharSequence channel, Message message) {
                logger.debug("The message is : " + message.getMediaId());

                try {
                    logger.debug("ConnectedClient mediaid: " + q.getMediaid() + ",Message mediaid " + message.getMediaId());
                    if (q.getMediaid().equals(message.getMediaId())) {
                        // we need to verify if the message goes to the right receiver
                        logger.debug("MESSAGE from PUBSUB to (" + q.getId() + ") @ " + q.getSession().getId() + " " + message);
                        // this is the actual message to the websocket client
                        // this executes on the wrong connected client when the connection is closed and reopened
                        q.getSession().getBasicRemote().sendText(message.getMessage());
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                    success[0] = false;
                }
            }
        };
        int listenerId = subcriberTopic.addListener(Message.class, listener);
}

我正在观察的问题如下：

• 来自客户端的初始连接将注册与该对象关联的侦听器
• 发送到ws服务器的消息被侦听器接收并正确发送
• 断开websocket连接-创建新连接-创建新侦听器
• 发送到ws服务器的消息会被相同的原始侦听器拾取，并使用连接的客户端而不是新注册的客户端
• 发送失败（因为客户端和ws连接不存在），并且不进一步处理

如果客户机被移除，我似乎只需要移除客户机的侦听器，但我还没有找到一个好的方法，因为尽管我在调试器中看到侦听器有关联的已连接的客户机对象，但如果不为此添加代码，我就无法检索它们。

我是否正确地观察到了这一点，什么是使这正常工作的好方法？

Answer 1

当我写这个问题的时候，我有点倾向于一个我想好的答案，并且尝试了，结果成功了。我添加了一个ConcurrentHashmap来跟踪连接的客户端和侦听器之间的关系。在我处理指向客户端删除的websocket错误的逻辑中，我随后删除了关联的侦听器（以及映射中的条目）。现在它按预期工作。

小片段：

int listenerId = subcriberTopic.addListener(Message.class, listener);
clientListeners.put(q,(Integer)listenerId);

然后在触发清理的websocket onError处理程序中：

// remove the associated listener
int listenerIdForClient = MessageContainer.clientListeners.get(cP);
MessageContainer.subcriberTopic.removeListener((Integer) listenerIdForClient);
// remove entry from map
MessageContainer.clientListeners.remove(cP);