Skip to main content

发布&订阅

tip

发布-订阅（Publish-Subscribe）：消息中间件可以用于实现发布-订阅模式。发布者将消息发布到一个或多个主题（Topic），而订阅者订阅感兴趣的主题。当有新的消息发布到主题时，所有订阅了该主题的订阅者都会接收到消息。这样可以实现一对多的消息传递，降低发送方和接收方之间的耦合性。

首先完成 连接创建 ，便可进行消息的发送和接收，

订阅主题消息​

    // 事件订阅
    zhub.subscribe("topic-a", x -> {
        System.out.println("接收到主题 topic-a 事件，消息内容：" + x);
    });

发送主题消息​

测试发送主题消息

    private ZHubClient zhub;
    
    @RestMapping(name = "publish_test", auth = false, comment = "发送主题消息测试")
    public String publishTest(String value) {
        zhub.publish("topic-a", value);
        return "send ok!";
    }

这个时候，将会在订阅端收到主题订阅消息，并在控制台输出： 接收到主题 topic-a 事件，消息内容：xx 的消息内容