-
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
提交
取消