RabbitMQ简单模式

相关视频参考（来自动力节点）：https://www.bilibili.com/video/BV1Ap4y1D7tU

相关资料下载：http://www.bjpowernode.com/?csdn

简单模式

 RabbitMQ是一个消息中间件，你可以想象它是一个邮局。当你把信件放到邮箱里时，能够确信邮递员会正确地递送你的信件。RabbitMq就是一个邮箱、一个邮局和一个邮递员。

• 发送消息的程序是生产者
• 队列就代表一个邮箱。虽然消息会流经RbbitMQ和你的应用程序，但消息只能被存储在队列里。队列存储空间只受服务器内存和磁盘限制，它本质上是一个大的消息缓冲区。多个生产者可以向同一个队列发送消息，多个消费者也可以从同一个队列接收消息.
• 消费者等待从队列接收消息

 

生产者发送消息

package rabbitmq.simple;



import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.ConnectionFactory;



public class Test1 {

public static void main(String[] args) throws Exception {

//创建连接工厂,并设置连接信息

ConnectionFactory f = new ConnectionFactory();

f.setHost("192.168.64.140");

f.setPort(5672);//可选,5672是默认端口

f.setUsername("admin");

f.setPassword("admin");





Connection c = f.newConnection();

//建立信道

Channel ch = c.createChannel();





ch.queueDeclare("helloworld", false,false,false,null);





ch.basicPublish("", "helloworld", null, "Hello world!".getBytes());



System.out.println("消息已发送");

c.close();

}

}

消费者接收消息

package rabbitmq.simple;



import java.io.IOException;

import java.util.concurrent.TimeoutException;

import com.rabbitmq.client.CancelCallback;

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.DeliverCallback;

import com.rabbitmq.client.Delivery;



public class Test2 {

public static void main(String[] args) throws Exception {

//连接工厂

ConnectionFactory f = new ConnectionFactory();

f.setHost("192.168.64.140");

f.setUsername("admin");

f.setPassword("admin");

//建立连接

Connection c = f.newConnection();

//建立信道

Channel ch = c.createChannel();

//声明队列,如果该队列已经创建过,则不会重复创建

ch.queueDeclare("helloworld",false,false,false,null);

System.out.println("等待接收数据");



//收到消息后用来处理消息的回调对象

DeliverCallback callback = new DeliverCallback() {

@Override

public void handle(String consumerTag, Delivery message) throws IOException {

String msg = new String(message.getBody(), "UTF-8");

System.out.println("收到: "+msg);

}

};



//消费者取消时的回调对象

CancelCallback cancel = new CancelCallback() {

@Override

public void handle(String consumerTag) throws IOException {

}

};



ch.basicConsume("helloworld", true, callback, cancel);

}

}