PHP 代码分享
MongoDB 教程
正则表达式
jQuery 教程
JavaScript 代码片段
PHP7 教程
目录一、RabbitMQ简介(1) AMQP协议(2)AMQP专业术语(3)RabbitMQ整体架构二、安装RabbitMQ三、RabbitMQ六种队列模式在.NetCore中使用(1)简单队列(2)工作队列模式(3)发布订阅模式(4)路由模式（推荐使用）(5)主题模式(6)RPC模式总结一、RabbitMQ简介是一个开源的消息代理和队列服务器，用来通过普通协议在完全不同的应用之间共享数据，RabbitMQ是使用Erlang(高并发语言)语言来编写的，并且RabbitMQ是基于AMQP协议的。(1) AMQ...
继续阅读 >
目录一、环境准备二、简单模式三、工作队列模式四、广播模式（Fanout）五、直连模式（Direct）六、通配符模式（Topic）一、环境准备1、pom依赖<!--父工程依赖--><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.3.6.RELEASE</version></parent><dependencies><dependency><groupId>org.springfram...
继续阅读 >
RabbitMQ-交换机1、交换机是干什么的？消息(Message)由Client发送，RabbitMQ接收到消息之后通过交换机转发到对应的队列上面。Worker会从队列中获取未被读取的数据处理。1、交换机的种类RabbitMQ包含四种不同的交换机类型：Directexchange：直连交换机，转发消息到routigKey指定的队列Fanoutexchange：扇形交换机，转发消息到所有绑定队列（速度最快）Topicexchange：主题交换机，按规则转发消息（最灵活）Heade...
继续阅读 >
RabbitMQManagement插件还提供了基于RESTful风格的HTTPAPI接口来方便调用。一共涉及4种HTTP方法：GET、PUT、DELETE和POST。GET方法一般用来获取如集群、节点、队列、交换器等信息。PUT方法用来创建资源，如交换器、队列之类的。DELETE方法用来删除资源。POST方法也是用来创建资源的，与PUT不同的是，POST创建的是无法用具体名称的资源。比如绑定关系（bindings）和发布消息（publish）无法指定一个具体的名称。点击Web管理界面左...
继续阅读 >
目录1.浅浅道来1.1什么是中间件？1.1.1分布式的概念（补充）1.2什么是消息中间件/消息队列（MQ）1.2.1消息队列应用场景1.3什么是RabbitMQ2.下载与安装2.1手动安装2.1.1下载安装过程2.1.2配置Web界面管理2.1.3简单介绍Web界面管理2.2Docker安装2.2.1配置yum2.2.2安装docker2.2.3安装RabbitMQ（任选其一）3.RabbitMQ协议和模型3.1协议3.1.1什么是协议？3.1.2RabbitMQ的AMQP协议3.1.3架构模型4.Ja...
继续阅读 >
对于消息发布者而言它只负责把消息发布出去，甚至它也不知道消息是发到哪个queue，消息通过exchange到达queue，exchange的职责非常简单，就是一边接收发布者的消息一边把这些消息推到queue中。而exchange是怎么知道消息应该推到哪个queue呢，这就要通过绑定queue与exchange时的routingkey了，通过代码进行绑定并且指定routingkey，下面有一张关系图,p(发布者)—>x(exchange)bindding(绑定关系也就是我们的routingkey)红色代表...
继续阅读 >
目录七种模式介绍与应用场景 简单模式（HelloWorld）工作队列模式（Workqueues）订阅模式（Publish/Subscribe）路由模式（Routing）主题模式（Topics）远程过程调用（RPC）发布者确认（PublisherConfirms）代码演示：简单模式工作队列模式发布订阅模式路由模式主题模式四种交换机介绍总结参考七种模式介绍与应用场景 简单模式（HelloWorld）做最简单的事情，一个生产者对应一个消费者，RabbitMQ相当于一个消息代理，...
继续阅读 >
目录RabbitMQ安装和运行MQ服务器设置创建用户创建虚拟机实现发送短信rabbit-mqservice-baseservice-core中发送消息service-sms中监听消息测试RabbitMQ安装和运行#安装rpm-ivherlang-21.3.8.9-1.el7.x86_64.rpmrpm-ivhsocat-1.7.3.2-1.el6.lux.x86_64.rpmrpm-ivhrabbitmq-server-3.8.1-1.el7.noarch.rpm#卸载#rpm-qa|greprabbitmq#启用管理插件rabbitmq-pluginsenablerabbitmq_management#启动RabbitMQsystemctl...
继续阅读 >
一、模式说明WorkQueues与入门程序的简单模式相比，多了一个或一些消费端，多个消费端共同消费同一个队列中的消息。应用场景：对于任务过重或任务较多情况使用工作队列可以提高任务处理的速度。二、代码WorkQueues与入门程序的简单模式的代码是几乎一样的：可以完全复制，并复制多一个消费者进行多个消费者同时消费消息的测试。①生产者packagecom.itheima.rabbitmq.work;importcom.itheima.rabbitmq.util.ConnectionUti...
继续阅读 >
前言Celery是一个异步任务队列。它可以用于需要异步运行的任何内容。RabbitMQ是Celery广泛使用的消息代理。在本这篇文章中，我将使用RabbitMQ来介绍Celery的基本概念，然后为一个小型演示项目设置Celery。最后，设置一个CeleryWeb控制台来监视我的任务基本概念 来！看图说话：BrokerBroker(RabbitMQ)负责创建任务队列，根据一些路由规则将任务分派到任务队列，然后将任务从任务队列交付给workerConsumer(CeleryWo...
继续阅读 >
最近在做一任务时，遇到需要延迟处理的数据，最开始的做法是现将数据存储在数据库，然后写个脚本，隔五分钟扫描数据表再处理数据，实际效果并不好。因为系统本身一直在用RabbitMQ做异步处理任务的中间件，所以想到是否可以利用RabbitMQ实现延迟队列。功夫不负有心人，RabbitMQ虽然没有现成可用的延迟队列，但是可以利用其两个重要特性来实现之：1、TimeToLive(TTL)消息超时机制；2、DeadLetterExchanges（DLX）死信队列。下面...
继续阅读 >