ActiveMQ
消息机制
测试代码如下：
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations={"classpath:spring/applicationContext.xml"})
public class UserMqTest {
@Autowired
MessageService messageService;
// @Ignore
@Test
public void sendMessage(){
UserMq user = new UserMq();
user.setUid("a");
user.setAddress("魔都");
messageService.sendMessage(user);
System.out.println("消息已发送");
// UserMq user1 = new UserMq();
// user1 = messageService.receiveMessage();
//
// System.out.println("已获取消息:"+user1.getUid()+user1.getAddress());
// assertEquals(user1,null);
}
@Ignore
@Test
public void veceiveMessage(){
UserMq user = new UserMq();
user=messageService.receiveMessage();
if (null==user){
System.out.println("尼玛，是个空的");
}else{
System.out.println("已获取消息:"+user.getUid()+user.getAddress());
}
}
}
jms代码：
@Service
public class MessageServiceImpl implements MessageService {
@Autowired
Destination destination;
@Autowired
JmsTemplate jmsTemplate;
/**
* 发送消息
*/
public void sendMessage(final UserMq user){
jmsTemplate.send(destination, new MessageCreator() {
public Message createMessage(Session session) throws JMSException {
ObjectMessage msg = session.createObjectMessage(user);
// TextMessage msg = session.createTextMessage("hello world");
//msg.setStringProperty(name, value)
//设置域属性，用于messageSelector过滤，暂时不用
msg.setStringProperty("aaaa", "bbbb");
return msg;
}
});
}
/**
* 接受消息
*/
public UserMq receiveMessage(){
ObjectMessage receivedMessage = (ObjectMessage) jmsTemplate.receive(destination);
try {
return (UserMq) receivedMessage.getObject();
} catch (JMSException e) {
throw JmsUtils.convertJmsAccessException(e);
}
}
}
spirng 配置(独立的xml)：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jms="http://www.springframework.org/schema/jms"
xmlns:amq="http://activemq.apache.org/schema/core"
xsi:schemaLocation="http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd
http://www.springframework.org/schema/jms
http://www.springframework.org/schema/jms/spring-jms.xsd
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
<!-- <amq:connectionFactory id="connectionFactory" brokerURL="tcp://localhost:61616"/> -->
<amq:connectionFactory id="connectionFactory" brokerURL="${jms.tcp}"/>
<bean id="destination" class="org.apache.activemq.command.ActiveMQQueue">
<!-- <constructor-arg index="0" value="ecs.alert.queue"></constructor-arg> -->
<constructor-arg index="0" value="${jms.destination}"></constructor-arg>
</bean>
<!-- <bean id="messageHandler" class="com.rockey.emonitor.jms.controller.MessageHandler" /> -->
<bean name="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="connectionFactory" />
<!-- 接收超时时间：1s -->
<property name="receiveTimeout" value="${jms.receiveTimeout}"/>
<!-- 发送模式 DeliveryMode.NON_PERSISTENT=1:非持久 ; DeliveryMode.PERSISTENT=2:持久-->
<property name="deliveryMode" value="${jms.deliveryMode}"/>
<!-- 类型转换 (可以做一些前置和后置处理过滤信息等)-->
<!-- <property name="messageConverter" ref="jmsConverter"/> -->
</bean>
<!-- <bean name="jmsConverter" class="com.rockey.emonitor.jms.util.JmsTrxConverter" /> -->
<!-- <bean name="messageService" class="com.rockey.emonitor.jms.service.impl.MessageServiceImpl" /> -->
<!-- <bean name="messageReceiver" class="com.rockey.emonitor.jms.service.impl.MessageReceiverImpl" /> -->
<!-- 监听处理
<jms:listener-container connection-factory="connectionFactory">
<jms:listener destination="emonitor.alert.queue" ref="messageHandler" method="processMessage" />
</jms:listener-container> -->
</beans>
参数配置文件：
#服务端地址
jms.tcp=tcp://localhost:61616
#目标名称
jms.destination=ecs.alert.queue
#超时时间(毫秒)
jms.receiveTimeout=1000
#消息的发送模式，1、非持久化。2、持久化
jms.deliveryMode=2
pom文件：
<!-- ActiveMQ start -->
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq</artifactId>
<version>5.9.0</version>
</dependency>
<!-- jmsTemplete的依赖包 start安装该包会自动下载 Spring-1.2.4jar,这个包就包含有jms-->
<dependency>
<groupId>org.apache.xbean</groupId>
<artifactId>xbean-spring-common</artifactId>
<version>2.8</version>
</dependency>
<!-- jmsTemplete的依赖包 end -->
<dependency>
<groupId>org.apache.xbean</groupId>
<artifactId>xbean-spring</artifactId>
<version>3.7</version>
</dependency>
<!-- ActiveMQ end -->
调用方代码目前没写，以后补上