返回目录:金融新闻
今天比较忙,忙的连车票都没来得及买,明天要请假一天回趟老家。所以今天的文章直到现在才抽出一点时间来写,手动已经准备好了要发布的内容,只是没有整理比较凌乱,所以打算明天再发布,今天我我们分享的主题是activeMq,给大家讲解一个helloworld。
ActiveMQ 是Apache出品,最流行的,能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。
1、首先去官方下载activeMQ,我用的版本是5.5.1,下载地址:http://activemq.apache.org/download.html
2、打开压缩包,展现以下目录结构
3、打开bin目录,启动activemq.bat文件,开启activemq服务
4、访问http://localhost:8161/ 进入manager页面,创建一个队列。注意该队列名我们之后会在代码中用到。
5、开始写代码,先写一个Receiver.Java 类,这个类的作用是监听一个IP和端口,接送信息。
6、然后再写一个sender.java 这个类的作用就是给我们制定的ip和端口发送消息。
7、执行sender.java 向服务器发送消息
发送消息:ActiveMQ 发送的消息 1
发送消息:ActiveMQ 发送的消息 2
发送消息:ActiveMQ 发送的消息 3
发送消息:ActiveMQ 发送的消息 4
发送消息:ActiveMQ 发送的消息 5
查看队列的变化:
8、启动Receiver.java 看是否可以接受到消息
收到消息:ActiveMQ 发送的消息 1
收到消息:ActiveMQ 发送的消息 2
收到消息:ActiveMQ 发送的消息 3
收到消息:ActiveMQ 发送的消息 4
收到消息:ActiveMQ 发送的消息 5
再次观察队列:
9、完成
10、小结
ActiveMQ在实际开发中也有用到,用以处理一些异步消息通知。例如邮件,短信,日志等,另外还有一款比较好用的中间件kafka,性能更好。