RabbitMQ实例教程:Hello RabbitMQ World之Java实现
RabbitMQ要实现Hello World,其实也很简单。只需一个服务器来发送消息,另外有个客户端接收消息即可。
整体的设计流程如下:
消息生产者发送Hello到消息队列,消息消费者从队列中接收消息。
下载依赖Jar包
RabbitMQ要用Java实现发送消息,就必须使用Java客户端库。目前RabbizMQ的Java客户端库最新版为为 3.5.5 。可以从Maven仓库下载,也可以直接去官网下载。
1
2
3
4
5
|
<dependency> <groupId>com.rabbitmq< /groupId >
<artifactId>amqp-client< /artifactId >
<version>3.5.5< /version >
< /dependency >
|
使用Java创建发送者
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
|
package com.favccxx.favrabbit;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
public class Sender {
private final static String QUEUE_NAME = "hello" ;
public static void main(String[] argv) throws IOException, TimeoutException {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost( "localhost" );
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.queueDeclare(QUEUE_NAME, false , false , false , null );
String message = "Hello RabbitMQ World!" ;
channel.basicPublish( "" , QUEUE_NAME, null , message.getBytes());
System.out.println( " [x] Sent '" + message + "'" );
}
} |
RabbitMQ控制台监控消息队列
运行上面的代码,从RabbitMQ控制台就可以看到刚刚发送的消息。
使用Java接收消息
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
package com.favccxx.favrabbit;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Consumer;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;
public class Receiver {
private final static String QUEUE_NAME = "hello" ;
public static void main(String[] argv)
throws java.io.IOException, java.lang.InterruptedException, TimeoutException {
ConnectionFactory factory = new ConnectionFactory();
factory.setHost( "localhost" );
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);
}
} |
分别运行消息发送者和消息接收者,从RabbitMQ控制台可以看到实时的状况。
到此为止,RabbitMQ的Hello World工作就结束了,是不是对消息队列有了一些好感了呢?
本文转自 genuinecx 51CTO博客,原文链接:http://blog.51cto.com/favccxx/1701004,如需转载请自行联系原作者