searchusermenu
  • 发布文章
  • 消息中心
点赞
收藏
评论
分享
原创

在云电脑上部署分布式消息服务RabbitMQ

2023-12-22 08:27:47
2
0

步骤1: 创建云电脑实例

选择你的云服务提供商并创建一个虚拟机实例。对于RabbitMQ,建议至少选择2核CPU和4GB内存的配置。确保选择一个支持的操作系统,例如Ubuntu 20.04 LTS。

步骤2: 安装RabbitMQ

登录到你的云电脑实例,然后运行以下命令来安装RabbitMQ及其依赖项。

# 添加Erlang的官方仓库,RabbitMQ依赖于Erlang运行环境
wget -O- ht*ps://packages.erlang-solutions.com/ubuntu/erlang_solutions.asc | sudo apt-key add -
echo "deb ht*ps://packages.erlang-solutions.com/ubuntu $(lsb_release -sc) contrib" | sudo tee /etc/apt/sources.list.d/erlang.list

# 更新仓库信息并安装Erlang
sudo apt update
sudo apt install -y erlang

# 添加RabbitMQ的官方APT仓库
echo "deb ht*ps://dl.bintray.com/rabbitmq-erlang/debian $(lsb_release -sc) main" | sudo tee /etc/apt/sources.list.d/rabbitmq.list
wget -O- ht*ps://w*w.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -

# 安装RabbitMQ服务器
sudo apt update
sudo apt install -y rabbitmq-server

# 启动RabbitMQ服务
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

步骤3: 配置RabbitMQ

RabbitMQ的默认配置通常就足够了,但是为了提高安全性,我们应该创建用户并设置权限。

# 启用RabbitMQ的管理插件
sudo rabbitmq-plugins enable rabbitmq_management

# 创建管理员用户(替换'admin'和'strongpassword'为你自己的用户名和密码)
sudo rabbitmqctl add_user admin strongpassword
sudo rabbitmqctl set_user_tags admin administrator
sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"

步骤4: 保护RabbitMQ

为了保护你的RabbitMQ服务器,应该设置防火墙规则来限制访问,并配置SSL/TLS。

# 限制端口访问(以UFW为例)
sudo ufw allow 5672  # RabbitMQ AMQP端口
sudo ufw allow 15672 # RabbitMQ管理界面端口

步骤5: 测试RabbitMQ

现在,我们可以测试RabbitMQ是否正常工作。我们将发送和接收一条简单的消息。

# 在RabbitMQ服务器上安装Python和Pika库
sudo apt install -y python3 python3-pip
pip3 install pika

# 创建一个Python脚本来发送消息
echo "import pika
credentials = pika.PlainCredentials('admin', 'strongpassword')
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', credentials))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(' [x] Sent \'Hello World!\'')
connection.close()" > send.py

# 创建一个Python脚本来接收消息
echo "import pika
credentials = pika.PlainCredentials('admin', 'strongpassword')
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', credentials))
channel = connection.channel()
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
    print(' [x] Received %r' % body)
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()" > receive.py

# 运行接收脚本
python3 receive.py

# 在另一个终端,运行发送脚本
python3 send.py

如果一切正常,你应该在接收脚本的终端看到 "Hello World!" 消息。

结语

部署RabbitMQ到云电脑上是一个相对简单的过程。通过这个基础的设置,你已经能够开始在你的分布式应用中使用RabbitMQ进行消息传递了。然而,这只是开始。在生产环境中,你可能需要考虑集群配置、高可用性、监控和日志管理等高级主题。希望本教程能为你提供一个良好的起点。

0条评论
0 / 1000
二进制诗人
285文章数
1粉丝数
二进制诗人
285 文章 | 1 粉丝
原创

在云电脑上部署分布式消息服务RabbitMQ

2023-12-22 08:27:47
2
0

步骤1: 创建云电脑实例

选择你的云服务提供商并创建一个虚拟机实例。对于RabbitMQ,建议至少选择2核CPU和4GB内存的配置。确保选择一个支持的操作系统,例如Ubuntu 20.04 LTS。

步骤2: 安装RabbitMQ

登录到你的云电脑实例,然后运行以下命令来安装RabbitMQ及其依赖项。

# 添加Erlang的官方仓库,RabbitMQ依赖于Erlang运行环境
wget -O- ht*ps://packages.erlang-solutions.com/ubuntu/erlang_solutions.asc | sudo apt-key add -
echo "deb ht*ps://packages.erlang-solutions.com/ubuntu $(lsb_release -sc) contrib" | sudo tee /etc/apt/sources.list.d/erlang.list

# 更新仓库信息并安装Erlang
sudo apt update
sudo apt install -y erlang

# 添加RabbitMQ的官方APT仓库
echo "deb ht*ps://dl.bintray.com/rabbitmq-erlang/debian $(lsb_release -sc) main" | sudo tee /etc/apt/sources.list.d/rabbitmq.list
wget -O- ht*ps://w*w.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -

# 安装RabbitMQ服务器
sudo apt update
sudo apt install -y rabbitmq-server

# 启动RabbitMQ服务
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

步骤3: 配置RabbitMQ

RabbitMQ的默认配置通常就足够了,但是为了提高安全性,我们应该创建用户并设置权限。

# 启用RabbitMQ的管理插件
sudo rabbitmq-plugins enable rabbitmq_management

# 创建管理员用户(替换'admin'和'strongpassword'为你自己的用户名和密码)
sudo rabbitmqctl add_user admin strongpassword
sudo rabbitmqctl set_user_tags admin administrator
sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"

步骤4: 保护RabbitMQ

为了保护你的RabbitMQ服务器,应该设置防火墙规则来限制访问,并配置SSL/TLS。

# 限制端口访问(以UFW为例)
sudo ufw allow 5672  # RabbitMQ AMQP端口
sudo ufw allow 15672 # RabbitMQ管理界面端口

步骤5: 测试RabbitMQ

现在,我们可以测试RabbitMQ是否正常工作。我们将发送和接收一条简单的消息。

# 在RabbitMQ服务器上安装Python和Pika库
sudo apt install -y python3 python3-pip
pip3 install pika

# 创建一个Python脚本来发送消息
echo "import pika
credentials = pika.PlainCredentials('admin', 'strongpassword')
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', credentials))
channel = connection.channel()
channel.queue_declare(queue='hello')
channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
print(' [x] Sent \'Hello World!\'')
connection.close()" > send.py

# 创建一个Python脚本来接收消息
echo "import pika
credentials = pika.PlainCredentials('admin', 'strongpassword')
connection = pika.BlockingConnection(pika.ConnectionParameters('localhost', 5672, '/', credentials))
channel = connection.channel()
channel.queue_declare(queue='hello')
def callback(ch, method, properties, body):
    print(' [x] Received %r' % body)
channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
print(' [*] Waiting for messages. To exit press CTRL+C')
channel.start_consuming()" > receive.py

# 运行接收脚本
python3 receive.py

# 在另一个终端,运行发送脚本
python3 send.py

如果一切正常,你应该在接收脚本的终端看到 "Hello World!" 消息。

结语

部署RabbitMQ到云电脑上是一个相对简单的过程。通过这个基础的设置,你已经能够开始在你的分布式应用中使用RabbitMQ进行消息传递了。然而,这只是开始。在生产环境中,你可能需要考虑集群配置、高可用性、监控和日志管理等高级主题。希望本教程能为你提供一个良好的起点。

文章来自个人专栏
服务器指南
285 文章 | 1 订阅
0条评论
0 / 1000
请输入你的评论
0
0