Easter79 Easter79
3年前
springcloud(九):配置中心和消息总线(配置中心终结版)
我们在springcloud(七):配置中心SVN实例和refresh 中讲到,如果需要客户端获取到最新的配置信息需要执行refresh,我们可以利用webhook的机制每次提交代码发送请求来刷新客户端,当客户端越来越多的时候,需要每个客户端都执行一遍,这种方案就不太适合了。使用SpringCloudBus可以完美解决这一问题。Spring
Stella981 Stella981
3年前
Android的消息处理机制(图+源码分析)——Looper,Handler,Message
作为一个大三的预备程序员,我学习android的一大乐趣是可以通过源码学习google大牛们的设计思想。android源码中包含了大量的设计模式,除此以外,androidsdk还精心为我们设计了各种helper类,对于和我一样渴望水平得到进阶的人来说,都太值得一读了。这不,前几天为了了解android的消息处理机制,我看了Looper,Handler,
Wesley13 Wesley13
3年前
ActiveMQ与SpringMVC整合实现发送PTP和订阅发布消息功能
实现一个基于SpringMVCJMSActiveMQTomcatJDK1.8IDEA工具,Spring4.1.0和ActiveMQ5.15整合的实例,实现PTP和订阅/发布两种消息模型一 添加依赖这里我贴上我所有的依赖,其中有个坑就是springaop要用高版本,否则会报方法找不到,主要就是spring提供的jms依赖
Stella981 Stella981
3年前
SpringBoot中使用rabbitmq,activemq消息队列和rest服务的调用
1\.activemq  首先引入依赖  pom.xml文件<dependency<groupIdorg.springframework.boot</groupId<artifactIdspringbootstarteractivemq</artifactId</depe
Wesley13 Wesley13
3年前
MQTT实战之MQTT入门
MQTT入门介绍(一)一.MQTT简述MQTT(MessageQueuingTelemetryTransport,消息队列遥测传输协议),是一种基于发布/订阅(publish/subscribe)模式的"轻量级"通讯协议,该协议构建于TCP/IP协议上,由IBM在1999年发布。MQTT最大优点在
Easter79 Easter79
3年前
SpringBoot中使用rabbitmq,activemq消息队列和rest服务的调用
1\.activemq  首先引入依赖  pom.xml文件<dependency<groupIdorg.springframework.boot</groupId<artifactIdspringbootstarteractivemq</artifactId</depe
Stella981 Stella981
3年前
Kafka在哪些场景下会造成重复消费或消息丢失?
kafka消费者在消费的时候对于位移提交的具体时机的把握也很有讲究,有可能会造成重复消费和消息丢失的现象。!(https://oscimg.oschina.net/oscnet/3566bbd82538478396a25dd6e023974e.png"image.png")参考上图,当前一次poll()操作所拉取的消
Wesley13 Wesley13
3年前
3、RabbitMQ
workqueues工作队列1、模型图:!(https://oscimg.oschina.net/oscnet/bf4b370589b4954af0314d5878d56952b20.png)为什么会出现workqueues?前提:使用simple队列的时候我们应用程序在是使用消息
Stella981 Stella981
3年前
CentOS 8.2部署RabbitMQ 3.8.3 消息队列服务器
!CentOS8.2部署RabbitMQ3.8.3消息队列服务器(https://s4.51cto.com/images/blog/202012/28/4113d28f6002831262675c9d294c3bea.png?xossprocessimage/watermark,size_16,text_QDUxQ1RP5Y2a5a6i,co
Wesley13 Wesley13
3年前
Java发送和接收广播的UDP,用于探测局域网中指定类型的设备
注意这是发的广播信息,同一网段中其它机器都会收到这个信息(只有特殊的监听这类消息的机器会做出回应):SendUDP.javaimport java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;impor