thierrysquirrel / rocketmq-spring-boot-starter Goto Github PK

复制到pom文件中之后 not found

如图所示,消费者代理失败！请问大佬 这是为何

比如我的mq的topic，group每个环境都不一样，如果在注解中的代码里写死很麻烦吧

分区顺序消息应该是没支持吧，目前shardingkey在OrderMessage注解中只是一个值，应该达不到分区顺序消息的需求

建议owner主页留一下邮箱，对这个项目很感兴趣

不用注解的方式怎么发送消息呢

Error:(4, 45) java: 无法访问com.github.thierrysquirrel.annotation.EnableRocketMQ
错误的类文件: /D:/repo/com/github/thierrysquirrel/rocketmq-spring-boot-autoconfigure/2.3.0.6-RELEASE/rocketmq-spring-boot-autoconfigure-2.3.0.6-RELEASE.jar!/com/github/thierrysquirrel/annotation/EnableRocketMQ.class
类文件具有错误的版本 55.0, 应为 52.0
请删除该文件或确保该文件位于正确的类路径子目录中。

在这一段代码中 会根据 MessageListener 的注解来注册 consumer

但是当出现多个 MessageListener 的时候会在 阿里云控制台注册多个 consumer 那这个消费岂不是针对方法级别的了
` @MessageListener(topic = "sdongpos-common",tag = "order")
public void consumerOrderMsg(String message) {
System.out.println("consumerMsg ： "+message);
}

@MessageListener(topic = "sdongpos-common",tag = "commonA")
public void consumerCommonMsg(String message) {
    System.out.println("consumercommonMsg ： "+message);
}

@MessageListener(topic = "sdongpos-common",tag = "commonB")
public void consumerCommonBMsg(String message) {
    System.out.println("consumercommonMsg ： "+message);
}

`这个是阿里云控制台的图片

<dependency>
            <artifactId>rocketmq-spring-boot-starter</artifactId>
            <groupId>com.github.thierrysquirrel</groupId>
            <version>2.0.6-RELEASE</version>
        </dependency>

如果用户只是想接收到字符串

那么如果消息中的如果带有“：” 则解析会直接抛出解析异常
可以在实现的时候判断下如果接收者要的就是String类型 那么可以不用做json转换

调试时消息在消费者中已经接收消费并处理了，但是查询消费轨迹中消息的消费状态仍然显示“尚未消费”。
版本2.1.2-RELEASE

我看你的源码是创建了多个Producer在不同线程中，不应该是不同线程中同享同一个实例用？

能自定义延时发送的延时时间么？

如题

想法非常好，但是报No route info for this topic

我加了：@EnableRocketMQ
有没有需要注意的点

能否或如何通过@Autowired方式触发消息发送，而不要通过http的get方式来调用。
个人尝试时按照文档收发消息没有问题，但必须通过http方式调用吗？

感觉这块少一个return呢？为啥是不需要的呢？

PutProducerStrategy中指定使用DefaultLocalTransactionChecker，这个checker应该是需要自己根据各自的业务去自行扩展的吧。 另外TransactionMessage注解中transactionStatus属性也有点不理解，不应该是根据checker里的查询结果返回不同的status吗？

上面上要求输入 阿里云的 accessKey SecretKey 没有这些能用吗 不是指定机器IP和端口吗

@MessageListener(topic = "message",tag = "message")
public void delayed(String message) {
// 异步多线程处理，处理失败抛出的RocketException异常，可以执行Action.ReconsumeLater？
asynTask.do();
}

我看源码里面是抛出异常就会执行ACK
public Action consume(Message message, ConsumeContext context) {
log.info(">>>>listener message:{}>>>>", message);
try {
super.getMethodFactoryExecution().methodExecution(message.getBody());
} catch (RocketException e) {
super.printErrorLog();
return Action.ReconsumeLater;
}
return Action.CommitMessage;
}