RabbitMQ技术帮助文档.pdf

发布时间：2022-06-08 发布人：admin 分类：说明书资料大小：2.55M 资料格式：pdf 举报版权申诉

xuchengfeifei-10677608-4744302543396294550.pdf-第1页.png

第1页 / 共29页

xuchengfeifei-10677608-4744302543396294550.pdf-第2页.png

第2页 / 共29页

xuchengfeifei-10677608-4744302543396294550.pdf-第3页.png

第3页 / 共29页

xuchengfeifei-10677608-4744302543396294550.pdf-第4页.png

第4页 / 共29页

xuchengfeifei-10677608-4744302543396294550.pdf-第5页.png

第5页 / 共29页

xuchengfeifei-10677608-4744302543396294550.pdf-第6页.png

第6页 / 共29页

xuchengfeifei-10677608-4744302543396294550.pdf-第7页.png

第7页 / 共29页

xuchengfeifei-10677608-4744302543396294550.pdf-第8页.png

第8页 / 共29页

RabbitMQ 文档

一简介

二安装 RabbitMQ

三添加用户

3.1 账号级别

3.2 添加账号

3.2.1 命令模式

3.2.2 web 方式

3.2.2.1 访问web

3.2.2.2 添加用户

3.2.2.3 分配可以访问的虚拟主机

3.2.2.4 创建虚拟主机

3.2.2.5 给虚拟主机分配权限

3.2.2.6 给指定用户分配权限

四消息

4.1消息模式种类

4.2 pom&log4j.properties

4.3 工具类ConnectionUtil

4.2 简单模式

4.2.1 生产者

4.2.2 消费者

4.2.3 测试

4.3 work 模式

4.3.1 发送者

4.3.2 消费者1

4.3.3 消费者2

4.3.4 测试

4.4 消息的确认模式

4.5 订阅模式

4.5.1 生产者

4.5.2 消费者1

4.5.3 消费者2

4.5.4 测试

4.6 路由模式

4.6.1 生产者

4.6.2 消费者1

4.6.3 消费者2

4.6.4 测试

4.7 通配符模式

4.7.1 生产者

4.7.2消费者1

4.7.3 消费者2

4.7.4 测试

五整合 spring

5.1 spring 自动模式

5.1.1 spring 配置文件

5.1.2 接收者

5.1.3 测试类

5.1.4 启动测试

5.2 spring 手动模式

5.2.1 配置文件

5.2.2 消费者

5.2.3 确认后回调

5.2.3 失败回滚

5.2.3 生产者

5.2.4 消费者

5.2.5 启动测试

六消息持久化

6.1 生产者

6.2 消费者

6.3测试

RabbitMQ MQMessage Queue, MQ MQIBM WEBSPHERE MQ RabbitMQAMQPMozilla Public License AMQPAdvanced Message Queuing Protocol, ,, /Erlang RabbitMQ RabbitMQ centos7 1. erlang solution wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm 2. rpm -Uvh erlang-solutions-1.0-1.noarch.rpm yum install epel-release yum install erlang 3. rabbit wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.6.6/rabbitmq-server- 3.6.6-1.el7.noarch.rpm 4. rabbit yum install rabbitmq-server-3.6.6-1.el7.noarch.rpm 5. ()

vi /etc/rabbitmq/rabbitmq.config ### [{rabbit, [{loopback_users, []}]}]. 6. web (,,) rabbitmq-plugins enable rabbitmq_management 7. cd /usr/lib/rabbitmq/lib/rabbitmq_server-3.6.6/plugins wget https://dl.bintray.com/rabbitmq/community- plugins/rabbitmq_delayed_message_exchange-0.0.1.ez rabbitmq-plugins enable rabbitmq_delayed_message_exchange 8. firewall-cmd --add-port=15672/tcp --permanent firewall-cmd --add-port=5672/tcp --permanent 9. service rabbitmq-server start ### service rabbitmq-server status ### service rabbitmq-server restart # service rabbitmq-server stop 3.1

1. administrator,,, 2. monitoring,,,, 3 policymaker ,,, 4 management 5 , , 3.2 3.2.1 rabbitmqctl add_user luke luke # luke luke rabbitmqctl set_user_tags luke administrator # luke administrator 3.2.2 web web 3.2.2.1 web http://192.168.3.227:15672/ ip ip, ip guest guest guest 3.2.2.2

3.2.2.3 ,(), 3.2.2.4

3.2.2.5 3.2.2.6 http://www.rabbitmq.com/getstarted.html , 4.1

4.2 pom&log4j.properties com.rabbitmq

amqp-client 4.5.0 org.slf4j slf4j-log4j12 1.7.25 org.apache.commons commons-lang3 3.3.2 org.springframework.amqp spring-rabbit 1.7.6.RELEASE org.springframework spring-test 4.3.7.RELEASE junit junit 4.12 log4j.properties

log4j.rootLogger=DEBUG,A1 log4j.logger.com.taotao = DEBUG log4j.logger.org.mybatis = DEBUG log4j.appender.A1=org.apache.log4j.ConsoleAppender log4j.appender.A1.layout=org.apache.log4j.PatternLayout log4j.appender.A1.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss,SSS} [%t] [%c]- [%p] %m%n 4.3 ConnectionUtil public class ConnectionUtil { public static Connection getConnection() throws Exception { // ConnectionFactory factory = new ConnectionFactory(); // factory.setHost("192.168.3.227"); // factory.setPort(5672); //vhost factory.setVirtualHost("/test"); factory.setUsername("test"); factory.setPassword("test"); // Connection connection = factory.newConnection(); return connection; } } 4.2 http://www.rabbitmq.com/tutorials/tutorial-one-python.html ,

分享到：

赞收藏

资料库

RabbitMQ技术帮助文档.pdf

相关推荐

课程资源

热门标签

最新资料