大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
这篇文章给大家分享的是有关使用ActiveMQ测试小程序的方法的内容。小编觉得挺实用的,因此分享给大家做个参考。一起跟随小编过来看看吧。
网站建设哪家好,找创新互联!专注于网页设计、网站建设、微信开发、微信小程序定制开发、集团企业网站建设等服务项目。为回馈新老客户创新互联还提供了遂平免费建站欢迎大家使用!
修改bin目录下activemq.bat
在最后一行加入
set ACTIVEMQ_OPTS=-Xms1G -Xmx1G
保存后执行该bat文件
新建maven项目
pom文件中加入依赖
org.apache.activemq activemq-all 5.9.0 org.apache.activemq activemq-broker 5.10.0 org.apache.activemq activemq-client 5.14.0
发送端程序
import org.apache.activemq.ActiveMQConnection;import org.apache.activemq. ActiveMQConnectionFactory;import javax.jms.*;public class Send { // private static final int SEND_NUMBER = 10; public static void main(String[] args){ //ConnectionFactory:连接工厂,JMS用它创建连接 ConnectionFactory connectionFactory; //Connection:JMS客户端到JMS Provider的连接 Connection connection = null; //Session:一个发送或接收消息的线程 Session session; //Destination:消息的目的地;消息的接收者 Destination destination; //MessageProducer:消息发送者 MessageProducer producer; //TextMessage message; //构造ConnectionFactory实例对象,此处采用ActiveMQ的实现jar connectionFactory = new ActiveMQConnectionFactory( ActiveMQConnection.DEFAULT_USER, ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616" ); try{ //构造从工厂得到连接对象 connection = connectionFactory.createConnection(); //启动 connection.start(); //获取操作连接 session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE); //获取session注意参数值test是一个服务器的queue,须在ActiveMQ的console配置 destination = session.createQueue("test"); //得到发送者 producer = session.createProducer(destination); //设置不持久化,实际情况请根据项目决定 producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); //构造消息,这里写死了,项目就是参数,或者方法获取 sendMessage(session,producer); session.commit(); }catch (Exception e){ e.printStackTrace(); }finally { try { if(null != connection) connection.close(); }catch (Throwable ignore){} } } public static void sendMessage(Session session, MessageProducer producer) throws Exception{ for (int i = 1; i <= 100000; i++){ TextMessage message = session.createTextMessage("今日天气asda" + i);//发送消息到目的地 System.out.println("发送:"+message.getText()); producer.send(message); } } }
接收端程序
import org.apache.activemq.ActiveMQConnection;import org.apache.activemq. ActiveMQConnectionFactory;import javax.jms.*;public class revice { public static void main(String[] args) { ConnectionFactory connectionFactory; Connection connection = null; Session session; Destination destination; //接收者-消费者 MessageConsumer messageConsumer; connectionFactory = new ActiveMQConnectionFactory( ActiveMQConnectionFactory.DEFAULT_USER, ActiveMQConnectionFactory.DEFAULT_PASSWORD, "tcp://localhost:61616"); try{ connection = connectionFactory.createConnection(); connection.start(); session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE); destination = session.createQueue("test"); messageConsumer = session.createConsumer(destination); while(true){ TextMessage message = (TextMessage) messageConsumer.receive(1000); if(null != message){ System.out.println("收到:"+message.getText()); }else{ break; } message.acknowledge(); } }catch(Exception ex){ ex.printStackTrace(); }finally{ try{ if(null != connection){ connection.close(); } }catch(Throwable ig){ } } } }
感谢各位的阅读!关于使用ActiveMQ测试小程序的方法就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到吧!