在研究了webflux和reactor的一些资料之后，我采用了以下方法。我使用的处理器，你可以连接多个订户。然后将此处理器连接到websocketclient中。
关于不同处理器的一个很好的总结可以在这里找到
如何在java的reactor中使用处理器
使用这种方法，我将能够动态添加订户。因此，当我检测到频道消息时，我可以使用过滤器为该频道号向处理器添加一个新的订户。下面的伪代码说明了这种行为。

ReplayProcessor<String> output = ReplayProcessor.create();
output.filter(msg -> msg.startsWith("{")).subscribe(msg -> {
    System.out.println(msg);
    JSONObject json = new JSONObject(msg); 
    if (json.has("event") && json.get("event").equals("auth")) {
        if (json.has("chanId")) {
            int chanId = json.getInt("chanId");
            // add new subscriber for that channel number, receives only messages from that channel
            output.filter(t -> t.startsWith("[" + chanId)).subscribe( t -> System.err.println(t));
        }
    }
});

client.execute(uri, session -> 
        // send message
        session.send(Mono.just(session.textMessage(authCommand)))
        .thenMany(session.receive()
            .map(message -> message.getPayloadAsText())
            .subscribeWith(output))
        .then()).block();