package com.activemq;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
public class Sender {
private static final int SEND_NUMBER = 5;
public static void main(String[] args) {
// ConnectionFactory :连接工厂,JMS 用它创建连接
ConnectionFactory connectionFactory;
// Connection :JMS 客户端到JMS Provider 的连接
Connection connection = null;
// Session: 一个发送或接收消息的线程
Session session;
// Destination :消息的目的地;消息发送给谁.
Destination destination;
// MessageProducer:消息发送者
MessageProducer producer;
// TextMessage message;
// 构造ConnectionFactory实例对象,此处采用ActiveMq的实现jar
connectionFactory = new ActiveMQConnectionFactory(
ActiveMQConnection.DEFAULT_USER,
ActiveMQConnection.DEFAULT_PASSWORD,
"tcp://localhost:61616");
try {
// 构造从工厂得到连接对象
connection = connectionFactory.createConnection();
// 启动
connection.start();
// 获取操作连接
session = connection.createSession(Boolean.TRUE,
Session.AUTO_ACKNOWLEDGE);
// 获取session注意参数值xingbo.xu-queue是一个服务器的queue,须在在ActiveMq的console配置
destination = session.createQueue("FirstQueue");
// 得到消息生成者【发送者】
producer = session.createProducer(destination);
// 设置不持久化,此处学习,实际根据项目决定
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
// 构造消息,此处写死,项目就是参数,或者方法获取
sendMessage(session, producer);
session.commit();
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (null != connection)
connection.close();
} catch (Throwable ignore) {
}
}
}
public static void sendMessage(Session session, MessageProducer producer)
throws Exception {
for (int i = 1; i <= SEND_NUMBER; i++) {
TextMessage message = session
.createTextMessage("ActiveMq 发送的消息" + i);
// 发送消息到目的地方
System.out.println("发送消息:" + "ActiveMq 发送的消息" + i);
producer.send(message);
}
}
}
没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
收起资源包目录
activemq.rar (78个子文件)
activemq
activemq-all-5.8.0.jar 5.56MB
.project 384B
MANIFEST.MF 98B
src
springhello
HelloSender.java 2KB
ProxyJMSCustomer.java 3KB
JMSTest.java 990B
csdn
BeanTest.java 1KB
TestListener.java 2KB
SendMessage.java 2KB
com
activemq
Sender.java 3KB
Receiver.java 2KB
classes
com
activemq
Sender.class 2KB
Receiver.class 2KB
lib
spring-asm-3.0.7.RELEASE.jar 52KB
spring-core.jar 279KB
activemq-all-5.8.0.jar 5.56MB
spring-jms.jar 191KB
activemq-jaas-5.8.0.jar 31KB
log4j-1.2.16.jar 470KB
spring.jar 2.43MB
geronimo-j2ee-management_1.1_spec-1.0.1.jar 20KB
activation-1.1.jar 62KB
spring-tx-3.0.7.RELEASE.jar 227KB
activemq-console-5.4.2.jar 113KB
activemq-pool-5.4.2.jar 36KB
activemq-pool-5.8.0.jar 44KB
commons-pool.jar 61KB
slf4j-api-1.5.0.jar 16KB
asm-3.3.1.jar 43KB
log4j-1.2.14.jar 359KB
spring-beans.jar 477KB
activemq-core-5.4.2.jar 3.16MB
spring-expression-3.0.7.RELEASE.jar 166KB
spring-context-support.jar 95KB
spring-jms-3.0.7.RELEASE.jar 181KB
commons-logging-1.1.1.jar 59KB
spring-core-3.0.7.RELEASE.jar 375KB
spring-context-3.0.7.RELEASE.jar 655KB
geronimo-jta_1.0.1B_spec-1.0.1.jar 14KB
commons-pool-1.5.4.jar 94KB
spring-context-support-3.0.7.RELEASE.jar 99KB
activemq-protobuf-1.1.jar 144KB
activemq-console-5.8.0.jar 179KB
camel-spring-2.4.0.jar 180KB
spring-beans-3.0.7.RELEASE.jar 544KB
spring-context.jar 466KB
activemq-jaas-5.4.2.jar 27KB
activemq-camel-5.4.2.jar 44KB
slf4j-api-1.6.2.jar 25KB
activemq-spring-5.8.0.jar 151KB
activemq-core-5.4.1.jar 3.17MB
geronimo-jms_1.1_spec-1.1.1.jar 32KB
spring-tx.jar 226KB
commons-logging-1.1.jar 52KB
activemq-camel-5.8.0.jar 37KB
activemq-web-5.8.0.jar 106KB
asm-2.2.3.jar 34KB
applicationContext-jms.xml 3KB
applicationContext-jms1.xml 2KB
.settings
org.eclipse.jdt.core.prefs 629B
dist
activemq-all-5.8.0.jar 5.56MB
com
activemq
Sender.class 2KB
Receiver.class 2KB
Project.jar 3KB
META-INF
MANIFEST.MF 179B
MANIFEST.MF.bak 185B
build.xml 2KB
.classpath 3KB
bin
springhello
HelloSender.class 1KB
JMSTest.class 1KB
HelloSender$1.class 833B
ProxyJMSCustomer.class 2KB
csdn
SendMessage.class 2KB
BeanTest.class 1KB
TestListener.class 2KB
SendMessage$1.class 986B
com
activemq
Sender.class 3KB
Receiver.class 2KB
共 78 条
- 1
资源评论
- wanglei_dkf2015-06-07挺好用的11
kaonixiwa
- 粉丝: 2
- 资源: 50
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功