消费者 - 使用多个消者费者组订阅

创建客户端时，通过 nameAs 设定默认消费者组

//客户端
MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
        .nameAs("demoapp")
        .connect();

1、使用默认消费者组

//订阅主题（使用默认消费者组）
client.subscribe("demo.topic", message -> {
    //消费
    System.out.println(message);
});

2、使用多个消费者组

• 使用默认 ack 机制

//订阅主题，并指定加入的消费者分组
client.subscribe("demo.topic", "demo-app1", message -> {
    //消费
    System.out.println(message);
});

//订阅主题，并指定加入的消费者分组
client.subscribe("demo.topic", "demo-app2", message -> {
    //消费
    System.out.println(message);
});

• 指定消费者分组的 ack 机制

//true 表示自动
client.subscribe("demo.topic", "demo-app1", true, message -> {
    //消费
    System.out.println(message);
});

//false 表示手动
client.subscribe("demo.topic", "demo-app2", false, message -> {
    //消费
    System.out.println(message);
    
    //ack
    message.acknowledge(true);
});