云消息队列 MQ代码的相关内容

文章 2025-04-17 来自：开发者社区

RocketMQ实战—9.营销系统代码初版

大纲 1.基于条件和画像筛选用户的业务分析和实现 2.全量用户促销活动数据模型分析以及创建操作 3.Producer和Consumer的工程代码实现 4.基于抽象工厂模式的消息推送实现 5.全量用户促销活动消息推送的流程和缺陷分析 6.全量用户促销活动推送引入MQ进行削峰 7.全量用户发优惠券业务流程实现 8.全量用户发优惠券引入M...

文章 2024-08-25 来自：开发者社区

【Azure Event Hub】原生应用中使用RabbitMQ，是否可以不改动代码的情况下直接转换为使用Event Hub呢？

问题描述原生应用中使用RabbitMQ，是否可以不改动代码的情况下直接转换为使用Azure Event Hub呢？问题解答 Rabbit MQ使用的协议是AMQP 0-9-1，而Azure Event Hub 或 Service Bus 使用的是AMQP1.0，所以无法直接复用之前的代码。需要使用Azure Event Hub SDK来生产/消费...

文章 2024-08-15 来自：开发者社区

MQTT(EMQX) - Java 调用 MQTT Demo 代码

POM <dependency> <groupId>org.eclipse.paho</groupId> <artifactId>org.eclipse.paho.client.mqttv3</artifactId&...

文章 2024-07-29 来自：开发者社区

消息队列 MQ使用问题之如何获取PHP客户端代码

问题一：RocketMQ 里有多台nameserver 是不是设计上有缺陷？ RocketMQ 里有多台nameserver 只要一台nameserver机器ip不存在了，发送端和消费端就无法启动了，但是ip存在端口不在还是可以启动成功的，我们看了一下源码的确如此，是不是设计上有缺陷？参考答案：检查客户端配置。关于本问...

问答 2024-07-17 来自：开发者社区

RocketMQ怎么可以用代码查询死信队列消息

问题描述 RocketMQ消费失败的消息进入死信队列，可以用java代码获取这部分消息吗，怎么用java代码编写期望结果用java代码获取死信队列消息已尝试的方法

问答 2024-07-16 来自：开发者社区

RocketMQ 改了下dashboard代码，可以用什么地址请求？

RocketMQ 改了下dashboard代码，将proxy地址传进去请求重新消费，报309类型不支持，请教下可以用什么地址请求吗？ Caused by: org.apache.rocketmq.client.exception.MQClientException: CODE: 3 DESC: request type 309 not supportedFor more informatio...

问答 2024-06-13 来自：开发者社区

RocketMQ，代码未上线，先新增group，重置消费位点是否会影响到topic的其他group

RocketMQ，代码未上线，先新增group，此时group 为离线状态，此时重置消费位点会生效吗？会影响到topic的其他group吗

问答 2024-05-21 来自：开发者社区

MQTT不写云端程序，只写终端程序，我在云服务器上挂载的也是终端程序代码，这样做会有什么后果吗？

问答 2024-05-15 来自：开发者社区

RocketMQ5.2.0版本里面的代码不是acl2.0的实现吧？

问答 2024-05-15 来自：开发者社区

有个rocketmq client模块的代码的问题请教一下

有个rocketmq client模块的代码的问题请教一下（详细描述在这里 https://github.com/apache/rocketmq/discussions/8114 ）。ConsumeMessageOrderlyService的内部类ConsumeRequest#run方法，在执行messageListener的消费方法前加了consumeLock.readLock，这个加锁操作....