每特教育学院蚂蚁课堂-4期消息中间件rabbitmq高级队列环境搭建.pdf
Java操作队列
简单队列
功能:一个生产者P发送消息到队列Q,一个消费者C接收
P表示为生产者、C表示为消费者红色表示队列。
Maven
dependencies
dependency
groupIdcom.rabbitmq/groupId
artifactIdamqp-client/artifactId
version3.6.5/version
/dependency
/dependencies
封装Connection
publicclassMQConnectionUtils{
publicstaticConnectionnewConnection()throwsIOException,TimeoutException{
//1.定义连接工厂
ConnectionFactoryfactory=newConnectionFactory();
//2.设置服务器地址
factory.setHost(127.0.0.1);
//3.设置协议端
factory.setPort(5672);
//4.设置vhost
factory.setVirtualHost(/test001_host);
//5.设置用户名称
factory.setUsername(test001);
//6.设置用户
factory.setPassword(123456);
//7.创建新的连接
ConnectionnewConnection=factory.newConnection();
returnnewConnection;
}
}
生产者
publicclassProducer{
privatestaticfinalStringQUEUE_NAME=test_queue;
publicstaticvoidmain(String[]args)throwsIOException,TimeoutException{
//1.获取连接
ConnectionnewConnection=MQConnectionUtils.newConnection();
//2.创建通道
Channelchannel=newConnection.createChannel();
//3.创建队列
channel.queueDeclare(QUEUE_NAME,false,false,false,null);
Stringmsg=test_yushengjun110;
System.out.println(生产者发送消息:+msg);
//4.发送消息
channel.basicPublish(,QUEUE_NAME,null,msg.getBytes());
channel.close();
newConnection.close();
}
}
消费者
publicclassCustomer{
privatestaticfinalStringQUEUE_NAME=test_queue;
publicstaticvoidmain(String[]args)throwsIOException,T