java架构之路-(MQ专题)RabbitMQ安装和基本使用

RabbitMQ安装

  我这里安装是使用阿里云的CentOS7.5来安装的,使用CentOS版本低于7的可能会报错。

1.安装rabbitmq所需要的依赖包

输入$ yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc- c++ kernel-devel m4 ncurses-devel tk tc xz

2.下载安装包

$ wget www.rabbitmq.com/releases/erlang/erlang-18.3-1.el7.centos.x86_64.rpm

$ wget http://repo.iotti.biz/CentOS/7/x86_64/socat-1.7.3.2-5.el7.lux.x86_64.rpm

$ wget www.rabbitmq.com/releases/rabbitmq-server/v3.6.5/rabbitmq-server-3.6.5-1.noarch.rpm

3.安装服务命令

#第一步:安装erlang语言环境

$ rpm -ivh erlang-18.3-1.el7.centos.x86_64.rpm

#第二步:安装socat加解密软件

$ rpm -ivh socat-1.7.3.2-5.el7.lux.x86_64.rpm

#第三步:最后安装rabbitmq

$ rpm -ivh rabbitmq-server-3.6.5-1.noarch.rpm

4.修改配置文件

#第一步:查找rabbit.app,并编辑改文件

修改:loopback_users 中的 <<"guest">>,只保留guest(不修改只能通过localhost访问)

#第二步,修改rabbitmq-env.conf文件

$ vim /etc/rabbitmq/rabbitmq-env.conf

添加NODENAME=rabbit

5.安装插件,保证浏览器可以访问

$ rabbitmq-plugins enable rabbitmq_management

6.启动服务

$ rabbitmq-server start &

$ rabbitmqctl start_app

打开浏览器,输入我们的地址加端口15672,就可以看到我们的页面了,账号密码都是guest,登录进来是这样的。

  说了这么多,还没说这个玩意是做什么的呢~!我第一次接触这个我也懵,完全不懂得是做什么的,我们先来看一下他能做什么吧。

  RabbitMQ(暂不说实际场景,后面说场景,现在说场景怕自己给自己说懵圈了)主要是传递消息,就是什么意思呢,看个图。

  简单来说就是这样的,通过我们的RabbitMQ将我们的数据发送到其它的服务器上去,让服务器得到我们的消息,有人会问为什么不直接传递,也可以直接传递,但是服务器达到一定数量,你是维护起来成本很高的,而且还需要可靠性的投递呢?代码实现起来是复杂的。

  我们再来打开黑色的盒子看一下里面的东西。

我们来说几个名词,有图了更容易理解和记忆

1:server :又称为broker,接受客户端连接,实现amqp实体服务

2:exchange 交换机: 消息直接投递到交换机上,然后交换机根据消息的路由key 来路由到对应绑定的队列上

3:baingding: 绑定 exchange 与queue的虚拟连接,bingding中可以包含route_key

4:route_key 路由key ,他的作用是在交换机上通过route_key来把消息路由到哪个队列上

5:queue:队列,用于来保存消息的载体,有消费者监听,然后消费消息

  就是我们的数据服务A通过网络通道,到达exchange交换机,通过路由route_key来把消息发送到哪个队列上,提供给我们的下游服务使用,左面的叫上游服务,右面的叫下游服务。

交换机exchange

  这里还得继续说点枯燥的理论,交换机分为三种,直接交换机,扇形交换机和我们的Topic交换机,也叫做话题交换机。来举三个栗子。

直接交换机:

就是说,携带我们的routing Key通过我们的路由匹配到我们的routing Key就能到达我们的的Queue队列下,接收到我们发送过来的消息。

扇形交换机

  通过我们的交换机,只要订阅了我们的交换机Exchange,就可以收到我们的消息。

Topic交换机

  需要匹配我们的routing Key,这里的匹配模式有两种,*和#,*表示值匹配一层,一层就是..之间就叫做一层,比如啊,top.xiaocai.
java,这时我们匹配top.xiaocai.*即可匹配到,而我们匹配top.*则不可匹配。再就是我们的#是全匹配,还是top.xiaocai.java的例子,这时我们匹配top.xiaocai.#即可匹配到,而我们匹配top.#也可匹配到。我们来看一个图

就是一个匹配的规则,其实不难的。

 命令行

  我们再来看几个命令行的使用

查看用户列表rabbitmqctl list_users,即可得到我们的用户列表了,前面是用户名,括号内的是用户对应的角色。

输入rabbitmqctl add_user xiaocaijava 123456,添加我们的新用户,前面xiaocaijava是用户名,123456是密码。

设置rabbitmq用户的角色 rabbitmqctl set_user_tags xiaocaijava administrator

输入rabbitmqctl delete_user xiaocaijava,即可删除我们的用户,注意别把guest用户删了,不然会很麻烦。

后面的我就大概说一下,不是很重要,会用即可。

为用户设置权限: rabbitmqctl set_permissions -p <虚拟机> <用户名> ".*" ".*" ".*"

列出用户权限: rabbitmqctl list_user_permissions xiaocai

清除用户权限 rabbitmqctl clear_permissions -p <虚拟机> <用户名>

修改用户密码 rabbitmqctl change_password 用户名 新密码

虚拟主机操作

rabbitmqctl add_vhost /cloudmall 增加一个虚拟主机

rabbitmqctl list_vhosts; 查看所有的虚拟主机

rabbitmqctl list_permissions -p /cloudmall查看虚拟主机的权限

rabbitmqctl delete_vhost /cloudmall 删除虚拟主机

操作队列命令

rabbitmqctl list_queues 查询所有队列

rabbitmqctl -p vhostpath purge_queue blue 清除队列消息

  今天只是简单了解一下我们的RabbitMQ,后面会详细的去说RabbitMQ的作用和java相关的使用。

原文地址:https://www.cnblogs.com/xyy2019/p/11759766.html

时间: 2024-11-05 20:48:13

java架构之路-(MQ专题)RabbitMQ安装和基本使用的相关文章

MQ(1)-RabbitMq安装

本人安装的rabbitmq环境相关文件,可在本人提供的百度云盘资源进行下载. 链接:https://pan.baidu.com/s/1bnofK3l 密码:whdm 一 前言 消息队列又称为MQ,应用程序间的消息通信工具,其有利于程序解耦.多语言集成.异步通信.扩展和简单负载均衡等,是生产-消费者模型的典型代表.常见MQ产品有RabbitMQ ZeroMQ Kafka等等. RabbitMQ,老牌MQ产品,基于erlang语言,实现对AMQP等协议的支持,重量级,适合企业级应用开发: Kafka

java架构之路-(Redis专题)SpringBoot连接Redis超简单

上次我们搭建了Redis的主从架构,哨兵架构以及我们的集群架构,但是我们一直还未投入到实战中去,这次我们用jedis和springboot两种方式来操作一下我们的redis 主从架构 如何配置我上次已经讲过了,https://www.cnblogs.com/cxiaocai/p/11711377.html.我们这次主要看如何用java来操作redis,先来复习一下上次的配置,准备三台服务器,安装redis,保证互通,两台改为slave,配置replicaof IP 端口,主从复制是通过rdb文件

图灵学院java架构之路-VIP(五)nginx的安装和基本配置

Linux是一套免费使用和自由传播的类Unix操作系统,是一个基于POSIX和Unix的多用户.多任务.支持多线程和多CPU的操作系统.它能运行主要的Unix工具软件.应用程序和网络协议.它支持32位和64位硬件.Linux继承了Unix以网络为核心的设计思想,是一个性能稳定的多用户网络操作系统. 一,安装环境准备: 1.linux 内核2.6及以上版本:使用uname -a查看即可. 2.GCC编辑器. GCC可以用来编译C语言程序.Nginx没有直接提供二级制可执行程序,只能下载源码进行编译

java架构之路-(Redis专题)Redis的高性能和持久化

上次我们简单的说了一下我们的redis的安装和使用,这次我们来说说redis为什么那么快和持久化数据 在我们现有的redis中(5.0.*之前的版本),Redis都是单线程的,那么单线程的Redis为什么还会有那么高的效率呢?因为它所有的数据都在内存中,所有的运算都是内存级别的运算,而且单线程避免了多线程的切换中性能损耗的问题,正因为Redis是单线程,所以我们要小心使用Redis指令,对于那些耗时的指令(比如keys),我们一定要谨慎使用. 在并发环境中,我们Redis的单线程并不是线程1请求

java架构之路(多线程)AQS之ReetrantLock显示锁的使用和底层源码解读

锁的粗化和锁的消除 这个本来应该是在synchronized里面去说的,忘记了,不是很重要,但是需要知道有这么一个东西啦. 我们先来演示一下锁的粗化: StringBuffer sb = new StringBuffer(); public void lockCoarseningMethod(){ //jvm的优化,锁的粗化 sb.append("1"); sb.append("2"); sb.append("3"); sb.append(&qu

java架构之路-(面试篇)JVM虚拟机面试大全

下文连接比较多啊,都是我过整理的博客,很多答案都在博客里有详细说明,理解记忆是最扎实的记忆.而且我的答案不一定是最准确的,但是我的答案不会让你失望,而且几乎每个答案都是问题的扩展答案. 1.JVM内存模型 答:https://www.cnblogs.com/cxiaocai/p/11483629.html 先经过类装载子系统装载,经由验证,准备,解析,初始化四个过程.方法被调用,方法进栈,对象放在堆,栈内存的引用指向我们的对象,方法逐行执行,由我们的程序计数器来控制.元空间放置静态方法,不占用j

java架构之路(多线程)大厂方式手写单例模式

上期回顾: 上次博客我们说了我们的volatile关键字,我们知道volatile可以保证我们变量被修改马上刷回主存,并且可以有效的防止指令重排序,思想就是加了我们的内存屏障,再后面的多线程博客里还有说到很多的屏障问题. volatile虽然好用,但是别用的太多,咱们就这样想啊,一个被volatile修饰的变量持续性的在修改,每次修改都要及时的刷回主内存,我们讲JMM时,我们的CPU和主内存之间是通过总线来连接的,也就是说,每次我们的volatile变量改变了以后都需要经过总线,“道路就那么宽,

java架构之路-(面试篇)Mysql面试大全

说一下mysql比较宏观的面试,具体咋写sql的这里就不过多举例了.后面我还会给出一个关于mysql面试优化的试题,这里主要说的索引和B+Tree结构,很少提到我们的集群配置优化方案. 1.索引是什么?有什么作用以及缺点 答:索引是对数据库表中一列或多列的值进行排序的一种结构,使用索引可快速访问数据库表中的特定信息.也可以理解为索引就是一本书的目录,创建索引和维护索引要耗费时间,这种时间随着数据量的增加而增加.索引需要占物理空间,除了数据表占数据空间之外,每一个索引还要占一定的物理空间,如果要建

java架构知识点

十年java架构师教你怎么学好java架构 一.分布式架构 架构分布式的应用和工具,成熟目前的技术包括 J2EE,CORBA 和 DCOM,这些技术牵扯的内容非常广,相关的书籍也非常多. 分布式系统是一个古老而宽泛的话题,而近几年因为“大数据”概念的兴起,又焕发出了新的青春与活力. 除此之外,分布式系统也是一门理论模型与工程技法.学习分布式系统的同学往往会感觉:“入门容易,深入难”的确,学习分布式系统几乎不需要太多数学知识. 分布式系统还是一个复杂且宽泛的研究领域,学习一两门在线课程,看一两本书