网上的教程虽然多,但是提供demo的比较少,或者没有详细的说明,因此,本人就照着网上的教程做了几个demo,并把代码托管在码云,供有需要的参考。 项目地址:https://gitee.com/dhclly/IceDog.RabbitMQ 项目属性: .net core , .net rabbit m ...
分类:
其他好文 时间:
2019-08-10 19:04:07
阅读次数:
107
//上面测试的下单消息是direct类型消息的,现在创建一个topic消息 //测试结果: //如何在rabbitMq管理页面查看没有还没被消费的消息信息: 通过界面发送Mq消息,场景,如日志发现某条消息没有发送,可以在这里发送回去: ...
分类:
编程语言 时间:
2019-08-10 14:33:59
阅读次数:
351
今天只看看原理,下一节看项目怎么集成mq进行解决分布式事物。 1、什么情况下会使用到分布式事物? 举例说明:现有一个支付系统,因为项目使用的是微服务框架,有订单模块和支付模块两个模块。生产者进行订单的下单操作购买100元,这时候订单表数据应该是新增一条,然后支付模块的个人账户资金应该是加100元。同 ...
分类:
其他好文 时间:
2019-08-10 10:10:56
阅读次数:
90
Kafka幂等性是所有kafka使用者需要解决的问题,也是BAT等大厂MQ必问知识点 ...
分类:
其他好文 时间:
2019-08-10 09:42:45
阅读次数:
85
根据自己收集的还有一部分自己面试的整理出来,希望能帮到面试的兄弟(2019年)。 用友网络 1、你们用微服务有什么好处呢? 2、微服务之间的事务是怎么处理的?怎么回滚? 3、MQ用的什么?MQ的事务是怎么做的? 4、Object里面有什么方法?这些方法什么时候需要用到?equals方法和hashCo ...
分类:
编程语言 时间:
2019-08-08 13:22:07
阅读次数:
361
引入MQ后的架构演进MQ的选择消息队列对比参照表:RocketMQvs.ActiveMQvs.Kafka:参考至:消息队列对比参照表RocketMQvs.ActiveMQvs.KafkaCentOS7上搭建RocketMQ环境要求:CentOS7.264位JDK1.8+4G+的可用磁盘空间1、下载RocketMQ的二进制包,我这里使用的是4.5.1版本,下载地址如下:http://rocketmq
分类:
编程语言 时间:
2019-08-03 23:33:22
阅读次数:
202
1、什么是MQ? MQ全称为Message Queue, 顾名思义,即消息队列,它是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表,生产者不断的往消息队列中不断写入消息,消费者则可以读取或者订阅队列中的消息,生产者和消费者不需要知道对方是谁,一个负责发消息,一个负责收消息, ...
分类:
其他好文 时间:
2019-08-03 11:20:22
阅读次数:
87
消息无序产生的原因消息队列,既然是队列就能保证消息在进入队列,以及出队列的时候保证消息的有序性,显然这是在消息的生产端(Producer),但是往往在生产环境中有多个消息的消费端(Consumer),尽管消费端在拉取消息时是有序的,但各个消息由于网络等方面原因无法保证在各个消费端中处理时有序。场景分析先后两次修改了商品信息,消息A和消息B先后同步写入MySQL,接着异步写入消息队列中发送消息,此时
分类:
其他好文 时间:
2019-07-30 12:54:41
阅读次数:
93
MQ (IBM MQ) MQ传递主干,在世界屡获殊荣。 它帮您搭建企业服务总线(ESB)的基础传输层。IBM WebSphere MQ为SOA提供可靠的消息传递。它为经过验证的消息传递主干, 全方位、 多用途的数据传输, 并帮助您搭建企业服务总线的传输基础设施。 消息队列(MQ)是一种应用程序对应用 ...
分类:
其他好文 时间:
2019-07-29 20:22:16
阅读次数:
488