-
Kafka特性查看全部
-
常见消息中间件对比之Kafka查看全部
-
RabbitMQ特性查看全部
-
常见消息中间件之 RabbitMQ查看全部
-
ActiveMQ特性查看全部
-
常见消息中间件之 ActiveMQ查看全部
-
JMS AMQP 对比查看全部
-
AMQP查看全部
-
JMS查看全部
-
什么是消息中间件查看全部
-
什么是中间件查看全部
-
java消息服务 称为 JMS 用于2个程序之间的异步通信。查看全部
-
为什么对消息中间件集群查看全部
-
<context:annotation-config />必不可少 <context:annotation-config /> <!--ActiveMQ为我们提供的ConnectionFactory--> <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> <property name="brokerURL" value="tcp:127.0.0.1:61616" /> </bean> <!--spring jms 为我们提供的连接池--> <bean id="connectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory"> <property name="targetConnectionFactory" ref="targetConnectionFactory" /> </bean> <!--一个队列的目的地，点对点的--> <bean id="queueDestionation" class="org.apache.activemq.command.ActiveMQQueue"> <constructor-arg value="queue" /> </bean> <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory" ref="connectionFactory" /> </bean> <bean class="com.imooc.jms.producer.ProducerServiceImpl"></bean>查看全部
-
实现类 public class ProducerServiceImpl implements ProducerService { @Autowired JmsTemplate jmsTemplate; @Resource(name = "queueDestionation") Destination destination; @Override public void sendMessage(final String message) { jmsTemplate.send(destination, new MessageCreator() { @Override public Message createMessage(Session session) throws JMSException { TextMessage textMessage = session.createTextMessage(message); System.out.println("发送消息："+textMessage.getText()); return textMessage; } }); } }查看全部
举报
0/150
提交
取消