阅读目录
1. 启动
rabbitmq-server &
2. 队列重置(清空队列、用户等)
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl stop
rabbitmqctl reset
rabbitmqctl stop
3. 关闭
rabbitmqctl stop
4. 列举所有用户
rabbitmqctl list_users
5. 列举所有队列
rabbitmqctl list_queues
6. 添加用户
rabbitmqctl add_user user_name user_passwd
7. 设置用户角色为管理员
rabbitmqctl set_user_tags user_name administrator
8. 权限设置
rabbitmqctl set_permissions -p / user_name ".*" ".*" ".*"
6,7,8三步操作举例(添加用户admin)
sudo rabbitmqctl add_user admin admin sudo rabbitmqctl set_user_tags admin administrator sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
9. 查看状态
rabbitmqctl status
10.安装 RabbitMQWeb管理插件
rabbitmq-plugins enable rabbitmq_management
可以利用http://ip:15672查看界面状态
11.疑难杂症
11.1 症状:启动后出现
1
2
3
4
5
6
7
8
|
Error: unable to connect to node 'rabbit@idcp-mq010177080030' : nodedown
Error in log handler
==================== Event: {error,<0.9.0>, {<0.451.0>,
"** Connection attempt from disallowed node ~w ** ~n" ,
[ 'rabbitmq-cli-3355@idcp-mq010177080030' ]}}
Error: function_clause |
破解
重启服务
sudo rabbitmq-server restart
11.2 无法正常启动rabbitmq-server
Error: unable to connect to node rabbit@nu5i12294: nodedown ERROR: epmd error for host nu5i12294: address (cannot connect to host/port
解决:
http://yodi.polatic.me/solve-rabbitmq-error-epmd-error-for-host-ubuntu-address-cannot-connect-to-hostport/
判断hostname 与/host/hosts里面的ip和主机名一致
例如,ip为10.10.10.10
检查hostname:
$hostname host_jihite
检查 /etc/hosts
10.10.10.10 host_jihite
12. RabbitMQ 集群与高可用配置
http://88250.b3log.org/rabbitmq-clustering-ha
相关推荐
- **RabbitMQ**: 专门设计的消息队列系统,支持多种协议,具有丰富的功能和高可用性。 - **Kafka**: 专为大规模日志收集和传输设计,适合处理大量实时数据。 通过上述方法,你可以使用Redis构建一个简单而实用的...
Redis作为一款高性能的键值数据库,常被用于构建消息队列,因为它提供了丰富的数据结构(如列表、集合、通道等)和原子操作,非常适合于实现消息的发布与订阅、入队与出队等操作。 在PHP中,我们可以使用Predis或...
RabbitMQ是一个开源的消息代理和队列服务器,它基于AMQP(Advanced Message Queuing Protocol)协议,被广泛用于处理分布式系统中的异步任务和消息传递。在这个“RabbitMQ相关安装包”中,可能包含了RabbitMQ服务器...
在IT行业中,软件开发与运维过程中常常涉及到多个关键组件的部署和配置,这些组件包括Java开发环境(JDK)、Web服务器(Tomcat)、数据库(MySQL)以及消息队列(RabbitMQ)。本教程集合了这些核心组件的安装、启动...
- **RabbitMQ Shovel Plugin:** 用于在不同队列间转移消息。 - **RabbitMQ Streams Plugin:** 支持大规模实时数据流处理。 **57. 如何安装和配置RabbitMQ的插件?** - 通过`rabbitmq-plugins enable`命令启用...
在消息队列中,消费者(订阅者)通过调用此命令获取并处理队列头部的消息。 以下是一个简单的PHP+Redis消息队列实现步骤: 1. **连接Redis**: 使用`new Redis()`创建Redis实例,并通过`connect()`方法连接到服务器...
在实际项目中,可以根据具体需求选择合适的队列实现,例如RabbitMQ、Beanstalkd或其他NoSQL数据库。同时,不断优化队列处理策略,如合理设置Redis缓存过期时间,可以进一步提高系统的整体性能。
如果需要更可靠的服务,可以考虑使用专门的延时消息中间件,如RabbitMQ的TTL(Time To Live)特性,或是Kafka配合专门的延时队列插件。 总的来说,Golang和Redis结合可以轻松地搭建一个延时消息队列的原型,适用于...
对于消息队列的处理,Redis提供了`rpush`和`lpop`(或`blpop`)等命令来实现先进先出(FIFO)的队列功能,例如: ```python redisClient.rpush('queue', 'msg1', 'msg2') first_msg = redisClient.lpop('queue') ```...
消息队列,如RabbitMQ、Kafka或Apache ActiveMQ,是分布式系统中用于异步处理和解耦组件的一种机制。它允许不同的服务之间通过发送和接收消息来通信,而无需直接相互依赖,从而提高系统的可扩展性和可靠性。 Redis...
不同的消息队列发出的确认消息形式不同,rabbitmq发送的是一个ack确认消息,rocketmq是返回的一个consume_success成功 >标志,kafka则是有个offet的概念。 > >造成重复消息的原因是因为网络传输的故障导致确认消息...
Java后端开发面试题涉及到多个核心领域,包括Redis的使用场景和持久化机制、Docker与虚拟机的区别、MySQL调优、以及消息队列RabbitMQ的基础知识。下面将逐一详细解析这些知识点。 1. Redis应用场景: - a. 数据...
本项目采用了SpringBoot作为核心框架,MySQL作为数据库,Redis用于缓存和分布式锁,RabbitMQ处理消息队列,Guava提供了一些实用工具类,共同协作以实现高效、稳定且可扩展的系统。 首先,SpringBoot是Spring框架的...
RabbitMQ是一种基于AMQP协议的消息队列服务,用于解耦生产者和消费者。在Java中,你可以使用RabbitMQ的Java客户端库`rabbitmq-client`来发送和接收消息。例如,使用`Channel`对象创建交换器和队列,然后使用`...
Erlang是一种并发性极强的编程语言,特别适合构建分布式系统,尤其是像RabbitMQ这样的消息队列系统。RabbitMQ是一个开源的消息代理和队列服务器,广泛应用于微服务架构中,用于处理异步任务和解耦系统组件。 `otp_...
Redis的发布/订阅模式可以实现简单的消息队列功能,但不适合大量消息堆积和持久化需求,对于复杂的消息队列场景,通常会选用RabbitMQ或Kafka。 八、Redis与Java的集成 在Java开发中,通常使用Jedis或Lettuce客户端...
压缩包子文件列表中的“rabbitmq-server-3.7.15.exe”是RabbitMQ的安装程序,RabbitMQ是一个开源的消息代理软件,基于AMQP协议,常与Redis一起使用,构建微服务架构中的消息队列系统。当一个应用程序发送消息到...
- **轻量级**:相比于完整的消息队列服务(如RabbitMQ、Kafka),Redis的Pub/Sub更简单,适合低延迟、实时性要求高的场景。 - **非持久化**:订阅者错过消息是常态,因为Redis不会存储未被消费的消息。如果订阅者...