开发者社区 > 云原生 > 消息队列 > 正文

RocketMQ中哪位大佬有C/C++调java版consumer的例子?

RocketMQ中哪位大佬有C/C++调java版consumer的例子?

展开
收起
真的很搞笑 2024-01-04 07:59:06 41 0
3 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Apache RocketMQ的消费者可以使用Java客户端来实现。以下是一个简单的示例代码,展示了如何使用DefaultMQPushConsumer来消费消息:

    import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
    import org.apache.rocketmq.client.exception.MQClientException;
    import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
    import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
    import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
    import org.apache.rocketmq.common.message.MessageExt;
    
    public class Consumer {
        public static void main(String[] args) throws MQClientException {
            // 创建一个名为 "ConsumerGroupName" 的消费者组
            DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroupName");
            // 设置 NameServer 地址
            consumer.setNamesrvAddr("127.0.0.1:9876");
            // 订阅一个名为 "TopicTest" 的主题
            consumer.subscribe("TopicTest", "*");
            // 注册一个消息监听器
            consumer.registerMessageListener(new MessageListenerConcurrently() {
                @Override
                public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
                    for (MessageExt msg : msgs) {
                        System.out.println("Receive message: " + new String(msg.getBody()));
                    }
                    return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                }
            });
            // 启动消费者
            consumer.start();
            System.out.println("Consumer started.");
        }
    }
    
    2024-01-04 17:40:42
    赞同 展开评论 打赏
  • 直接java客户端消费 通过http协议发给C呗,c有一个客户端的, 基本功能都没有问题https://github.com/apache/rocketmq-client-cpp ,此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”

    2024-01-04 11:52:20
    赞同 展开评论 打赏
  • 对于C/C++调用Java版的RocketMQ Consumer,Apache RocketMQ官方并未提供直接的示例。但你可以借鉴其Java客户端的使用方式,使用JNI的方式进行调用。

    在RocketMQ中,消息消费者(Consumer)负责消费消息,一般是后台系统负责异步消费。一个消息消费者会从Broker服务器拉取消息、并将其提供给应用程序。以下是一个简单的Java客户端消费消息的示例代码:

    import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
    import org.apache.rocketmq.client.exception.MQClientException;
    import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
    import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
    import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
    import org.apache.rocketmq.common.message.MessageExt;
    
    public class Consumer {
        public static void main(String[] args) throws MQClientException {
            // 创建一个名为 "ConsumerGroupName" 的消费者组
            DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("ConsumerGroupName");
    
            // 设置 NameServer 地址
            consumer.setNamesrvAddr("127.0.0.1:9876");
    
            // 订阅一个名为 "TopicTest" 的主题
            consumer.subscribe("TopicTest", "*");
    
            // 注册一个消息监听器,用于处理从 Broker 接收到的消息
            consumer.registerMessageListener(new MessageListenerConcurrently() {
                @Override
                public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {
                    for (MessageExt msg : msgs) {
                        System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), new String(msg.getBody()));
                    }
                    // 标记该消息已经被成功消费
                    return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                }
            });
    
            // 启动消费者实例
            consumer.start();
            System.out.printf("Consumer Started.%n");
        }
    }
    
    2024-01-04 08:51:08
    赞同 展开评论 打赏

高弹性低成本、更稳定更安全、智能化免运维的消息队列服务,涵盖RocketMQ、Kafka、RabbitMQ、MQTT、MNS等。 RocketMQ一站式学习:https://rocketmq-learning.com

相关产品

  • 云消息队列 MQ
  • 热门讨论

    热门文章

    相关电子书

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载