eclipse 搭建连接 activemq

今天我特地写下笔记，希望可以完全掌握这个东西，也希望可以帮助到任何想对学习这个东西的同学。

1.下载activemq压缩包，并解压（如果需要下载请看文章尾部附录）

2.进入bin文件夹，（64位电脑就进入win64，,32进入win32）找到activemq.bat 文件，双击运行，产生如下界面

3.访问activemq页面http://localhost:8161，用户名密码都是admin

4.然后点击队列或者主题，本项目以主题为例

5.创建一个主题

可以看到默认都是0

6.打开eclipse，并新建maven项目

7.添加需要的jar包

8.添加tomcat服务

9.先运行测试，测试是否成功

7.运行成功后，开始正式写连接activemq代码

创建class

Producer.java代码如下：

  1 package chansea.ToConnActivemq;

  2

  3 import java.util.Arrays;

  4 import java.util.Random;

  5 import java.util.Timer;

  6 import java.util.TimerTask;

  7

  8 import javax.jms.Connection;

  9 import javax.jms.ConnectionFactory;

 10 import javax.jms.Destination;

 11 import javax.jms.JMSException;

 12 import javax.jms.MessageProducer;

 13 import javax.jms.ObjectMessage;

 14 import javax.jms.Session;

 15 import javax.jms.TextMessage;

 16

 17 import org.apache.activemq.ActiveMQConnection;

 18 import org.apache.activemq.ActiveMQConnectionFactory;

 19

 20 import net.sf.json.JSONObject;

 21

 22 import utils.Utils;

 23

 24 public class Producer {

 25

 26     // 默认连接用户名

 27     private static final String USERNAME = ActiveMQConnection.DEFAULT_USER;

 28     // 默认连接密码

 29     private static final String PASSWORD = ActiveMQConnection.DEFAULT_PASSWORD;

 30     // 默认连接地址

 31     private static final String BROKERURL = ActiveMQConnection.DEFAULT_BROKER_URL;

 32     // 发送的消息数量

 33     private static final int SENDNUM = 1;

 34

 35     public static void main(String[] args) {

 36         // 连接工厂

 37         ConnectionFactory connectionFactory;

 38         // 连接

 39         Connection connection = null;

 40         // 会话,接收或者发送消息的线程

 41         Session session;

 42         // 消息的目的地

 43         Destination destination;

 44         // 消息生产者

 45         MessageProducer messageProducer;

 46         // 实例化连接工厂

 47         connectionFactory = new ActiveMQConnectionFactory(Producer.USERNAME, Producer.PASSWORD, Producer.BROKERURL);

 48

 49         try {

 50             // 通过连接工厂获取连接

 51             connection = connectionFactory.createConnection();

 52             // 启动连接

 53             connection.start();

 54             // 创建session

 55             session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);

 56             // 创建一个名称为Status_Iot_Machines_J6-3_J6-3-9的消息队列

 57             destination = session.createTopic("Status_Iot_Machines_J6-3_J6-3-9");

 58             // 创建消息生产者

 59             messageProducer = session.createProducer(destination);

 60             // 发送消息

 61             sendMessage(session, messageProducer);

 62

 63         } catch (Exception e) {

 64             e.printStackTrace();

 65         }

 66

 67     }

 68

 69     /**

 70      * 发送消息

 71      *

 72      * @param session 链接会话

 73      * @param messageProducer 消息生产者

 74      * @throws Exception

 75      */

 76     public static void sendMessage(final Session session, final MessageProducer messageProducer) throws Exception {

 77         final Utils u = new Utils();

 78         System.out.println("----start：" + u.intToDateTime(System.currentTimeMillis(), "-"));

 79         TimerTask task = new TimerTask() {

 80             @Override

 81             public void run() {

 82                 try {

 83                     Random r = new Random();

 84                     int[] status = {-1,0,1,3,4,13,14,15,16,17};

 85                     int _statusIndex = r.nextInt(status.length);

 86                     String[] macCode = {"N260","N692","N77","N697","N123","N232","N651","N213","N972","N290","N954","N633","N632","N196","N378","N81","N921","N489","N150","N791","N555","N713","N963","N666","N240","N563","N617","N825","N243","N275","N815","N49","N377","N244","N215","N689","N250","N587","N837","N268","N465","N96","N132","N398","N803","N811","N55","N16","N646","N777","N225","N412","N79","N441","N672","N457","N466","N447","N293","N190","N93","N361","N643","N430","N404","N819","N889","N771","N286","N844","N05","N550","N848","N890","N647","N596","N690","N974","N425","N09","N321","N662","N344","N941","N54","N957","N612","N166","N214","N121","N748","N842","N977","N807","N488","N316","N11","N616","N202","N939","N384","N834","N882","N135","N80","N357","N681","N14","N418","N806","N938","N222","N393","N122","N980","N362","N226","N381","N161","N434","N374","N01","N579","N925","N851","N267","N456","N956","N635","N206","N08","N390","N769","N452","N136","N172","N60","N348","N353","N212","N294","N831","N29","N451","N231","N426","N840","N710","N127","N449","N603","N915","N369","N259","N936","N375","N352","N895","N554","N208","N912","N445","N141","N839","N695","N269","N433","N106","N88","N475","N604","N432","N664","N714","N891","N755","N471","N600","N949","N906","N759","N356","N745","N284","N879","N111","N333","N712","N239","N733","N278","N21","N758","N210","N299","N216","N405","N169","N109","N648","N875","N953","N932","N382","N61","N707","N860","N894","N06","N273","N238","N854","N856","N933","N143","N562","N946","N301","N679","N350","N642","N797","N251","N944","N801","N25","N112","N283","N892","N351","N589","N608","N871","N861","N696","N200","N47","N300","N904","N709","N847","N31","N762","N964","N796","N327","N786","N526","N154","N732","N620","N778","N195","N182","N836","N360","N116","N102","N824","N151","N249","N282","N482","N104","N07","N832","N853","N553","N33","N660","N287","N607","N152","N417","N421","N905","N193","N774","N58","N459","N454","N950","N221","N125","N812","N551","N867","N62","N48","N265","N217","N930","N237","N419","N766","N305","N28","N621","N82","N354","N593","N472","N168","N756","N270","N38","N552","N970","N723","N328","N920","N817","N558","N297","N828","N264","N570","N685","N924","N627","N574","N649","N407","N194","N900","N147","N585","N380","N975","N852","N850","N70","N17","N741","N493","N827","N885","N669","N580","N435","N785","N823","N559","N188","N913","N317","N784","N708","N98","N227","N798","N958","N520","N177","N18","N303","N883","N789","N24","N720","N207","N976","N754","N73","N440","N897","N862","N728","N341","N50","N638","N880","N91","N255","N704","N443","N295","N485","N192","N849","N181","N57","N66","N137","N594","N198","N702","N156","N63","N306","N173","N951","N887","N59","N878","N37","N203","N257","N961","N365","N575","N808","N923","N622","N703","N582","N611","N829","N826","N470","N74","N205","N597","N654","N464","N326","N869","N945","N877","N962","N338","N967","N258","N911","N474","N311","N414","N857","N782","N148","N211","N176","N253","N423","N687","N899","N809","N914","N387","N820","N734","N581","N866","N522","N947","N323","N10","N779","N749","N367","N266","N160","N446","N484","N845","N795","N876","N557","N640","N722","N140","N315","N15","N235","N673","N567","N392","N800","N246","N624","N197","N422","N319","N650","N164","N100","N04","N560","N910","N726","N602","N814","N525","N670","N615","N307","N92","N750","N960","N35","N613","N163","N658","N929","N19","N671","N588","N746","N67","N870","N65","N02","N979","N340","N677","N684","N262","N973","N864","N481","N03","N868","N400","N737","N978","N916","N655","N129","N599","N117","N409","N201","N224","N721","N285","N399","N566","N322","N320","N12","N917","N609","N199","N189","N155","N881","N928","N395","N406","N934","N142","N170","N483","N183","N281","N572","N966","N52","N408","N72","N427","N680","N688","N776","N431","N56","N349","N292","N174","N491","N686","N388","N731","N898","N462","N312","N765","N639","N955","N22","N394","N128","N379","N436","N114","N893","N943","N735","N661","N610","N347","N873","N27","N276","N358","N790","N578","N302","N584","N165","N682","N799","N478","N32","N455","N346","N942","N230","N770","N242","N469","N97","N644","N623","N810","N444","N144","N653","N467","N75","N131","N590","N442","N813","N68","N220","N781","N901","N126","N524","N792","N752","N569","N725","N940","N656","N751","N36","N740","N413","N576","N179","N233","N20","N926","N30","N636","N256","N23","N363","N701","N209","N107","N528","N397","N931","N527","N178","N71","N401","N788","N793","N747","N437","N601","N371","N94","N715","N149","N678","N772","N775","N314","N113","N261","N219","N332","N157","N204","N331","N411","N463","N835","N450","N959","N838","N368","N729","N101","N85","N396","N663","N968","N234","N110","N468","N40","N822","N487","N761","N458","N922","N325","N816","N298","N919","N606","N167","N652","N705","N228","N191","N383","N896","N78","N794","N229","N476","N521","N764","N185","N355","N416","N146","N739","N918","N171","N716","N742","N162","N90","N486","N184","N366","N279","N45","N313","N763","N460","N490","N659","N153","N330","N41","N342","N115","N665","N477","N805","N969","N473","N865","N821","N296","N694","N420","N69","N236","N46","N711","N908","N591","N691","N13","N843","N403","N773","N134","N492","N846","N886","N952","N935","N907","N263","N571","N308","N410","N391","N625","N657","N461","N241","N86","N667","N158","N818","N902","N359","N345","N573","N389","N26","N619","N744","N700","N274","N927","N271","N304","N874","N105","N291","N187","N783","N223","N718","N618","N364","N124","N568","N787","N424","N448","N592","N668","N43","N95","N53","N727","N757","N888","N736","N334","N120","N39","N318","N595","N605","N626","N83","N309","N44","N186","N699","N34","N133","N598","N965","N561","N385","N329","N564","N280","N180","N937","N218","N84","N376","N415","N630","N738","N863","N675","N64","N706","N556","N175","N159","N683","N139","N99","N324","N138","N130","N254","N629","N245","N767","N641","N802","N89","N717","N453","N833","N289","N903","N288","N948","N753","N628","N108","N119","N429","N343","N859","N804","N841","N76","N884","N577","N272","N103","N693","N87","N724","N698","N480","N872","N743","N971","N529","N118","N780","N42","N631","N645","N768","N730","N402","N614","N719","N586","N637","N583","N858","N145","N760","N565","N674","N909","N676","N855","N386","N248","N830","N51","N634"};

 87                     int len = macCode.length - 1;

 88                     int _index = (int) (Math.random() * len);

 89                     while (_index > macCode.length - 1) {

 90                         if (_index <= macCode.length - 1) {

 91                             break;

 92                         }

 93                         _index = (int) (Math.random() * len);

 94                     }

 95

 96                     JSONObject obj = new JSONObject();

 97                     obj.element("MachineCode", macCode[_index]);

 98                     obj.element("RunMode_Cur", "MEMory");

 99                     obj.element("StatusID_Cur", status[_statusIndex]);

100                     obj.element("StatusID_Pre", status[_statusIndex]);

101                     obj.element("StatusStep", 23);

102                     obj.element("Type_Data", 13);

103                     obj.element("pub_time", System.currentTimeMillis());

104                     System.out.println("消息：" + obj + u.intToDateTime(obj.getLong("pub_time"), "-"));

105                     // 创建一条文本消息

106                     TextMessage message = session.createTextMessage(obj.toString());

107                     // 通过消息生产者发出消息

108                     messageProducer.send(message);

109                     session.commit();

110                 } catch (JMSException e) {

111                     // TODO Auto-generated catch block

112                     e.printStackTrace();

113                 }

114             }

115         };

116         Timer timer = new Timer();

117         // 开始等待时间

118         long delay = 100;

119         // 定义每次执行的间隔时间

120         long intevalPeriod = 5 * 10;

121         // 安排任务在一段时间内运行

122         timer.scheduleAtFixedRate(task, delay, intevalPeriod);

123     }

124

125 }

utils.java代码如下（本例为打印需要，如果不需要可不必添加，只需在Producer代码上相关utils的代码注释即可）：

package utils;

import java.text.SimpleDateFormat;

import java.util.Date;

public class Utils {

    public String intToDateTime(Long timestamp, String symbol){

        String sd = "";

        Date d = new Date();

        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

        sd = sdf.format(new Date(timestamp)); // 时间戳转换日期

        return sd;

    }

}

运行后

10.接着去查看activemq的也页面生产者是否大于0

有大于0，就算成功了

附录1：activemq下载

链接：https://pan.baidu.com/s/1jW0221hRnQ0kgV_XuOF-eg
提取码：9z6c

附录2：eclipse下载

链接：https://pan.baidu.com/s/1obT7Owr4G9VVs5o2rZkc0g
提取码：891y

附录3：jdk下载

链接：https://pan.baidu.com/s/1dsiMxYLQnBFQMOraU1ZTyw
提取码：yo23

附录4：tomcat下载

链接：https://pan.baidu.com/s/1Iob2hBFoT1LC3H3Y5XVJGA
提取码：rpfu

附录5：需要的jar包

https://files.cnblogs.com/files/Chansea/eclipse搭建连接activemq所需JAR包.zip

巴特西