rabbitmq实战指南

简介: MQ消息队列中间件,P2P,PUB/SUB 生产者消费者模型erlang中实现AMQP1 安装配置2 rabbitmqctl status3 增加用户??rabbitmqctl add_user root root 增加用户rabbitmqctl set_permissions -p / root ".

MQ消息队列中间件,P2P,PUB/SUB 生产者消费者模型
erlang中实现AMQP
1 安装配置
2 rabbitmqctl status
3 增加用户??
rabbitmqctl add_user root root 增加用户
rabbitmqctl set_permissions -p / root "." "." ".*"
rabbitmqctl set_user_tags root administrator

rabbitmqctl list_queues name messages_ready
D:持久化队列


vhost之间是绝对独立的
rabbitmqctl add_vhost vhost1
rabbitmqctl list_vhosts name tracing
rabbitmqctl trace_on
rabbitmqctl delete_vhost aa
rabbitmqctl set_permissions -p vhost user conf write read
rabbitmqctl set_permissions -p vhost1 root "." "." ".*"
rabbitmqctl clear_permissions -p vhosts root
rabbitmqctl list_permissions -p vhost1
rabbitmqctl list_vhosts -q -t xx

rabbitmqctl add_user username password
rabbitmqctl change_user username password
rabbitmqctl authenticate_user username password
rabbitmqctl delete_user username
rabbitmqctl list_users
rabbit默认的角色:tag
none,management:web policymaker:web,policy,parameter
monitoring, administrator:all
rabbitmqctl set_user_tags userename management,policymaker,monitoring

开启web管理端插件:
rabbitmq-plugins enable rabbitmq_management
rabbitmq-plugins list
web:http://ip:15672

用-detach启动的,没有pidfile
rabbitmqctl shutdown
rabbitmqctl stop_app
rabbitmqctl start_app
rabbitmqctl reset
rabbitmqctl force_reset
日志lunxun
rabbitmqctl rotate_logs .1

集群

rabbitmqctl cluster_status
rabbitmqctl stop_app
rabbitmqctl join_cluster rabbit@node2
rabbitmqctl start_app
rabbitmqctl set_cluster_name cluster_name

rabbitmqctl list_queues -p vhosts x1 x2 x3 ..

rabbitmqctl report > a.txt
./rabbitmqadmin --help


rabbitmq-env.conf 配置文件
NODENAME=
NODE_PORT=5672
CONFIG_FILE=/XXX
RABBITMQ_NODE_IP_ADDRESS
RABBITMQ_NODE_PORT 5672
RABBITMQ_DIST_PORT 25672
RABBITMQ_NODENAME
RABBITMQ_CONF_ENV_FILE
RABBITMQ_CONFIG_FILE #没有.config
RABBITMQ_MNESIA_BASE
RABBITMQ_MNESIA_DIR
RABBITMQ_LOG_BASE
RABBITMQ_LOGS
RABBITMQ_PLUGINS_DIR
----常用配置
CONFIG_FILE=/rabbitmq/rabbitmq
CONFIG_ENV_FILE=/rabbitmq/rabbitmq-env.conf
LOG_BASE=/rabbitmq/logs
MNESIA_BASE=/rabbitmq/mnesia

rabbitmqctl set_parameter -p vhost
rabbitmqctl list_parameters -p /
rabbitmqctl clear_parameter -p vhost
rabbitmqctl list_global_parameters

rabbitmqctl set_policy --apply-to exchanges --prority 1 p1


rabbitmq集群的搭建
节点的删除、添加、更新
--
rabbitmq单机多节点的配置
监控
rabbitmq 通过3种方式实现分布式部署:集群、federation、shovel


rabbitmq-plugins enable rabbitmq_federation
rabbitmq-plugins enable rabbitmq_federation_management

rabbitmq-plugins enable rabbitmq_shovel
rabbitmq-plugins enable rabbitmq_shovel_management

集群种erlang和rabbitmq的版本要一致
shovel和federation的版本可以随意


rabbitmq消息堆积处理
5672 25672

处理网络分区
配置自动处理网络分区:pause-minority ,autoheal


img_0bbacd7e1762533aac70ab5812004015.png
image.png

firehose,rabbitmq_tracing插件

rabbitmq负载均衡

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
6月前
|
消息中间件 负载均衡 Java
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息消费长轮训机制体系的原理分析
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息消费长轮训机制体系的原理分析
98 0
|
6月前
|
消息中间件 Java RocketMQ
RocketMQ实战教程之RocketMQ安装
这是一篇关于RocketMQ安装的实战教程,主要介绍了在CentOS系统上使用传统安装和Docker两种方式安装RocketMQ。首先,系统需要是64位,并且已经安装了JDK 1.8。传统安装包括下载安装包,解压并启动NameServer和Broker。Docker安装则涉及安装docker和docker-compose,然后通过docker-compose.yaml文件配置并启动服务。教程还提供了启动命令和解决问题的提示。
|
1月前
|
消息中间件 数据采集 中间件
RabbitMQ的使用—实战
RabbitMQ的使用—实战
|
6月前
|
消息中间件 前端开发 数据库
RocketMQ实战教程之MQ简介与应用场景
RocketMQ实战教程介绍了MQ的基本概念和应用场景。MQ(消息队列)是生产者和消费者模型,用于异步传输数据,实现系统解耦。消息中间件在生产者发送消息和消费者接收消息之间起到邮箱作用,简化通信。主要应用场景包括:1)应用解耦,如订单系统与库存系统的非直接交互;2)异步处理,如用户注册后的邮件和短信发送延迟处理,提高响应速度;3)流量削峰,如秒杀活动限制并发流量,防止系统崩溃。
|
2月前
|
消息中间件 缓存 Java
RocketMQ的JAVA落地实战
RocketMQ作为一款高性能、高可靠、高实时、分布式特点的消息中间件,其核心作用主要体现在异步处理、削峰填谷以及系统解耦三个方面。
168 0
|
3月前
|
消息中间件 运维 Java
【揭秘RabbitMQ背后的秘密!】如何确保消息正确发送及消费?深入剖析与实战指南!
【8月更文挑战第24天】本文通过一个电商平台订单确认消息的案例,深入探讨了如何确保消息准确无误地发送到 RabbitMQ 以及如何保证消息被正确处理。为确保消息成功发送,文中介绍了使用发布确认、设置重试机制及事务处理等策略;并通过 Java 代码示例展示了如何实施这些策略。此外,还讨论了确保消息正确消费的方法,包括使用确认机制、设置超时及异常处理等,并提供了相应的 Java 示例代码。这些技术和策略有助于提升系统的稳定性和可靠性,对日常运维和性能优化具有重要意义。
59 1
|
4月前
|
消息中间件 新零售 弹性计算
云消息队列 RabbitMQ 版入门训练营,解锁对比开源优势与零基础实战
欢迎加入「云消息队列 RabbitMQ 版入门训练营」。
167 14
|
3月前
|
区块链 C# 存储
链动未来:WPF与区块链的创新融合——从智能合约到去中心化应用,全方位解析开发安全可靠DApp的最佳路径
【8月更文挑战第31天】本文以问答形式详细介绍了区块链技术的特点及其在Windows Presentation Foundation(WPF)中的集成方法。通过示例代码展示了如何选择合适的区块链平台、创建智能合约,并在WPF应用中与其交互,实现安全可靠的消息存储和检索功能。希望这能为WPF开发者提供区块链技术应用的参考与灵感。
62 0
|
6月前
|
消息中间件 存储 安全
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
89 0
|
6月前
|
消息中间件 存储 Apache
RocketMQ实战教程之常见概念和模型
Apache RocketMQ 实战教程介绍了其核心概念和模型。消息是基本的数据传输单元,主题是消息的分类容器,支持字节、数字和短划线命名,最长64个字符。消息类型包括普通、顺序、事务和定时/延时消息。消息队列是实际存储和传输消息的容器,是主题的分区。消费者分组是一组行为一致的消费者的逻辑集合,也有命名限制。此外,文档还提到了一些使用约束和建议,如主题和消费者组名的命名规则,消息大小限制,请求超时时间等。RocketMQ 提供了多种消息模型,包括发布/订阅模型,有助于理解和优化消息处理。