开源消息中间件ActiveMQ回顾(一):客户端实现与JMS规范
前一段时间工作中经常使用到Apache ActiveMQ用作消息传输。今天在公司不是很忙,于是又深入研究了一下,总结一下分享出来。
首先是基于ActiveMQ的Java客户端实现例子。
接口定义:
public class MQServiceUtils { //此处同样可以使用IoC框架注入private static MQService mqService = ActiveMQServiceImpl.getInstance();public static void sendMessage(String message){try{mqService.sendQueueMessage(message);}catch(Exception e){e.printStackTrace();}}public static void publishMessage(String message){try{mqService.publishTopicMessage(message);}catch(Exception e){e.printStackTrace();}}}更新中...
?
?
?