简单经纪人

ChatGPT-4o-mini 中英对照 Simple Broker

内置的简单消息代理处理来自客户端的订阅请求，将其存储在内存中，并向具有匹配目标的连接客户端广播消息。该代理支持类似路径的目标，包括对 Ant 风格目标模式的订阅。

备注

应用程序也可以使用点分隔（而不是斜杠分隔）目标。请参见 Dots as Separators。

如果配置了任务调度器，简单代理支持 STOMP 心跳。要配置调度器，您可以声明自己的 TaskScheduler bean，并通过 MessageBrokerRegistry 设置它。或者，您可以使用内置 WebSocket 配置中自动声明的调度器，但您需要使用 @Lazy 来避免内置 WebSocket 配置与您的 WebSocketMessageBrokerConfigurer 之间的循环。例如：

Java

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfiguration implements WebSocketMessageBrokerConfigurer {

    private TaskScheduler messageBrokerTaskScheduler;

    @Autowired
    public void setMessageBrokerTaskScheduler(@Lazy TaskScheduler taskScheduler) {
        this.messageBrokerTaskScheduler = taskScheduler;
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/queue/", "/topic/")
                .setHeartbeatValue(new long[] {10000, 20000})
                .setTaskScheduler(this.messageBrokerTaskScheduler);

        // ...
    }
}

java

Kotlin

@Configuration
@EnableWebSocketMessageBroker
class WebSocketConfiguration : WebSocketMessageBrokerConfigurer {

    private lateinit var messageBrokerTaskScheduler: TaskScheduler

    @Autowired
    fun setMessageBrokerTaskScheduler(@Lazy taskScheduler: TaskScheduler) {
        this.messageBrokerTaskScheduler = taskScheduler
    }

    override fun configureMessageBroker(registry: MessageBrokerRegistry) {
        registry.enableSimpleBroker("/queue/", "/topic/")
            .setHeartbeatValue(longArrayOf(10000, 20000))
            .setTaskScheduler(messageBrokerTaskScheduler)

        // ...
    }
}

kotlin