NodeJS work with ActiveMQ(1)Basic Connect to Local ActiveMQ

NodeJSworkwithActiveMQ(1)BasicConnecttoLocalActiveMQ

Longtimeago,IamusingactiveMQ,thatis15yearsback,olddaysinAlibaba?Hudsun?Taobao?Alipay?Chinatelecom?Icannotremember,butthatisreallylongtimeago.

Today,IwilltrytouseTypeScriptunderserverlessframeworkinAWSLambdatoconnecttoActiveMQasaproducer.Yeah.Enjoycoding.

Firstofall,SetUpanActiveMQServeronLocal

OldOldHomePagehttp://activemq.apache.org/

http://activemq.apache.org/web-console.html

IamusingtheMacOS,soIwilltrythepackagehttp://apache.mirrors.pair.com//activemq/5.15.7/apache-activemq-5.15.7-bin.tar.gz

Unzipandmovethefiletotheworkingdirectory

>sudoln-s/Users/hluo/tool/apache-activemq-5.15.7/opt/apache-activemq-5.15.7

>sudoln-s/opt/apache-activemq-5.15.7/opt/activemq

http://activemq.apache.org/getting-started.html

Starttheserviceintheforeground

>cd/opt/activemq

>bin/activemqconsole

ActiveMQWebConsoleavailableathttp://0.0.0.0:8161/

ActiveMQJolokiaRESTAPIavailableathttp://0.0.0.0:8161/api/jolokia/

WecanalsostarttheactiveMQonthebackground

>bin/activemqstart

Visitthewebconsoleherehttp://127.0.0.1:8161/admin/

Wecaneasilycreateaqueueandtestmessagesending.

Commandtostoptheservice

>bin/activemqstop

ConnecttoActiveMQwithNodeJS

STOMPprotocol-StreamingTextOrientatedMessageProtocol:SEND,SUBSCRIBE,UNSUBSCRIBE,BEGIN,COMMIT,ABORT,ACK,DISCONNECT.

Ontheofficialwebsite,thereisoneIcantryhttps://github.com/gdaws/node-stomp

APIdocumentisherehttp://gdaws.github.io/node-stomp/api/

Portsinformationhttp://activemq.apache.org/nms/stomp-uri-configuration.html

DefaultPortis61616,JAVAClientisconnectingasfollow:

packagecom.sillycat.feeds2g;

importjavax.jms.Connection;

importjavax.jms.ConnectionFactory;

importjavax.jms.JMSException;

importjavax.jms.Message;

importjavax.jms.MessageProducer;

importjavax.jms.Session;

importorg.apache.activemq.ActiveMQConnectionFactory;

publicclassActiveMQApp{

publicstaticvoidmain(String[]args)throwsJMSException{

Connectionconnection;

Sessionsession;

MessageProducerproducer;

Stringurl="failover:(tcp://localhost:61616)";

ConnectionFactoryconnectionFactory=newActiveMQConnectionFactory(url);

connection=connectionFactory.createConnection();

connection.start();

session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);

producer=session.createProducer(session.createQueue("dwh_datawarehouse"+","+"dwh_datawarehouse-raw"));

Messagemsg=session.createTextMessage("testconnectiontotheserver");

producer.send(msg);

producer.close();

session.close();

connection.close();

}

}

Packagedependencyisasfollow:

<dependency>

<groupId>org.apache.activemq</groupId>

<artifactId>activemq-all</artifactId>

<version>5.15.7</version>

</dependency>

STOMPinnodeJSisdoingasfollow:

varstompit=require('stompit');

varconnectOptions={

'host':'localhost',

'port':61613,

'timeout':6000,

'connectHeaders':{

'host':'/',

//'login':'username',

//'passcode':'password',

'heart-beat':'5000,5000'

}

};

stompit.connect(connectOptions,function(error,client){

if(error){

console.log('connecterror'+error.message);

return;

}

varsendHeaders={

'destination':'/queue/dwh_datawarehouse',

'content-type':'text/plain'

};

varframe=client.send(sendHeaders);

frame.write('hellofromnodejs'+newDate());

frame.end();

client.disconnect();

});

Hereisthepackagedependency

"stompit":"0.26.0"

Therearemaybemorethingsneedtocareabout,butwecancheckthedocumentsherehttp://gdaws.github.io/node-stomp/api/

References:

http://activemq.apache.org/cross-language-clients.html

https://blog.csdn.net/qq_37398530/article/details/78140371

https://medium.com/@mackplevine/using-activemq-with-node-js-stomp-and-http-b251ce8d995

https://simplesassim.wordpress.com/2016/03/13/how-to-send-a-message-to-an-apache-activemq-queue-with-node-js/

STOMP

https://blog.csdn.net/chszs/article/details/5200554

Monitortool

http://activemq.apache.org/how-can-i-monitor-activemq.html

100yearsago

https://www.soapui.org/documentation/jms/config.html

http://activemq.apache.org/hermes-jms.html