通过某个节点的写操作结果对后面通过其他节点的读操作可见。　　如果更新数据后，并发访问的情况下可立即感知该更新，称为强一致性　　如果允许之后部分或全部感知不到该更新，称为弱一致性。　　若在之后的一段时间（通常该时间不是固定的）后，一定可以感知到该更新，称为最终一致性。　　即是任何一个没有发生故障的节点必须在有限的时间...

　　　　一个Kafka集群中包含若干个Broker(消息实例)，Kafka支持Broker横向扩展，Broker越多，吞吐量越大，同时也包含了若干个Producer(可以是web前端产生的PageView，或者是服务器日志，系统CPU、Memory等）和若干个Consumer(消费者)以及一个zookeeper集群，K...

　　Kafkaisadistributed,partitioned,replicatedcommitlogservice。它提供了类似于JMS的特性，但是在设计实现上完全不同，此外它并不是JMS规范的实现。kafka对消息保存时根据Topic进行归类，发送消息者成为Producer,消息接受者为Consumer,此外k...

持久化：将交换机或队列数据保存到磁盘，服务器宕机或重启之后依然存在。非持久化：将交换机或队列的数据保存到内存中，服务器宕机或重启之后数据将不存在。在RabbitMQ中也提供了持久化和非持久化方式。实现方式为将durable设置为false即可。在配置文件中配置交换机或队列时配置durable="false"即可，配置方...

在SpringAMQP项目中Spring也提供了对RabbitMQ的支持，这里在之前学习SpringBoot的时候也整合过，但是今天这里使用的Spring的xml配置来整个rabbit.SpringAMQP项目地址：https://spring.io/projects/spring-amqp；下面来看看使用方式。pom...

　　 　　上图表示一个消费者消费消息之后，不讲消息直接存储到队列，而是使用两个消费者各自声明一个队列，将各自的对应的队列与交换机绑定。这样每个消费者都读取的是自身所对应的队列的所有消息，大达到了一个生产者生产消息，所有消费者都能消费的目的。　　将交换机类型设置为fanout即可实现Publish/Subscr...

　　　　这里表示一个生产者生产了消息发送到队列中，但是确有两个消费者在消费同一个队列中的消息。　　Producer如下：packagecom.wangx.rabbitmq.worker;importcom.rabbitmq.client.Channel;importcom.rabbitmq.client.Connect...

　　　　pom.xml文件<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.5.0</version>&l...

　　RabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是AMQP（高级消息队列协议）的标准实现。　　而AMQP协议则是指：即AdvancedMessageQueuingProtocol,一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。...

1、做计划，并同时写博客在四个月的时间里，我首先按照Java后端路线图（两个图结合着参考学习）安排好复习计划，每个知识点都安排一段时间。比如我可能花一天时间复习“Java反射”，两天时间复习“设计模式”，一周的时间用于复习"JVM虚拟机”。我一般会在月初做好整个月的计划，然后根据进度做一些微调。2、“写博客整合知识点”...

　　1.异步通信　　2.一对多通信　　3.做个系统的集成，同构，异构　　4.作为RPC的替代　　5.多个应用相互解耦　　6.作为事件驱动架构的幕后支撑　　7.为了提高性能的可伸缩性　　 　1.网络拓扑结构，比如;嵌入、主从复制、网络连接。　　　　2.transport协议　　　　3.service的质量，比如...

　　WebConsole方式：直接访问ActiveMQ的管理页面：http://localhost:8161/admin，默认的用户名和密码是admin/admin。具体配置在conf/jetty.xml里面，这就是我们前面例子中一直使用的方式。　　Hawtio-webManagementConsole方式：　　默认用...

　　JMSSelectors用在获取消息的时候，可以基于消息属性和Xpath语法对消息进行过滤。JMSSelectors有SQL92语义定义。以下是个Selectors的例子：　　consumer=session.createConsumer(destination,"JMSType='car'ANDweight>...

　　独有消费者：Queue中的消息是按照顺序被分发到consumer的，然而，当你有多个consumers同时从相同的queue中提取消息时，你将失去这个保证。因为这些消息是被多个线程并发的处理。有的时候，保证消息按照顺序处理是很重要的。例如：你可能不希望在插入订单操作结束之前执行更新这个订单的操作。　　ActiveM...

　　有些时候，我们需要传递Blob（BinaryLargeObjects)消息，在5.14之前，（5.12和5.13需要在jetty.xml中手动开启）可以按照如下的方式配置使用fileserver:　　配置BLOBTansferPolicy，可以在发送方的连接URI上设置，如：tcp://localhost:6161...