成人小视频在线_欧美xxxav_国产亚洲精AA在线观看SEE_日韩在线免费播放_69日影院_92精品国产自产在线观看481页

18842388900

網站建設 APP開發 小程序

Article/文章

記錄成長點滴 分享您我感悟

您當前位置>首頁 > 知識 > 軟件開發

如何使用ActiveMQ測試小程序

發表時間:2019-05-20 08:50:47

文章來源:沈陽網站建設

標簽:active MQ

分享:

瀏覽次數:0

介紹 Active MQ是個消息隊列管理器,用于通訊的中間件。現在由我來給大家介紹一下如何使用ActiveMQ測試小程序

首先需要下載ActiveMQ,并修改內存

修改bin目錄下activemq.bat
在最后一行加入

set ACTIVEMQ_OPTS=-Xms1G -Xmx1G

保存后執行該bat文件
新建maven項目
pom文件中加入依賴

<dependencies>        <dependency>            <groupId>org.apache.activemq</groupId>            <artifactId>activemq-all</artifactId>            <!--我的mq版本為5.9.0-->            <version>5.9.0</version>        </dependency>        <!-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-broker -->        <dependency>            <groupId>org.apache.activemq</groupId>            <artifactId>activemq-broker</artifactId>            <version>5.10.0</version>        </dependency>        <!-- https://mvnrepository.com/artifact/org.apache.activemq/activemq-client -->        <dependency>            <groupId>org.apache.activemq</groupId>            <artifactId>activemq-client</artifactId>   設計軟件

<a href=http://www.kingszun.cn target=_blank class=infotextkey>沈陽<a href=http://www.kingszun.cn target=_blank class=infotextkey>軟件開發</a></a>,<a href=http://www.kingszun.cn target=_blank class=infotextkey>沈陽<a href=http://www.kingszun.cn target=_blank class=infotextkey>軟件公司</a></a>

<version>5.14.0</version> </dependency> </dependencies>

發送端程序

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://www.kingszun.cn: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://www.kingszun.cn: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){            }        }    }}              
              

active MQ

相關案例查看更多

主站蜘蛛池模板: 久久久一| 免费亚洲黄色片 | 国精品久久久久久久久久久58 | 中文字幕无码人妻少妇免费视频 | 在线综合亚洲欧美网站 | 中文字幕成人免费视频 | 国产裸体舞一区二区视频在哪看 | 污网站视频 | 老熟女高潮喷了一地 | 亚洲6080YY久久无码产自国产 | 亚洲国产成人综合一区二区三区 | 久久国产乱子伦精品免费午夜 | 国产精品久久久久久久久久妞妞 | 香蕉久久一区二区不卡无毒影院 | 99蜜桃臀久久久欧美精品网站 | 亚洲欧美日韩国产综合V | 一女多男两根同时进去性视频 | 国产精品日本一区二区三区在线 | 漂亮人妻被中出中文字幕久久 | 中国一级a毛片 | 西西小说网 | caoprom最新超碰地址 | 在线免费观看黄网 | 国产人澡人澡澡澡人视频 | 无码人妻丰满熟妇啪啪网不卡 | 林雅诗三级无删减在线观看 | 黄色仓库av| 成人无码A片一区二区三区免费看 | 国产成人精品久久二区二区 | 日本JAPANESE熟睡人妻 | 日韩和欧美一区二区三区 | 美国一区二区 | 又色又爽1000部偷拍免费视频 | 国模大胆无码私拍啪啪AV | 精品在线一区二区 | 八区精品色欲人妻综合网 | 国产成人精品福利色多多 | 日日躁夜夜躁白天躁晚上 | 免费看片A片人人免费 | 美女的胸18岁以下禁止观看 | 亚洲黄色在线免费观看 |