客户端的五个重要配置

客户端接口有三个重要的配置，都是需要在连接前设定好的

1、client.config(...)

这是 Scoket.D 的客户端配置接口，我们是用 Socket.D 开发的嘛。一般是不用动（可以点进去看看）。

其中 trafficLimiter 为流量限制，默认为 1万/秒。

FolkMQ.createClient("folkmq://127.0.0.1:18602")
    .config(c -> c.trafficLimiter(new TrafficLimiterDefault(10_000)))
    .connect();

2、client.nameAs(...)

给当前客户端取个名字。相当于默认“消费者组”，也是 rpc 通讯的“应用名”。

3、client.namespaceAs(...)

给所有消息“发布”和“订阅”配置命名空间。默认为空

4、client.autoAcknowledge(...)

这是“消费者”角色的配置，指定是否自动 ACK。默认是 true。如果是异步消费，需要手动确认，则改为 false。

5、client.consumeExecutor(...)

给当前客户端安排消费执行器（线程池），如果是 java21 可以使用虚拟线程池。默认为使用 RunUtils.async 方法执行（线程比较多）。