如何解析SpringBoot整合ActiveMQ過程

如何解析SpringBoot整合ActiveMQ過程，很多新手對此不是很清楚，為了幫助大家解決這個難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。

創(chuàng)新互聯(lián)專注于萊蕪網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗。 熱誠為您提供萊蕪營銷型網(wǎng)站建設(shè)，萊蕪網(wǎng)站制作、萊蕪網(wǎng)頁設(shè)計、萊蕪網(wǎng)站官網(wǎng)定制、小程序設(shè)計服務(wù)，打造萊蕪網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供萊蕪網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。

目錄結(jié)構(gòu)

引入 maven依賴

<parent>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-parent</artifactId>    <version>1.5.4.RELEASE</version>    <relativePath/>   </parent>  <properties>    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>    <java.version>1.8</java.version>  </properties>  <dependencies>    <dependency>      <groupId>org.springframework.boot</groupId>      <artifactId>spring-boot-starter</artifactId>    </dependency>    <dependency>      <groupId>org.springframework.boot</groupId>      <artifactId>spring-boot-starter-web</artifactId>    </dependency>    <dependency>      <groupId>org.springframework.boot</groupId>      <artifactId>spring-boot-starter-test</artifactId>      <scope>test</scope>    </dependency>    <dependency>      <groupId>org.springframework.boot</groupId>      <artifactId>spring-boot-starter-activemq</artifactId>    </dependency>  </dependencies>  <build>    <plugins>      <plugin>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-maven-plugin</artifactId>      </plugin>    </plugins>  </build>

引入 application.yml配置

spring: activemq:  broker-url: tcp://127.0.0.1:61616  user: admin  password: adminqueue: springboot-queueserver: port: 8080

創(chuàng)建QueueConfig

@Configurationpublic class QueueConfig {  @Value("${queue}")  private String queue;  @Bean  public Queue logQueue() {    return new ActiveMQQueue(queue);  }  @Bean  public JmsTemplate jmsTemplate(ActiveMQConnectionFactory activeMQConnectionFactory, Queue queue) {    JmsTemplate jmsTemplate = new JmsTemplate();    jmsTemplate.setDeliveryMode(2);// 進(jìn)行持久化配置 1表示非持久化，2表示持久化</span>    jmsTemplate.setConnectionFactory(activeMQConnectionFactory);    jmsTemplate.setDefaultDestination(queue); // 此處可不設(shè)置默認(rèn)，在發(fā)送消息時也可設(shè)置隊列    jmsTemplate.setSessionAcknowledgeMode(4);// 客戶端簽收模式</span>    return jmsTemplate;  }  // 定義一個消息監(jiān)聽器連接工廠，這里定義的是點對點模式的監(jiān)聽器連接工廠  @Bean(name = "jmsQueueListener")  public DefaultJmsListenerContainerFactory jmsQueueListenerContainerFactory(      ActiveMQConnectionFactory activeMQConnectionFactory) {    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();    factory.setConnectionFactory(activeMQConnectionFactory);    // 設(shè)置連接數(shù)    factory.setConcurrency("1-10");    // 重連間隔時間    factory.setRecoveryInterval(1000L);    factory.setSessionAcknowledgeMode(4);    return factory;  }}

創(chuàng)建生產(chǎn)者：

@SpringBootApplication@Component@EnableSchedulingpublic class Producer {    @Autowired  private JmsMessagingTemplate jmsMessagingTemplate;    @Autowired  private Queue queue;    @Scheduled(fixedDelay=3000)  public void send() {    String result = System.currentTimeMillis()+"---測試";    System.out.println("result"+result);    jmsMessagingTemplate.convertAndSend(queue,result);  }  public static void main(String[] args) {    SpringApplication.run(Producer.class, args);  }}

創(chuàng)建消費者的application.yml

spring: activemq:  broker-url: tcp://127.0.0.1:61616  user: admin  password: adminqueue: springboot-queueserver: port: 8081

創(chuàng)建消費者：

@Component@SpringBootApplicationpublic class consumer {  private int count =0;    @JmsListener(destination = "${queue}")  public void receive(TextMessage textMessage,Session session) throws JMSException {    String text = textMessage.getText();        System.out.println("消費:"+text+"第幾次獲取消息count："+(++count));        System.out.println();    String jmsMessageID = textMessage.getJMSMessageID();  }   public static void main(String[] args) {    SpringApplication.run(consumer.class,args);  }}

看完上述內(nèi)容是否對您有幫助呢？如果還想對相關(guān)知識有進(jìn)一步的了解或閱讀更多相關(guān)文章，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對創(chuàng)新互聯(lián)的支持。

標(biāo)題名稱：如何解析SpringBoot整合ActiveMQ過程
URL分享：http://muchs.cn/article32/ipjesc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站改版、外貿(mào)建站、營銷型網(wǎng)站建設(shè)、外貿(mào)網(wǎng)站建設(shè)、網(wǎng)站排名、面包屑導(dǎo)航

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)