滴滴 离很远接单 车到了上车点 然后司机取消订单 拉别人
发简信
IP属地：北京
-
楼主代码看起来挺奇怪，和我平常写的不一样（我是新人），是用了什么设计模式吗（不太懂），感觉像是实现了一个自己的rabbitmqTemplate
rabbitmq可靠确认模式的java封装及示例
最近的一个计费项目，在rpc调用和流式处理之间徘徊了许久，后来选择流式处理。一是可以增加吞吐量，二是事务的控制相比于rpc要容易很多。 确定了流式处理的方式，后续是技术的选型...
-
@littlersmall 我现在也先把消息存在redis中了
rabbitmq可靠发送的自动重试机制
http://www.jianshu.com/p/4112d78a8753 接这篇 在上文中，主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略，主...
-
@littlersmall 哦哦 谢楼主解惑 em。。 假如我用reids存储消息 ，但我的redis现在部署在消费端的机器上，这样也怕网络抖动。。那我应该在生产者端另部署一个redis 专用 这样吗？
rabbitmq可靠发送的自动重试机制
http://www.jianshu.com/p/4112d78a8753 接这篇 在上文中，主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略，主...
-
@littlersmall 感谢楼主回复， 我小小的疑惑的地方在于文章中 “ rabbitTemplate的ack确认机制是异步的，依旧是不安全的。 ”
emmm。。异步应该是指生产者client不必等待ack响应，可以一直向broker发送消息吧
我想问一下，我通过ReturnCallback和ConfirmCallback 来重发 消息 不好的地方在哪呢rabbitmq可靠发送的自动重试机制
http://www.jianshu.com/p/4112d78a8753 接这篇 在上文中，主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略，主...
-
还有另外一点是否也有问题呢？
“在confirmCallback中是没有原message的，"，没有message,但是有CorrelationData啊，完全可以自己的实现CorrelationData，然后rabbitTemplate.convertAndSend()作为参数一起发送，这样confirmCallback时不就有message了吗。。rabbitmq可靠发送的自动重试机制
http://www.jianshu.com/p/4112d78a8753 接这篇 在上文中，主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略，主...
-
楼主你好， 感觉有点问题啊。。 关于 “rabbitTemplate的ack确认机制是异步的”。。
我想问， exchange、queue持久化了吗？官网有一段描述 和你说的完全不一致。
```
When Will Published Messages Be Confirmed by the Broker?
For unroutable messages, the broker will issue a confirm once the exchange verifies a message won't route to any queue (returns an empty list of queues). If the message is also published as mandatory, the basic.return is sent to the client before basic.ack. The same is true for negative acknowledgements (basic.nack).
For routable messages, the basic.ack is sent when a message has been accepted by all the queues. For persistent messages routed to durable queues, this means persisting to disk. For mirrored queues, this means that all mirrors have accepted the message.
```
对于持久化消息，是在持久化到磁盘时才ack，楼主可以解释一下吗rabbitmq可靠发送的自动重试机制
http://www.jianshu.com/p/4112d78a8753 接这篇 在上文中，主要实现了可靠模式的consumer。而可靠模式的sender实现的相对简略，主...
-
emmm。。关于producer的ack，在提出一点问题：
当消息到达exchange,却没到达queue时，ack为true，楼主逻辑判断为“发送成功",实际上却发送失败了
应该ack为true,且returnback没调用时，才能确定消息已经到达队列并持久化Spring Boot RabbitMQ实践
背景 我们现在有两个主要的系统一个是活动系统一个是奖品系统，活动系统会调用奖品系统发放奖励。 最开始两个之间只通过http直接调用，优点：开发成本低，没有多余组件引入；发放奖...
-
这里我弄错了， basicNack()， requeue=false时会发到死信，但3楼那个basicAck没有这个功能
Spring Boot RabbitMQ实践
背景 我们现在有两个主要的系统一个是活动系统一个是奖品系统，活动系统会调用奖品系统发放奖励。 最开始两个之间只通过http直接调用，优点：开发成本低，没有多余组件引入；发放奖...
-
还有这里
catch (Exception dbe) {
logger.error("保存异常MQ消息到数据库异常，放到死性队列，消息体：{}", JSON.toJSONString(sendMessage), dbe);
// 确认消息将消息放到死信队列
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, false);
}
确认了消息，消息怎么会发到死信队列。。Spring Boot RabbitMQ实践
背景 我们现在有两个主要的系统一个是活动系统一个是奖品系统，活动系统会调用奖品系统发放奖励。 最开始两个之间只通过http直接调用，优点：开发成本低，没有多余组件引入；发放奖...
-
这里有问题啊
catch (Exception e) {
logger.error("MQ消息处理异常，消息体:{}", message.getMessageProperties().getCorrelationIdString(), JSON.toJSONString(sendMessage), e);
// 确认消息已经消费消费失败，将消息发给下一个消费者
channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
}
确认了消息。消息根本不会发给下一个消费者了啊Spring Boot RabbitMQ实践
背景 我们现在有两个主要的系统一个是活动系统一个是奖品系统，活动系统会调用奖品系统发放奖励。 最开始两个之间只通过http直接调用，优点：开发成本低，没有多余组件引入；发放奖...
-
Spring Boot RabbitMQ快速入门 (2)
Prefetch设置 当我们进入RabbitMQ的GUI管理界面, 点入某个队列查看消费者的属性时, 有记录如下 上面的表格说明消息的消费需要手工ack, 且是公平分发的. ...
-
建立 project（maven），然后在其中 建立 module（maven），
与 直接建立 project（maven），有什么区别吗
楼主公司用mac开发吗 棒棒哒IntelliJ IDEA 2017创建基于maven的web项目
开始上班了，公司里用的是IDEA来进行项目开发，因此自己有必要了解学习下IDEA的使用。 在此记录一下使用IntelliJ IDEA 2017来创建基于maven的web项目...
-
楼主写的不错 赞👍。
IntelliJ IDEA 2017创建基于maven的web项目
开始上班了，公司里用的是IDEA来进行项目开发，因此自己有必要了解学习下IDEA的使用。 在此记录一下使用IntelliJ IDEA 2017来创建基于maven的web项目...
-
「真实故事｜女大学生被拐卖之后……」
01 有时候，人命运的转变就是在一瞬间。 假如11年前，素月不曾萌生过去乡村支教的念头，也就不会在辗转的旅途中被人掳走，被卖到那个荒昧闭塞的小山村。 那一年，她才21岁，还是...
-
@英勇青铜5 是 看楼主简介像是做andriod的
期待楼主的新文章(☆▽☆)(☆▽☆)(ง •_•)งJava基础学习——HashMap原理学习
学习资料： Java编程思想 P492 忍不住吐槽，这书翻译的真是 。。。 1. SimpleHashMap 简易HashMap <p> private static fi...
-
难得楼主还不是java 主业
对比楼主很惭愧啊Java基础学习——HashMap原理学习
学习资料： Java编程思想 P492 忍不住吐槽，这书翻译的真是 。。。 1. SimpleHashMap 简易HashMap <p> private static fi...
