activemq使用ide编写一段发送消息:学号姓名,的代码
时间: 2024-10-12 14:11:51 浏览: 26
activeMQ消息发送过程与原理浅析
在ActiveMQ中,通常使用Java语言编写客户端代码来发送消息。这里是一个简单的示例,假设你已经在IDE(如IntelliJ IDEA、Eclipse等)创建了一个项目,并添加了activemq-client依赖。首先,你需要创建一个`ConnectionFactory`连接到ActiveMQ服务器,然后创建一个`Connection`,接着创建一个`Session`用于管理会话,再创建一个`Producer`来发送消息。
```java
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import java.util.Properties;
public class SendMessage {
private static final String QUEUE_NAME = "studentMessagesQueue";
public static void main(String[] args) throws Exception {
// 创建连接工厂,配置URL和用户名密码(如果需要)
Properties props = new Properties();
props.put("connectionfactory", "tcp://localhost:61616");
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(props);
// 创建连接
Connection connection = connectionFactory.createConnection();
connection.start();
// 创建会话
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // 消息自动确认
// 创建队列(如果不存在则会自动创建)
Queue queue = session.createQueue(QUEUE_NAME);
// 创建生产者
MessageProducer producer = session.createProducer(queue);
// 准备发送的消息
String message = "学号:001,姓名:张三";
TextMessage textMsg = session.createTextMessage(message);
// 发送消息
producer.send(textMsg);
System.out.println("消息已发送: " + message);
// 关闭资源
producer.close();
session.close();
connection.close();
}
}
```
在这个例子中,我们发送了一条包含"学号姓名"信息的文本消息。运行这个程序,消息会被存储在指定的queue中。
阅读全文