路由发现:缓存中的路由信息什么时候更新呢? 由QueueData转topicPublishInfo的List<QueueMessage>: 选择消息队列: sendLatencyFaultEnable=false,默认不启动Broker故障延迟机制, sendLatenFaultEnable=tru ...
分类:
其他好文 时间:
2020-01-16 00:50:47
阅读次数:
93
钩子的注册: DefaultMQProducerImpl#registerSendMessageHook注册钩子处理类,可注册多个。 public SendResult sendMessage( final String addr, final String brokerName, final Me ...
分类:
其他好文 时间:
2020-01-16 00:50:30
阅读次数:
93
packagecom.adtec.mq;importjava.security.MessageDigest;publicclassmd5Utils{privateString[]hexDigits={"0","1","2","3","4","5","6","7","8","9","A","B","C","D","E","F"};publicStringmd5Digest(Stringsrc){tr
分类:
其他好文 时间:
2020-01-15 19:18:42
阅读次数:
71
文章目录 一、 Producer端重试 二、 Consumer端重试 1. Exception 2. Timeout总结 对于MQ,可能存在各种异常情况,导致消息无法最终被Consumer消费掉,因此就有了消息失败重试机制。很显示,消息重试分为2种:Producer端重试和Consumer端重试。 ...
分类:
其他好文 时间:
2020-01-15 19:11:14
阅读次数:
95
消息队列核心使用场景:削峰,解耦,异步 MQ的好处 削峰: 比如抢购秒杀,不在这个点上的时候,可能每秒只有50次请求,但是开始秒杀的时候每秒的请求数可能可以达到上万次,如果这些操作直接落点在数据库上, 拿MYSQL来说,一般MYSQL一秒最多可以处理2000条请求,一秒上万的请求基本直接就把服务器给 ...
分类:
其他好文 时间:
2020-01-14 16:30:44
阅读次数:
93
TF如何为OpenStack、Kubernetes、vCenter等编排器提供虚拟网络。
分类:
其他好文 时间:
2020-01-14 09:47:19
阅读次数:
87
FAQ Q: 如何确保消息不丢失? Q: mq 的缺点 Q: 如何避免消息重复投递或重复消费? 在消息 时,MQ 内部针对每条生产者发送的消息生成一个 inner msg id,作为去重的依据(消息投递失败并重传),避免重复的消息进入队列; 在消息 时,要求消息体中必须要有一个 bizId(对于同一 ...
分类:
其他好文 时间:
2020-01-13 19:40:08
阅读次数:
63
OpenStack基础理论云计算概述概念狭义的云计算是指IT基础设施的交付和使用模式广义的云计算是指服务的交付和使用模式云资源网络资源存储资源服务器资源云计算服务模型IaaS(基础架构即服务)提供底层IT基础设施服务,包括处理能力、存储空间、网络资源等一般面向对象是IT管理人员PaaS(平台即服务)把安装好开发环境的系统平台作为一种服务通过互联网提供给用户一般面向对象是开发人员SaaS(软件即服务
分类:
其他好文 时间:
2020-01-12 22:22:39
阅读次数:
141
SpringBoot整合RabbitMQ 入门2020-01-12 创建生产者类,并且在yml配置文件中配置5要素连接MQ yml配置文件 spring: rabbitmq: host: xx.xx.xx.xx port: 5672 virtual-host: / username: 默认guest ...
分类:
编程语言 时间:
2020-01-12 09:28:07
阅读次数:
85
一、heat编排 heat编排简单来讲,就是替代人工自动选择OpenStack自身基础架构资源,包括计算、网络和存储等资源。通过编排这些资源,用户可以得到最基本的VM。 二、heat模板 目前heat支持两种格式的模板,一种是基于JSON格式的CFN模板,另一种是基于YAML格式的HOT模板。 一个 ...
分类:
其他好文 时间:
2020-01-11 22:04:02
阅读次数:
146