增加微信订阅号(在右侧),关注后,及时收到最新更新的文章。

RabbitMQ指南(5)-HelloWorld

JAVA 智菲尔 2382℃ 0评论

1、简单介绍

RabbitMQ是一个消息协调器(Broker),它的主要思路非常简单:接收和传输消息。可以把它看成一个邮局:当你将邮件送到邮箱中后,肯定知道邮差将会把封信送到收件人手中。类似地,RabbitMQ就是邮局、邮箱、邮差,唯一的区别就是,邮局传递的是纸质邮件,而RabbitMQ接收、存储、传递的是二进制流数据。

介绍一下RabbitMQ使用的一些术语:

1.1、生产者(Producing )

生产者仅会发送消息。简称”P“。

1.2、队列(Queue)

队列就相当于邮箱,它存在于RabbitMQ Server中。在RabbitMQ的组件中,所有的消息仅能够存储在队列中。队列的大小理论上是无限制的,本质上它是一个无限大的缓存区。多个生产者可以往同一个队列中发送消息,多个消息者也可以从一个队列中接收消息。

1.3、消费者(Consuming

消费者就是接收消息。它主要是等待接收消息,简称”C“。

2、HelloWorld

HelloWorld将非常简单,P发送消息,C接收消息并打印它。如下图所示,中间是一个队列:

python-one

2.1、JAVA实现

2.1.1、安装配置

下载java客户端包:client library package,解压后,将jar包加入到开发环境的classpath中。若使用maven管理方式,查找groupId为com.rabbitmq,artifactId为amqp-client的归档。

2.1.2、发送端

主要完成发送消息的功能,具体实现代码如下:

package com.zenfery.example.rabbitmq;

import java.io.IOException;
import java.util.Scanner;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

//生产者
public class Sender {

	private static final String QUEUE_NAME = "hello"; // 队列名称

	public static void main(String[] args) throws IOException {
		ConnectionFactory factory = new ConnectionFactory();
		factory.setHost("localhost");
		factory.setPort(5672);
		//创建连接
		Connection connection = factory.newConnection();
		Channel channel = connection.createChannel();

		//定义队列
		channel.queueDeclare(QUEUE_NAME, false, false, false, null);

		//发送消息,接收控制台输入,并将其发送
		Scanner scanner = new Scanner(System.in);
		while(scanner.hasNextLine()){
			String message = scanner.nextLine();
			//退出
			if(message != null && "quit".equals(message)){
			  channel.close();
			  connection.close();
			  break;
			}
			//发送消息
			else{
			  channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
			  System.out.println("  >>>发送:"+message+"");
			}
		}
	}
}

使用ConnectionFactory创建连接,实质上,此连接就是一个Socket连接,设置host为localhost来连接本地的RabbitMQ Server,设置Port为5672(默认队列连接端口),未设置用户名和密码,将默认使用guest/guest口令(当然,此口令仅能在localhost本地使用)。

使用channel.queueDeclare()来定义队列,在RabbitMQ中,队列仅能够创建一次,如果发现已经存在此队列,将会忽略此方法。

使用Scanner来从控制台循环输入内容,以行分隔。使用方法channel.basicPublish()循环将键盘输入发送到hello队列,如果输入”quit“时,将会退出当前发送客户端;如果发送至队列中的消息为”ok“时,消费者如果接收到此消息,将会退出消费者客户端。

2.1.3、消费者

主要用于接收指定队列(hello)中的消息。代码实现如下:

package com.zenfery.example.rabbitmq;

import java.io.IOException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConsumerCancelledException;
import com.rabbitmq.client.QueueingConsumer;
import com.rabbitmq.client.ShutdownSignalException;

//消费者
public class Receiver {

	private static final String QUEUE_NAME = "hello"; // 队列名称

	public static void main(String[] args) throws IOException
	, ShutdownSignalException, ConsumerCancelledException
	, InterruptedException {
		ConnectionFactory factory = new ConnectionFactory();
		factory.setHost("localhost");
		factory.setPort(5672);
		//创建连接
		Connection connection = factory.newConnection();
		Channel channel = connection.createChannel();

		//定义队列,因为消费者有可能比生产者先启动,为了保证消费者能连接
		//上已知队列。
		channel.queueDeclare(QUEUE_NAME, false, false, false, null);

		QueueingConsumer consumer = new QueueingConsumer(channel);
		channel.basicConsume(QUEUE_NAME, true, consumer);

		while (true) {
		      QueueingConsumer.Delivery delivery = consumer.nextDelivery();
		      String message = new String(delivery.getBody());
		      System.out.println(" >>>接收消息:" + message);
		      if(message!=null && "ok".equals(message)){
		    	  channel.close();
		    	  connection.close();
		    	  break;
		      }
		}
	}
}

同样,启动消费者客户端,首先要建立RabbitMQ的连接。在创建消费者对象之前,同样定义了hello的队列,因为消费者有可能会在生产者之前启动,为了不至于连接不到指定队列,所以也需要定义队列,不必担心,如果队列已经存在了,将不会再重复执行。

QueueingConsumer是队列消费对象,使用channel.basicConsume()方法将队列消费对象和队列进行绑定。使用consumer.nextDelivery()获取一个一个信件。使用delivery.getBody()获取二进制消息体流,然后将消息打印。如果接收到的消息为”ok“的话,将退出消费者客户端。

2.1.4、执行

启动第一个生产者,输入hello world。

hello world
  >>>发送:hello world

启动第二个生产者,输入hello world 2。

hello world 2
  >>>发送:hello world 2

在第二个生产者中输入quit,退出。

此时,可以在Web UI管理界面上,看到hello队列中有两条消息。

此时启动消费者。控制台输出:

 >>>接收消息:hello world
 >>>接收消息:hello world 2

在第一个生产者中输入ok,此时消费者接收到此消息并退出。再输入quit,第一个生产者也退出。

转载请注明:子暃之路 » RabbitMQ指南(5)-HelloWorld

喜欢 (0)or分享 (0)
发表我的评论
取消评论
表情

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址