1.Confirm消息确认机制 消息的确认：是指生产者投递消息后，如果Broker收到消息，则会给生产者一个应答。 生产者进行接收应答，用来确定这条消息是否正常的发送到Broker，这种方式也是消息的可靠性投递的核心保障。 生产端 public static void main(String[] a ...
分类：
其他好文 时间：
2020-05-29 13:36:50
阅读次数：
47
概述 在日常开发中，为了提高主线程的效率，往往需要采用异步调用处理，例如系统日志等。在实际业务场景中，可以使用消息中间件如RabbitMQ、RocketMQ、Kafka等来解决。假如对高可用没有太高的要求，也可以使用线程池或者队列来解决。 创建工程 创建Maven工程 修改配置文件 <project ...
分类：
编程语言 时间：
2020-05-28 18:17:10
阅读次数：
72
官网地址：https://www.rabbitmq.com/getstarted.html RabbitMQ 1.docker 安装 RabbitMQ docker pull rabbitmq:management //拉去rabbitmq管理版 //启动rabbitmq docker run -d ...
分类：
其他好文 时间：
2020-05-28 14:54:36
阅读次数：
40
建立Connection，创建Channel，注意Channel不能在线程间共享（非线程安全） 创建交换器和队列 消费者消费消息支持推和拉两种模式 推：通过consume方法订阅队列 拉：通过channel.basicGet方法获取消息 一旦consume以后，channel会被置为接收模式，直到取 ...
分类：
其他好文 时间：
2020-05-28 00:38:09
阅读次数：
65
1,安装依赖库 composer require php-amqplib/php-amqplib 地址:https://github.com/php-amqplib/php-amqplib 2，mq生产者.php include(__DIR__ . '../../public/config.php' ...
分类：
Web程序 时间：
2020-05-27 15:23:48
阅读次数：
257
AMQP相关概念, 工作模式, 发布/订阅模式, Routing路由模式, Topic通配符模式 ...
分类：
其他好文 时间：
2020-05-26 22:14:59
阅读次数：
64
安装erlang 下载rpm仓库： wget http://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm 安装rpm仓库 rpm -Uvh erlang-solutions-1.0-1.noarch.rpm 安装erl ...
分类：
其他好文 时间：
2020-05-26 13:55:14
阅读次数：
61
消息中间件概述 什么是消息中间件 MQ全称为Message Queue: 消息队列是应用程序之间的通信. 为什么要使用MQ 在项目中, 可将一些无需即时返回且耗时的操作提取出来, 进行异步处理, 而这种异步处理的方式能大大节省服务器的请求响应时间, 从而提高了系统的吞吐量. 开发中消息队列的应用场景 ...
分类：
其他好文 时间：
2020-05-26 12:39:22
阅读次数：
51
一、实现功能：当前页面点击请求后，另一个页面立即收到一条消息，用springboot+websocket+rabbitMQ实现。 二、java代码： 1、先在pom里导入需要的坐标 <!--rabbitMQ--> <dependency> <groupId>org.springframework.b ...
分类：
Web程序 时间：
2020-05-25 12:25:54
阅读次数：
131
错误截图如下： 我遇到的两种可能： 1. 端口设置的不对：15672端口是web管理界面的端口，5672才是rabbitmq的端口。检查之后端口正确。 2. virtual host虚拟主机设置的不对：我在服务端设置的为 "kings" ，springboot中设置的为 "/kings", 两者不一 ...
分类：
编程语言 时间：
2020-05-24 12:07:22
阅读次数：
83
