0


【动力节点】最新rabbitmq笔记-1-6章What is RabbitMQ?

1. What is RabbitMQ?

1.1简介

动力节点最新RabbitMQ视频
RabbitMQ是一个广泛使用的消息服务器,采用Erlang语言编写,是一种开源的实现 AMQP(高级消息队列协议)的消息中间件;
RabbitMQ最初起源于金融系统,它的性能及稳定性都非常出色;
AMQP协议(http://www.amqp.org),即 Advanced Message Queuing Protocol,高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计;
我们学的协议有哪些:(http、ftp)

1.2 相关网址

| 官网:https://www.rabbitmq.com
Github:https://github.com/rabbitmq

1.3 消息中间件(MQ=Message Queue)

简单来说,消息中间件就是指保存数据的一个容器(服务器),可以用于两个系统之间的数据传递。
消息中间件一般有三个主要角色:生产者、消费者、消息代理(消息队列、消息服务器);


rabbitmq-java-client rabbitmq-server rabbitmq-java-client
生产者发送消息到消息服务器,然后消费者从消息代理(消息队列)中获取数据并进行处理;

1.4 常用的消息中间件

目前比较主流的几个消息中间件:

|

  • RabbitMQ
  • kafka(大数据领域)
  • RocketMQ(阿里巴巴开源)献给Apache组织
  • pulsar(最近一两年流行起来的) | | — |

2. MQ(Message Queue)的应用场景

2.1 异步处理

下订单:下订单–》加积分–》发红包–》发手机短信

下订单—向MQ 发消息–》积分系统,红包系统,手机短信系统接收消息

同步是阻塞的(会造成等待),异步是非阻塞的(不会等待);
大流量高并发请求、批量数据传递,就可以采用异步处理,提升系统吞吐量;

2.2系统解耦

多个系统之间,不需要直接交互,通过消息进行业务流转;

2.3 流量削峰

高负载请求/任务的缓冲处理;

2.4日志处理

主要是用kafka这个服务器来做;
日志处理是指将消息队列用于在日志处理中,比如Kafka解决大量日志传输的问题;
loger.info(…)
ELK 日志处理解决方案:
loger.error(…) -->logstash收集消息–> 发送消息的kafka --> elastic search (es) -->Kibana ELK日志处理平台

3. RabbitMQ运行环境搭建

RabbitMQ是使用Erlang语言开发的,所以要先下载安装Erlang

3.1 Erlang及RabbitMQ安装版本的选择

下载时一定要注意版本兼容性
版本兼容说明地址:https://www.rabbitmq.com/which-erlang.html
我们选择的版本

3.2下载Erlang

Erlang官网
https://www.erlang.org/
Linux下载:
wget https://github.com/erlang/otp/releases/download/OTP-25.1.1/otp_src_25.1.1.tar.gz
说明:wget 是linux命令,可以用来下载软件

3.3 安装Erlang

3.3.1 安装erlang前先安装Linux依赖库

yum -y install make gcc gcc-c++ kernel-devel m4 ncurses-devel openssl-devel
说明:yum -y install 安装linux的一些依赖库的命令 ,-y表示自动确认;

3.3.2 解压erlang压缩包文件

tar -zxvf otp_src_25.1.1.tar.gz

3.3.3 配置

切换到解压的目录下,运行相应命令

| cd otp_src_25.1.1
./configure

3.3.4 编译

make

3.3.5安装

make install
安装好了erlang后可以将解压的文件夹删除:
rm -rf otp_src_25.1.1

3.3.6 验证erlang是否安装成功

在命令行输入: erl 如果进入了编程命令行则表示安装成功,然后按ctrl + z 退出编程命令行;

3.4 下载RabbitMQ

从RabbitMQ官网https://www.rabbitmq.com找到下载链接
Linux:下载3.10.11

| wget
https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.10.11/rabbitmq-server-generic-unix-3.10.11.tar.xz
generic 是通用的意思,这个版本也就是通用的unix版本

3.5 安装RabbitMQ

解压RabbitMQ的压缩包,即安装完成,无需再编译
tar -xvf rabbitmq-server-generic-unix-3.10.11.tar.xz -C /usr/local/
说明 -C 选项是指定解压目录,如果不指定会解压到当前目录
此时rabbitmq就安装好了;

4. 启动及停止RabbitMQ

4.1启动RabbitMQ

切换到安装目录的sbin目录下:

| #启动
./rabbitmq-server -detached
说明:
-detached 将表示在后台启动运行rabbitmq;不加该参数表示前台启动;
rabbitmq的运行日志存放在安装目录的var目录下;
现在的目录是:/usr/local/rabbitmq_server-3.10.11/var/log/rabbitmq

4.2 查看RabbitMQ的状态

切换到sbin目录下执行:
./rabbitmqctl -n rabbit status
说明:-n rabbit 是指定节点名称为rabbit,目前只有一个节点,节点名默认为rabbit
此处-n rabbit 也可以省略

4.3 停止RabbitMQ

切换到sbin目录下执行:
./rabbitmqctl shutdown

4.4 配置path环境变量

vi /etc/profile

| RABBIT_HOME=/usr/local/rabbitmq_server-3.10.11
PATH=

     P 
    
   
     A 
    
   
     T 
    
   
     H 
    
   
     : 
    
   
  
    PATH: 
   
  
PATH:RABBIT_HOME/sbin

export RABBIT_HOME PATH
刷新环境变量,命令如下
source /etc/profile

5. RabbitMQ管理命令

./rabbitmqctl 是一个管理命令,可以管理rabbitmq的很多操作。
./rabbitmqctl help可以查看一下有哪些操作
查看具体子命令 可以使用 ./rabbitmqctl help 子命令名称

5.1 用户管理

用户管理包括增加用户,删除用户,查看用户列表,修改用户密码。
这些操作都是通过rabbitmqctl管理命令来实现完成。
查看帮助:
rabbitmqctl add_user --help
相应的命令
(1) 查看当前用户列表
rabbitmqctl list_users
(2) 新增一个用户

| 语法:rabbitmqctl add_user Username Password
示例: rabbitmqctl add_user admin 123456

5.2 设置用户角色

| rabbitmqctl set_user_tags User Tag
示例:rabbitmqctl set_user_tags admin administrator
说明:此处设置用户的角色为管理员角色

5.3 设置用户权限

*rabbitmqctl set_permissions -p / admin “." ".” “.
说明:此操作是设置admin用户拥有操作虚拟主机/下的所有权限
查看用户权限
./rabbitmqctl list_permissions

6. web管理后台

Rabbitmq有一个web管理后台,这个管理后台是以插件的方式提供的,启动后台web管理功能,切换到sbin目录下执行:

6.1 启用管理后台

| # 查看rabbitmq 的插件列表
./rabbitmq-plugins list
#启用
./rabbitmq-plugins enable rabbitmq_management
#禁用
./rabbitmq-plugins disable rabbitmq_management

6.2防火墙操作

| systemctl status firewalld --检查防火墙状态
systemctl stop firewalld --关闭防火墙,Linux重启之后会失效
systemctl disable firewalld --防火墙置为不可用,Linux重启后,防火墙服务不自动启动,依然是不可用

6.3 访问

| http://192.168.131.131:15672
用户名/密码为我们上面创建的admin/123456
注意上面改成你的虚拟主机的ip地址
备注:如果使用默认用户guest、密码guest登录,会提示User can only log in via localhost
说明guest用户只能从localhost本机登录,所以不要使用该用户。

6.4 通过web页面新建虚拟主机


建完后如下


本文转载自: https://blog.csdn.net/Java___interview/article/details/130425806
版权归原作者 Java___interview 所有, 如有侵权,请联系我们删除。

“【动力节点】最新rabbitmq笔记-1-6章What is RabbitMQ?”的评论:

还没有评论