在SpringMQ中,可以通过配置文件配置消息监听器,例如:
<bean id="myListener" class="com.example.MyListener"/>
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> <property name="connectionFactory" ref="connectionFactory"/> <property name="destinationName" value="myQueue"/> <property name="messageListener" ref="myListener"/> </bean>
其中,MyListener是自定义的消息监听器类,DefaultMessageListenerContainer是Spring提供的消息监听器容器。
连接到消息队列可以使用Spring的JmsTemplate类,例如:
<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate"> <property name="connectionFactory" ref="connectionFactory"/> <property name="defaultDestinationName" value="myQueue"/> </bean>
在应用中使用JmsTemplate发送消息:
@Autowired private JmsTemplate jmsTemplate;
public void sendMessage(String message) { jmsTemplate.send(session -> session.createTextMessage(message)); }
在监听器中接收消息:
@Component public class MyListener implements MessageListener {
@Override
public void onMessage(Message message) {
// 处理消息
}
}