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 #### 消息队列简介 消息队列(Message Queue, MQ)作为一种重要的中间件技术,它提供了应用程序间的一种通信方式,通过写入和读取出入列队的消息来进行通信,...
在使用 RabbitMQ 之前,需要先配置好连接,确保双方的连接配置一致。否则,无法传递消息。连接配置包括主机名、端口号、用户名、密码等信息。 2. MQ sending principle RabbitMQ 的发送原理可以分为三步:第一步是...
RabbitMQ快速入门及API介绍(401M) QQ截图 20191220230107.png?x-oss-process=style/pnp8 (42.73KB, 下载次数:227) 下载附件 2019-12-2023 :01 上传【课程介绍】:第一章 : RabbitMQ介绍:消息中间件概念、RabbitMQ...
【RabbitMQ极速入门】 RabbitMQ是一款广泛使用的开源消息队列系统,它基于Advanced Message Queuing Protocol(AMQP)标准,提供可靠、灵活的消息传递服务。作为一个分布式系统的支柱,RabbitMQ允许不同组件之间...
消息中间件rabbitmq的入门
【RabbitMQ 入门到精通】:RabbitMQ 是一款流行的消息中间件,它基于 AMQP(Advanced Message Queuing Protocol)协议实现,用于在分布式系统中高效地传输消息,从而实现异步处理、解耦和流量控制。本教程旨在帮助...
【标题】:“rabbitMQ入门” 在IT行业中,消息队列是一种常见的中间件技术,用于解耦应用程序组件,提高系统的可扩展性和可靠性。RabbitMQ是一个开源的消息代理和队列服务器,广泛应用于分布式系统中。本篇文章将带...
这个“rabbitMQ代码案例 简单入门”的资料包为初学者提供了了解和学习RabbitMQ的基础知识。 首先,让我们了解一下RabbitMQ的基本概念: 1. **消息队列**:RabbitMQ的核心是消息队列,它负责存储和转发消息。生产者...
【RabbitMQ快速入门】 RabbitMQ是一款广泛使用的开源消息队列系统,它基于AMQP(Advanced Message Queuing Protocol)协议,提供高可用性、可靠性和可扩展性,是分布式系统中实现异步任务处理、解耦组件以及负载...
### RabbitMQ 入门教程(JAVA) #### 一、RabbitMQ 概述 RabbitMQ 是一个消息中间件,其主要功能是接收来自生产者的消息,并根据规则将其路由、缓冲以及持久化后传递给消费者。RabbitMQ 和消息传递系统通常会使用...
**开发语言**:RabbitMQ 使用 Erlang 语言编写,Erlang 是一种面向并发的编程语言,非常适合构建高并发和容错性强的系统。 **AMQP**:这是一种开放的协议标准,用于实现消息队列之间的通信。AMQP 协议支持多种消息...
消息中间件之RabbitMQ入门讲解”的主题中,我们将深入理解RabbitMQ的核心概念,如何通过控制台进行管理,以及如何在Spring Cloud框架下创建消息生产者和消费者。 首先,让我们了解RabbitMQ的基本概念。RabbitMQ的...
Linux中安装RabbitMQ急速入门,快速安装,纯小白可直接上手,内容详细步骤明确,只要按照文档中来操作,成功率100%
MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统 源码说明地址:https://www.cnblogs.com/personblog/p/10681741.html
- Binding:绑定,定义交换器和队列之间的关系,使用RoutingKey指定路由规则。 - Queue:消息队列,存储消息供消费者消费。 工作流程如下: 1. 生产者连接服务器,创建连接和信道。 2. 生产者声明交换器和队列,...
RabbitMQ基础入门主要涵盖了MQ的基本概念、使用MQ的原因、MQ的分类以及RabbitMQ的详细知识。MQ,即Message Queue,是一种基于FIFO(先进先出)原则的消息队列服务,用于不同进程间的通信,尤其在互联网架构中,它起...
RabbitMQ入门介绍,初学者宝典,chm文档,方便阅读。
RabbitMQ使用Erlang语言编写,因其性能和稳定性,被众多互联网公司如滴滴、美团、携程、去哪儿等采纳。 RabbitMQ之所以高性能,一方面是由于它使用了Erlang语言,Erlang的性能可以与原生socket的延迟相媲美。另一...
【RabbitMQ入门操作手册】提供了全面的RabbitMQ学习指南,从基础概念到实际操作,帮助初学者快速掌握这个强大的消息队列系统。RabbitMQ是一个基于AMQP(Advanced Message Queuing Protocol)的开源消息代理,其核心...
在这个“RabbitMQ入门代码”中,我们将深入探讨如何使用Java来与RabbitMQ进行交互,包括队列持久化、消息持久化、Direct交换机、Fanout交换机和Topic交换机的基础测试代码。 首先,让我们从基础开始,了解如何在...