ActiveMQ的消息事务 消息事务，是保证消息传递原子性的一个重要特性，和JDBC的事务特征类似。 一个事务性发送，其中一组消息要么能够全部保证到达服务器，要么都不到达服务器。生产者，消费者与消息服务器都支持事务性。ActiveMQ得事务主要偏向在生产者得应用。 ActiveMQ消息事务流程图： ...
分类：
其他好文 时间：
2020-02-16 12:38:59
阅读次数：
95
消息队列的基本原理 消息队列是基于队列实现的，存储具有特定格式的消息数据。消息队列包括生产者，消息队列以及消费者。 RocketMQ的原理与工作机制 架构图 NameServer Cluster：名字服务器集群，类似于kafka中的zookeeper，提供分布式协调与管理的功能 Producer C ...
分类：
其他好文 时间：
2020-02-15 11:46:33
阅读次数：
63
点对点（P2P） 结构 创建生产者和消费者两个springboot工程 导入依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-activemq</artifactId ...
分类：
编程语言 时间：
2020-02-14 20:21:17
阅读次数：
72
1.消息中间件：采用异步通讯防止，支持点对点以及发布订阅模式，可以解决高并发问题 传统调用接口，可能发生阻塞，重复提交，超时等等问题，可以利用消息中间件发送异步通讯请求 点对点：生产者 消息队列 消费者 发布订阅：生产者 主题 消费者1 消费者N 2.windows安装ActiveMQ 2.1 解压 ...
分类：
其他好文 时间：
2020-02-13 16:44:48
阅读次数：
67
Routing(路由模式) 生产者将消息发送到direct交换器,在绑定队列和交换器的时候有一个路由key,生产者发送的消息会指定一个路由key,那么消息只会发送到相应key相同的队列,接着监听该队列的消费者消费信息. Direct exchange 会把消息路由到那些binding key与rou ...
分类：
其他好文 时间：
2020-02-13 00:31:49
阅读次数：
345
RabbitMQ Work Queues(工作队列) 工作队列模式为一个生产者对应多个消费者，但是只有一个消费者获得消息，即一个队列被多个消费者监听，但一条消息只能被其中的一个消费者获取 代码如下： 生产者代码： ? 消费者代码 1 生产者将消息交个交换机 2 交换机交给绑定的队列 3 队列由多个消 ...
分类：
其他好文 时间：
2020-02-13 00:31:33
阅读次数：
83
Publish/Subscribe(发布订阅模式) 发布订阅模式其实就是生产者将数据发送到交换机，交换机将所有的消息发送到每个绑定的队列中，因此 在发布消息时可以只先指定交换机的名称，交换机的声明的代码可以放到消费者端进行声明，队列的声明也放在消费者端来声明 Exchange类型 fanout fa ...
分类：
其他好文 时间：
2020-02-12 23:57:04
阅读次数：
126
RabbitMQ的简单使用 RabbitMQ安装 安装步骤可以参考该网址进行安装，此处不再赘述 "安装教程" RabbitMQ的生产者消费者简单实例 创建pom工程，并引入下面依赖 生产者代码 首先定义一个链接对象 生产者代码 消费者代码 上面完成消费者和生产者代码，运行即可 RabbitMQ Sp ...
分类：
其他好文 时间：
2020-02-12 23:52:01
阅读次数：
77
消息分组通常在生产环境，我们的每个服务都不会以单节点的方式运行在生产环境，当同一个服务启动多个实例的时候，这些实例都会绑定到同一个消息通道的目标主题（Topic）上。默认情况下，当生产者发出一条消息到绑定通道上，这条消息会产生多个副本被每个消费者实例接收和处理，但是有些业务场景之下，我们希望生产者产 ...
分类：
编程语言 时间：
2020-02-12 21:58:33
阅读次数：
171
生产者：生产者是负责发送消息的 队列：队列是RabbitMQ用来存储消息的，受主机内存和磁盘大小的限制，本质上是一个消息的缓冲区。生产者可以将消息发送至队列中，消费者可以从队列中接收到消息 消费者：消费者是用来等待接收消息 生产者，消费者，代理可以驻留在不同主机或同一主机，一个应用可以是生产者也可以 ...
分类：
其他好文 时间：
2020-02-12 11:15:35
阅读次数：
77
