e3mall商城的归纳总结8之solr集群、activemq的搭建和使用
2024-08-27 05:20:21
由于本节内容比较分散，因此专门为这两个技术进行开展了帖子。
solr集群的搭建
activemq的搭建
activemq的使用
引入activemq.jar包
我们先来说说Queue（点到点）
第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。
第二步：使用ConnectionFactory对象创建一个Connection对象。
第三步：开启连接，调用Connection对象的start方法。
第四步：使用Connection对象创建一个Session对象。
第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Queue对象。
第六步：使用Session对象创建一个Producer对象。
第七步：创建一个Message对象，创建一个TextMessage对象。
第八步：使用Producer对象发送消息。
第九步：关闭资源。
@Test
public void testQueueProducer() throws Exception {
// 第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。
//brokerURL服务器的ip及端口号
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");
// 第二步：使用ConnectionFactory对象创建一个Connection对象。
Connection connection = connectionFactory.createConnection();
// 第三步：开启连接，调用Connection对象的start方法。
connection.start();
// 第四步：使用Connection对象创建一个Session对象。
//第一个参数：是否开启事务。true：开启事务，第二个参数忽略。
//第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Queue对象。
//参数：队列的名称。
Queue queue = session.createQueue("test-queue");
// 第六步：使用Session对象创建一个Producer对象。
MessageProducer producer = session.createProducer(queue);
// 第七步：创建一个Message对象，创建一个TextMessage对象。
/*TextMessage message = new ActiveMQTextMessage();
message.setText("hello activeMq,this is my first test.");*/
TextMessage textMessage = session.createTextMessage("hello activeMq,this is my first test.");
// 第八步：使用Producer对象发送消息。
producer.send(textMessage);
// 第九步：关闭资源。
producer.close();
session.close();
connection.close();
}
Consumer（消费者）接收消息
消费者：接收消息。
第一步：创建一个ConnectionFactory对象。
第二步：从ConnectionFactory对象中获得一个Connection对象。
第三步：开启连接。调用Connection对象的start方法。
第四步：使用Connection对象创建一个Session对象。
第五步：使用Session对象创建一个Destination对象。和发送端保持一致queue，并且队列的名称一致。
第六步：使用Session对象创建一个Consumer对象。
第七步：接收消息。
第八步：打印消息。
第九步：关闭资源
@Test
public void testQueueConsumer() throws Exception {
// 第一步：创建一个ConnectionFactory对象。
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");
// 第二步：从ConnectionFactory对象中获得一个Connection对象。
Connection connection = connectionFactory.createConnection();
// 第三步：开启连接。调用Connection对象的start方法。
connection.start();
// 第四步：使用Connection对象创建一个Session对象。
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 第五步：使用Session对象创建一个Destination对象。和发送端保持一致queue，并且队列的名称一致。
Queue queue = session.createQueue("test-queue");
// 第六步：使用Session对象创建一个Consumer对象。
MessageConsumer consumer = session.createConsumer(queue);
// 第七步：接收消息。
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
try {
TextMessage textMessage = (TextMessage) message;
String text = null;
//取消息的内容
text = textMessage.getText();
// 第八步：打印消息。
System.out.println(text);
} catch (JMSException e) {
e.printStackTrace();
}
}
});
//等待键盘输入
System.in.read();
// 第九步：关闭资源
consumer.close();
session.close();
connection.close();
}
再来测试一个Topic的代码是否可以用
Tocpic的生产者
使用步骤：
第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。
第二步：使用ConnectionFactory对象创建一个Connection对象。
第三步：开启连接，调用Connection对象的start方法。
第四步：使用Connection对象创建一个Session对象。
第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个Topic对象。
第六步：使用Session对象创建一个Producer对象。
第七步：创建一个Message对象，创建一个TextMessage对象。
第八步：使用Producer对象发送消息。
第九步：关闭资源。
@Test
public void testTopicProducer() throws Exception {
// 第一步：创建ConnectionFactory对象，需要指定服务端ip及端口号。
// brokerURL服务器的ip及端口号
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");
// 第二步：使用ConnectionFactory对象创建一个Connection对象。
Connection connection = connectionFactory.createConnection();
// 第三步：开启连接，调用Connection对象的start方法。
connection.start();
// 第四步：使用Connection对象创建一个Session对象。
// 第一个参数：是否开启事务。true：开启事务，第二个参数忽略。
// 第二个参数：当第一个参数为false时，才有意义。消息的应答模式。1、自动应答2、手动应答。一般是自动应答。
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 第五步：使用Session对象创建一个Destination对象（topic、queue），此处创建一个topic对象。
// 参数：话题的名称。
Topic topic = session.createTopic("test-topic");
// 第六步：使用Session对象创建一个Producer对象。
MessageProducer producer = session.createProducer(topic);
// 第七步：创建一个Message对象，创建一个TextMessage对象。
/*
* TextMessage message = new ActiveMQTextMessage(); message.setText(
* "hello activeMq,this is my first test.");
*/
TextMessage textMessage = session.createTextMessage("hello activeMq,this is my topic test");
// 第八步：使用Producer对象发送消息。
producer.send(textMessage);
// 第九步：关闭资源。
producer.close();
session.close();
connection.close();
}
Topic的Consumer（消费者）
消费者：接收消息。
第一步：创建一个ConnectionFactory对象。
第二步：从ConnectionFactory对象中获得一个Connection对象。
第三步：开启连接。调用Connection对象的start方法。
第四步：使用Connection对象创建一个Session对象。
第五步：使用Session对象创建一个Destination对象。和发送端保持一致topic，并且话题的名称一致。
第六步：使用Session对象创建一个Consumer对象。
第七步：接收消息。
第八步：打印消息。
第九步：关闭资源
@Test
public void testTopicConsumer() throws Exception {
// 第一步：创建一个ConnectionFactory对象。
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");
// 第二步：从ConnectionFactory对象中获得一个Connection对象。
Connection connection = connectionFactory.createConnection();
// 第三步：开启连接。调用Connection对象的start方法。
connection.start();
// 第四步：使用Connection对象创建一个Session对象。
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// 第五步：使用Session对象创建一个Destination对象。和发送端保持一致topic，并且话题的名称一致。
Topic topic = session.createTopic("test-topic");
// 第六步：使用Session对象创建一个Consumer对象。
MessageConsumer consumer = session.createConsumer(topic);
// 第七步：接收消息。
consumer.setMessageListener(new MessageListener() {
@Override
public void onMessage(Message message) {
try {
TextMessage textMessage = (TextMessage) message;
String text = null;
// 取消息的内容
text = textMessage.getText();
// 第八步：打印消息。
System.out.println(text);
} catch (JMSException e) {
e.printStackTrace();
}
}
});
System.out.println("topic的消费端03。。。。。");
// 等待键盘输入
System.in.read();
// 第九步：关闭资源
consumer.close();
session.close();
connection.close();
}
最新文章
- 2.2 ARM处理器工作模式
- Codeforces Round #216 (Div. 2) B. Valera and Contest
- Orleans中的Timer和Reminder
- Oracle- 存储过程和异常捕捉
- C#面向对象基础类与方法
- 《鸟哥的Linux私房菜》读书笔记四
- jsoncpp使用
- codeforces 665C Simple Strings
- [HNOI 2017]影魔
- Oracle12c中SQL优化（SQL TUNING）新特性之SQL计划指令
- my new blog
- excel技巧--单元格合并与拆分
- 浅谈跨平台框架 Flutter 的优势与结构
- WebLogic使用总结(六)——WebLogic创建虚拟主机和修改启动端口号
- django的视图函数介绍
- 我与GitHub的第一次——自制音乐文件修改器
- 80X86计算机组织
- I2S音频总线学习（二）I2S总线协议
- BZOJ3157: 国王奇遇记 & 3516: 国王奇遇记加强版
- hibernate的子查询