Spring+ActiveMQ+Mysql 配置JMS

消息发送public static void main(String[] args) throws JMSException{// ConnectionFactory ：连接工厂，JMS 用它创建连接ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");// JMS 客户端到JMS Provider 的连接Connection connection = connectionFactory.createConnection();connection.start();// Session： 一个发送或接收消息的线程Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);// Destination ：消息的目的地;消息发送给谁.// 获取session注意参数值Queue.Name是Query的名字Destination destination = session.createQueue("[color=red]Queue.Name[/color]");// MessageProducer：消息生产者MessageProducer producer = session.createProducer(destination);// 设置不持久化producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);// 发送一条消息sendMsg(session, producer);session.commit();connection.close();}/*** 在指定的会话上，通过指定的消息生产者发出一条消息* * @param session 消息会话* @param producer 消息生产者*/public static void sendMsg(Session session, MessageProducer producer) throws JMSException{// 创建一条文本消息TextMessage message = session.createTextMessage("Hello ActiveMQ！");// 通过消息生产者发出消息producer.send(message);System.out.println("");}

消息接收public static void main(String[] args) throws JMSException{// ConnectionFactory ：连接工厂，JMS 用它创建连接ConnectionFactory connectionFactory =
new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");// JMS 客户端到JMS Provider 的连接Connection connection = connectionFactory.createConnection();connection.start();// Session： 一个发送或接收消息的线程Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);// Destination ：消息的目的地;消息发送给谁.// 获取session注意参数值xingbo.xu-queue是一个服务器的queue，须在在ActiveMq的console配置Destination destination = session.createQueue("Queue.Name");// 消费者，消息接收者MessageConsumer consumer = session.createConsumer(destination);while(true){TextMessage message = (TextMessage) consumer.receive(1000);if(null != message)System.out.println("收到消息：" + message.getText());elsebreak;}session.close();connection.close();}

  spring application.xml 文件配置<!-- 配置JMS消息发送 --><bean id="jmsFactory" class="org.apache.activemq.pool.PooledConnectionFactory"destroy-method="stop"><property name="connectionFactory"><bean class="org.apache.activemq.ActiveMQConnectionFactory"><property name="brokerURL"><value>tcp://localhost:61616</value></property></bean></property></bean><!-- Spring JMS Template --><bean id="myJmsTemplate" class="org.springframework.jms.core.JmsTemplate"><property name="connectionFactory"><ref local="jmsFactory" /></property></bean><bean id="destination" class="org.apache.activemq.command.ActiveMQQueue"><constructor-arg index="0"><value>Queue.Name</value></constructor-arg></bean><bean id="sender" class="demo.JmsQueueSender"><property name="jmsTemplate" ref="myJmsTemplate"></property></bean><bean id="receive" class="demo.JmsQueueReceiver"></bean><bean id="listenerContainer"class="org.springframework.jms.listener.DefaultMessageListenerContainer"><property name="connectionFactory" ref="jmsFactory"></property><property name="messageListener" ref="receive"></property><property name="destination" ref="destination" /></bean><!-- 配置JMS消息发送完成 -->

sender@Component
public class JmsQueueSender
{private JmsTemplate jmsTemplate;public void setConnectionFactory(ConnectionFactory cf){this.jmsTemplate = new JmsTemplate(cf);}public void simpleSend(){jmsTemplate.convertAndSend("Queue.Name", "test!!!");}public JmsTemplate getJmsTemplate(){return jmsTemplate;}public void setJmsTemplate(JmsTemplate jmsTemplate){this.jmsTemplate = jmsTemplate;}
}

receiver@Component
public class JmsQueueReceiver implements MessageListener
{@Overridepublic void onMessage(Message message){if(message instanceof TextMessage){final TextMessage textMessage = (TextMessage) message;try{System.out.println(textMessage.getText());}catch(final JMSException e){e.printStackTrace();}}}
}

配置ActiveMQ以数据库的方式存储消息 ActiveMQ安装目录\conf\activemq.xml 找到 <broker>标签中的内容<persistenceAdapter><kahaDB directory="${activemq.base}/data/kahadb"/></persistenceAdapter>注释掉以上内容，添加自己的数据库配置<persistenceAdapter><jdbcPersistenceAdapter dataSource="#mysql-ds"/>
</persistenceAdapter>配置以Mysql的方式保存消息 <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"><property name="driverClassName" value="com.mysql.jdbc.Driver"/> <property name="url" value="jdbc:mysql://localhost/test?relaxAutoCommit=true"/><property name="username" value="root"/><property name="password" value="root"/> <property name="poolPreparedStatements" value="true"/>
</bean> 将Mysql的包加到ActiveMQ的启动Lib下 在Mysql数据中新建数据库 test，ActiveMQ在启动的时候会自动建表。 重新启动服务。 这样消息的发送者的消息将被保存到Mysql数据库，同时消息消耗者每读取一条消息。数据库中的消息也会相应的删除。

Spring+ActiveMQ+Mysql 配置JMS相关推荐

spring mvc mysql配置_spring mvc配置数据库连接
ACM 配置中心实战:Spring + MyBatis + Druid + ACM 很多基于 Spring MVC 框架的 Web 开发中,Spring + MyBatis + Druid 是一个黄金 ...
activemq mysql 配置详解_activeMQ数据库配置
ActiveMQ很好的支持了消息的持久性(Persistence).消息持久性对于可靠消息传递来说应该是一种比较好的方法,有了消息持久化, 即使发送者和接受者不是同时在线或者消息中心在发送者发送消息后 ...
spring spring c3p0 mysql配置_Spring通过c3p0配置bean连接数据库
Spring配置bean连接数据库两种方法: (1)直接在.xml文件内部配置: xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance&q ...
activemq mysql 配置详解_ActiveMQ配置详解
一.消息目的地策略在节点destinationPolicy配置策略,可以对单个或者所有的主题和队列进行设置,使用流量监控,当消息达到memoryLimit的时候,ActiveMQ会减慢消息的产生甚至 ...
springboot原生mysql写法_【Rainbond最佳实践】Spring Boot框架配置MySQL
Rainbond开源软件介绍: Rainbond是国内首个开源的生产级无服务器PaaS. 深度整合基于Kubernetes的容器管理.多类型CI/CD应用构建与交付.多数据中心的资源管理等技术,提供云 ...
SpringMVC +Spring + MyBatis + Mysql + Redis(作为二级缓存) 配置
转载:http://blog.csdn.net/xiadi934/article/details/50786293 项目环境: 在SpringMVC +Spring + MyBatis + MySQL ...
【Spring】SpringBoot 配置MySql和Doris多数据源
嗨, 大家好, 最近公司想要使用DorisDB做数据存储, 经过几天对Doris的研究,发现Dorsi连接方式其实用的就是JDBC连接方式.今天把这两天的学习成果记录一下. 也希望对看到此文章的人有所 ...
java+spring+mysql配置_JAVA后台搭建(springboot+mybatis+mysql)项目搭建
前言上篇文章写了基本环境配置的搭建,接下来我们需要搭建项目了,项目搭建使用的IDEA,springboot项目的搭建非常快只需要几分钟,然后介绍MyBatis以及MySql的基本配置以及项目的Hel ...
3.了解Spring Boot2自动配置原理
了解Spring Boot2自动配置原理 1.SpringBoot特点 1.1.依赖管理 1.父项目做依赖管理依赖管理 <parent><groupId>org.spring ...

Spring+ActiveMQ+Mysql 配置JMS

Spring+ActiveMQ+Mysql 配置JMS相关推荐

最新文章

热门文章