当前位置:   article > 正文

RabbitMQ 入门到精通(这一篇就够了)_rabbitmq erl是什么

rabbitmq erl是什么

一、 什么是 RabbitMQ

RabbitMQ是实现了高级消息队列协议(AMQP)的开源消息代理软件(亦称面向消息的中间件)。RabbitMQ服务器是用Erlang语言编写的,而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。

二、 安装 RabbitMQ

1 安装 Erlang
1.1什么是 Erlang
Erlang(['ə:læŋ])是一种通用的面向并发的编程语言,它由瑞典电信设备制造商爱立信所辖的 CS-Lab 开发,目的是创造一种可以应对大规模并发活动的编程语言和运行环境
系统版本:CentOS6.5 ; RabbitMQ-Server:3.5.1
2 安装 erlang
2.1安装准备,下载安装文件
wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.r pm
rpm-Uvherlang-solutions-1.0-1.noarch.rpm
修改 primary.xml.gz 的 sha 的加密值
cd/var/cache/yum/x86_64/6/erlang-solutionssha1sumprimary.xml.gz
修改vimrepomd.xml

<datatype="primary">
<checksumtype="sha">结果为 sha1sum 命令结果</checksum>
  • 1
  • 2

3 安装 erlang
yum install erlang
4 安装完成后可以用 erl 命令查看是否安装成功
erl-version
5 安装 RabbitMQServer
5.1安装准备,下载 RabbitMQServer
wget http://www.rabbitmq.com/releases/rabbitmq-server/v3.5.1/rabbitmqserver-3.5.1-1.noarch.rpm
5.2安装 RabbitMQServer
rpm --import http://www.rabbitmq.com/rabbitmq-signing-key-public.asc
yum install rabbitmq-server-3.5.1-1.noarch.rpm
6 启动 RabbitMQ
6.1配置为守护进程随系统自动启动,root 权限下执行:
chkconfig rabbitmq-serveron
6.2启动 rabbitMQ 服务
/sbin/service rabbitmq-serverstart
7 安装 Web 管理界面插件
7.1安装命令
rabbitmq-plugins enable rabbitmq_management
7.2安装成功后会显示如下内容

The following plugins have been enabled:
mochiweb
webmachine
rabbitmq_web_dispatch
amqp_client
rabbitmq_management_agent
rabbitmq_management
Plugin configuration haschanged. Restart RabbitMQ forchanges totakeeffect.
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8

8 设置 RabbitMQ 远程 ip 登录
因为默认的账号和密码都是guest ;所以我们以创建个admin帐号,密码 123456 为例,创建一个账号并 支持远程 ip 访问.
8.1创建账号
rabbitmqctl add_user admin 123456
8.2设置用户角色
rabbitmqctl set_user_tags admin administrator
8.3设置用户权限
rabbitmqctl set_permissions-p"/“oldlu”.""."".*"
8.4设置完成后可以查看当前用户和角色(需要开启服务)
rabbitmqctl list_users
浏览器输入:serverip:15672。其中 serverip 是 RabbitMQ-Server 所 在主机的 ip

三、 为什么要使用 RabbitMQ?他解决了什么问题?

在这里插入图片描述
在这里插入图片描述

四、 消息队列基础知识。

1 Provider
消息生产者,就是投递消息的程序。
2 Consumer
消息消费者,就是接受消息的程序。
3 没有使用消息队列时消息传递方式
在这里插入图片描述
4 使用消息队列后消息传递方式
消息 消息
5 什么是队列?
队列就像存放了商品的仓库或者商店,是生产商品的工厂和购买商品的用户之间的中转站
6 队列里存储了什么?
在 rabbitMQ 中,信息流从你的应用程序出发,来到 Rabbitmq 的队列,所有信息可以只 存储在一个队列中。队列可以存储很多信息,因为它基本上是一个无限制的缓冲区,前提是 你的机器有足够的存储空间。
7 队列和应用程序的关系?
多个生产者可以将消息发送到同一个队列中,多个消息者也可以只从同一个队列接收数据。

五、 编写 RabbitMQ 的入门案例

1 搭建项目环境
1.1创建项目
在这里插入图片描述
1.2修改 pom 文件添加 RabbitMQ 坐标

<dependency> 
	<groupId>org.springframework.boot</groupId> 
	<artifactId>spring-boot-starter-amqp</artifactId> 
</dependency>
  • 1
  • 2
  • 3
  • 4

1.3修改全局配置文件,添加 RabbitMQ 相关的配置

spring.application.name=springcloud-mq
spring.rabbitmq.host=192.168.70.131
spring.rabbitmq.port=5672
spring.rabbitmq.username=admin
spring.rabbitmq.password=123456
  • 1
  • 2
  • 3
  • 4
  • 5

2 编写代码
创建队列

 /** 
 * 创建消息队列 
 * @author Administrator 
 * */
@Configuration 
public class QueueConfig {
   
/** * 创建队列 * @return */ 
	@Bean 
	public Queue createQueue(){
   	 
		return new Queue("hello-queue"); 	
	}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14

创建消息提供者

/**
 * 消息发送者
 *
 * @author Administrator
 */
@Component
public class Sender {
   

    @Autowired
    private AmqpTemplate rabbitAmqpTemplate;

    /*
     * 发送消息的方法
     */
    public void send(String msg) {
   
        //向消息队列发送消息
        //参数一:队列的名称。
        //参数二:消息
        this.rabbitAmqpTemplate.convertAndSend("hello-queue", msg);
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23

消息接收者

@Component
public class Receiver {
   

	/**
	 * 接收消息的方法。采用消息队列监听机制
	 * @param msg
	 */
	@RabbitListener(queues="hello-queue")
	public void process(String msg){
   
		System.out.println("receiver: "+msg);
	}
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14

测试代码

@RunWith(SpringRunner.class)
@SpringBootTest(classes = SpringbootServerApplication.class)
public class QueueTest {
   

    @Autowired
    private Sender sender;

    /*
     * 测试消息队列
     */
    @Test
    public void test1() throws Exception {
   
        while 
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/在线问答5/article/detail/892590
推荐阅读
相关标签
  

闽ICP备14008679号