文档详情

每特教育学院蚂蚁课堂-4期消息中间件rabbitmq高级队列环境搭建.pdf

发布:2025-03-29约2.65万字共21页下载文档
文本预览下载声明

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

显示全部
相似文档