RabbitMQ简介
MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信,而不是通过直接调用彼此来通信,直接调用通常是用于诸如远程过程调用的技术。通常用于不同进程和服务之间的业务解耦。
简单说明
MQ是消费-生产者模型的一个典型的代表,一端往消息队列中不断写入消息,而另一端则可以读取或者订阅队列中的消息。
基本概念
Broker:简单来说就是消息队列服务器实体。
Exchange:消息交换机,它指定消息按什么规则,路由到哪个队列。
Queue:消息队列载体,每个消息都会被投入到一个或多个队列。
Binding:绑定,它的作用就是把exchange和queue按照路由规则绑定起来。
Routing Key:路由关键字,exchange根据这个关键字进行消息投递。
vhost:虚拟主机,一个broker里可以开设多个vhost,用作不同用户的权限分离。
producer:消息生产者,就是投递消息的程序。
consumer:消息消费者,就是接受消息的程序。
channel:消息通道,在客户端的每个连接里,可建立多个channel,每个channel代表一个会话任务。
RabbitMQ使用指南
安装
sudo apt-get install rabbitmq-server
service rabbitmq-server start
rabbitmq管理
基本信息管理
rabbitmqctl用于管理rabbitmq-server,常用的命令包括了 status, report
管理插件
启用管理插件
rabbitmq-plugins enable rabbitmq_management
访问url: HTTP://192.168.1.119:15672/;用户名:guest;密码:guest;
RabbitMQ程序使用入门
创建Maven工程
<dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>3.4.0</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
Consumer
import com.rabbitmq.client.*;
import java.io.IOException;
public class Application {
public static void main(String[] argv) throws Exception {
String QUEUE_NAME = "hello";
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("192.168.1.119");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
Consumer consumer = new DefaultConsumer(channel) {
@Override
public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)
throws IOException {
String message = new String(body, "UTF-8");
System.out.println(" [x] Received '" + message + "'");
}
};
channel.basicConsume(QUEUE_NAME, true, consumer);
}
}
producer
import com.rabbitmq.client.*;
import junit.framework.TestCase;
import java.io.IOException;
/**
* Created by fiboliu on 16-1-21.
*/
public class ApplicationTest extends TestCase {
public void testMain() throws Exception {
String QUEUE_NAME = "hello";
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("192.168.1.119");
Connection connection = null;
Channel channel = null;
try {
connection = factory.newConnection();
channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
String message = "Hello World!";
channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
System.out.println(" [x] Sent '" + message + "'");
} catch (Exception e) {
} finally {
try {
channel.close();
connection.close();
} catch (Exception e) {
}
}
}
}
创建
参考文献:
相关推荐
RabbitMQ从入门到放弃
RabbitMQ快速入门及API介绍(401M) QQ截图 20191220230107.png?x-oss-process=style/pnp8 (42.73KB, 下载次数:227) 下载附件 2019-12-2023 :01 上传【课程介绍】:第一章 : RabbitMQ介绍:消息中间件概念、RabbitMQ...
RabbitMQ极速入门
十六、RabbitMQ快速入门
Rabbitmq入门到精通全套教程
RabbitMQ从入门到进阶的详细讲解,其中包含各种用例、代码等
介绍RabbitMQ使用的教程
rabbitMQ代码案例 简单入门,适合初学者使用,里面讲的很详细
RabbitMQ环境搭建,介绍队列类型,spring-rabbit示例, 使用RabbitMQ完成商品数据的同步
Linux中安装RabbitMQ急速入门,快速安装,纯小白可直接上手,内容详细步骤明确,只要按照文档中来操作,成功率100%
RabbitMq开发入门
此处统计一些mq接口在开发过程中容易碰到的一些问题。 首先必须保证双方的连接配置一致,也就是说双方所用的mq服务器必须是同一个 不然后面根本没法传报文。
MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统 源码说明地址:https://www.cnblogs.com/personblog/p/10681741.html
简单介绍了RabbitMQ的内容,怎么使用控制界面,以及编写消息生产者和消息消费者
RabbitMQ入门-实战-RabbitMQ
rabbitmq安装以及入门,包会,最全面最可靠的安装及入门教程手册,祝你玩儿转rabbitmq,装不上你揍我
RabbitMQ入门介绍,初学者宝典,chm文档,方便阅读。
NULL 博文链接:https://zhaoshijie.iteye.com/blog/2161345
AMQP(advanced message queuing protocol)是一个提供统一消息服务的应用层标准协议,基于此协议的客户端与消息中间件可传递消息,并不受客户端/中间件不同产品,不同开发语言...RabbitMQ(支持更多语言,基于AMQP规范)
rabbitmq-demo入门代码