Golang在CentOS上如何配置消息队列_运维文库_资讯中心

发布时间:2026-04-27 18:46:03

阅读量:1

在CentOS上配置消息队列，您可以选择多种消息队列系统，如RabbitMQ、Kafka、ActiveMQ等。以下是在CentOS上安装和配置RabbitMQ的步骤：

安装RabbitMQ

更新系统包
```
sudo yum update -y
```
安装Erlang RabbitMQ需要Erlang环境，可以使用以下命令安装：
```
sudo yum install -y erlang
```
添加RabbitMQ仓库 创建一个新的YUM仓库文件：
```
sudo tee /etc/yum.repos.d/rabbitmq.repo <<EOF
```

[rabbitmq-server] name=RabbitMQ Repository baseurl=https://packagecloud.io/rabbitmq/rabbitmq-server/el/7/$basearch repo_gpgcheck=1 enabled=1 gpgcheck=1 gpgkey=https://packagecloud.io/rabbitmq/rabbitmq-server/gpgkey EOF


4. **安装RabbitMQ服务器**
```bash
sudo yum install -y rabbitmq-server

启动RabbitMQ服务
```
sudo systemctl start rabbitmq-server
```
设置开机自启动
```
sudo systemctl enable rabbitmq-server
```

配置RabbitMQ

启用管理插件

sudo rabbitmq-plugins enable rabbitmq_management

创建用户并设置权限 创建一个新用户并设置密码：

sudo rabbitmqctl add_user your_username your_password

设置用户权限：

sudo rabbitmqctl set_permissions -p / your_username ".*" ".*" ".*"

设置用户角色（可选）：

sudo rabbitmqctl set_user_tags your_username administrator

访问管理界面 打开浏览器并访问 http://your_server_ip:15672/，使用您创建的用户登录。

测试RabbitMQ

发送消息 使用RabbitMQ自带的命令行工具发送消息：

sudo rabbitmqadmin publish routing_key="test_queue" payload="Hello, RabbitMQ!"

接收消息 使用RabbitMQ自带的命令行工具接收消息：
```
sudo rabbitmqadmin get queue=test_queue
```

其他消息队列系统

如果您选择其他消息队列系统，如Kafka或ActiveMQ，安装和配置步骤会有所不同。以下是简要概述：

Kafka

安装Java Kafka需要Java环境，可以使用以下命令安装：
```
sudo yum install -y java-1.8.0-openjdk-devel
```

下载并解压Kafka

wget https://archive.apache.org/dist/kafka/2.8.0/kafka_2.13-2.8.0.tgz
sudo tar -xzf kafka_2.13-2.8.0.tgz -C /opt
sudo ln -s /opt/kafka_2.13-2.8.0 /opt/kafka

启动Zookeeper和Kafka服务器

sudo /opt/kafka/bin/zookeeper-server-start.sh /opt/kafka/config/zookeeper.properties &
sudo /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties &

创建主题

sudo /opt/kafka/bin/kafka-topics.sh --create --topic test_topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1

发送和接收消息

sudo /opt/kafka/bin/kafka-console-producer.sh --topic test_topic --bootstrap-server localhost:9092
sudo /opt/kafka/bin/kafka-console-consumer.sh --topic test_topic --from-beginning --bootstrap-server localhost:9092

ActiveMQ

下载并解压ActiveMQ

wget https://archive.apache.org/dist/activemq/5.16.3/apache-activemq-5.16.3-bin.tar.gz
sudo tar -xzf apache-activemq-5.16.3-bin.tar.gz -C /opt
sudo ln -s /opt/apache-activemq-5.16.3 /opt/activemq

启动ActiveMQ
```
sudo /opt/activemq/bin/activemq start
```
访问管理界面 打开浏览器并访问 http://your_server_ip:8161/admin，使用默认用户名和密码（admin/admin）登录。
发送和接收消息 可以使用ActiveMQ提供的命令行工具或编写客户端代码进行消息的发送和接收。

希望这些步骤能帮助您在CentOS上成功配置消息队列系统。

以上就是关于“Golang在CentOS上如何配置消息队列”的相关介绍，筋斗云是国内较早的云主机应用的服务商，拥有10余年行业经验，提供丰富的云服务器、租用服务器等相关产品服务。云服务器资源弹性伸缩，主机vCPU、内存性能强悍、超高I/O速度、故障秒级恢复；电子化备案，提交快速，专业团队7×24小时服务支持！

简单好用、高性价比云服务器租用链接：https://www.jindouyun.cn/product/cvm