日韩精品www,日韩国产欧美,日韩一级视频

很久沒(méi)有寫(xiě)spring boot的內(nèi)容了，正好最近在寫(xiě)spring cloud bus的內(nèi)容，因?yàn)閮?nèi)容會(huì)有一些相關(guān)性，所以先補(bǔ)一篇關(guān)于amqp的整合。

message broker與amqp簡(jiǎn)介

message broker是一種消息驗(yàn)證、傳輸、路由的架構(gòu)模式，其設(shè)計(jì)目標(biāo)主要應(yīng)用于下面這些場(chǎng)景：

消息路由到一個(gè)或多個(gè)目的地
消息轉(zhuǎn)化為其他的表現(xiàn)方式
執(zhí)行消息的聚集、消息的分解，并將結(jié)果發(fā)送到他們的目的地，然后重新組合相應(yīng)返回給消息用戶(hù)
調(diào)用web服務(wù)來(lái)檢索數(shù)據(jù)
響應(yīng)事件或錯(cuò)誤
使用發(fā)布-訂閱模式來(lái)提供內(nèi)容或基于主題的消息路由

amqp是advanced message queuing protocol的簡(jiǎn)稱(chēng)，它是一個(gè)面向消息中間件的開(kāi)放式標(biāo)準(zhǔn)應(yīng)用層協(xié)議。amqp定義了這些特性：

消息方向
消息隊(duì)列
消息路由（包括：點(diǎn)到點(diǎn)和發(fā)布-訂閱模式）
可靠性
安全性

rabbitmq

本文要介紹的rabbitmq就是以amqp協(xié)議實(shí)現(xiàn)的一種中間件產(chǎn)品，它可以支持多種操作系統(tǒng)，多種編程語(yǔ)言，幾乎可以覆蓋所有主流的企業(yè)級(jí)技術(shù)平臺(tái)。

安裝

在rabbitmq官網(wǎng)的下載頁(yè)面https://www.rabbitmq.com/download.html中，我們可以獲取到針對(duì)各種不同操作系統(tǒng)的安裝包和說(shuō)明文檔。這里，我們將對(duì)幾個(gè)常用的平臺(tái)一一說(shuō)明。

下面我們采用的erlang和rabbitmq server版本說(shuō)明：

erlang/otp 19.1
rabbitmq server 3.6.5

windows安裝

安裝Erland，通過(guò)官方下載頁(yè)面http://www.erlang.org/downloads獲取exe安裝包，直接打開(kāi)并完成安裝。

安裝RabbitMQ，通過(guò)官方下載頁(yè)面https://www.rabbitmq.com/download.html獲取exe安裝包。

下載完成后，直接運(yùn)行安裝程序。

rabbitmq server安裝完成之后，會(huì)自動(dòng)的注冊(cè)為服務(wù)，并以默認(rèn)配置啟動(dòng)起來(lái)。

Spring Boot中使用RabbitMQ的示例代碼

mac os x安裝

在mac os x中使用brew工具，可以很容易的安裝rabbitmq的服務(wù)端，只需要按如下命令操作即可：

brew更新到最新版本，執(zhí)行：brew update
安裝erlang，執(zhí)行：brew install erlang
安裝rabbitmq server，執(zhí)行：brew install rabbitmq

通過(guò)上面的命令，rabbitmq server的命令會(huì)被安裝到/usr/local/sbin，并不會(huì)自動(dòng)加到用戶(hù)的環(huán)境變量中去，所以我們需要在.bash_profile或.profile文件中增加下面內(nèi)容：

1	`path=$path:/usr/local/sbin`

這樣，我們就可以通過(guò)rabbitmq-server命令來(lái)啟動(dòng)rabbitmq的服務(wù)端了。

ubuntu安裝

在ubuntu中，我們可以使用apt倉(cāng)庫(kù)來(lái)進(jìn)行安裝

安裝erlang，執(zhí)行：apt-get install erlang
執(zhí)行下面的命令，新增apt倉(cāng)庫(kù)到/etc/apt/sources.list.d

1 2	`echo` `'deb http://www.rabbitmq.com/debian/ testing main'` `\|` `sudo tee /etc/apt/sources.list.d/rabbitmq.list`

更新apt倉(cāng)庫(kù)的package list，執(zhí)行sudo apt-get update命令

安裝rabbit server，執(zhí)行sudo apt-get install rabbitmq-server命令

rabbit管理

我們可以直接通過(guò)配置文件的訪問(wèn)進(jìn)行管理，也可以通過(guò)web的訪問(wèn)進(jìn)行管理。下面我們將介紹如何通過(guò)web進(jìn)行管理。

執(zhí)行rabbitmq-plugins enable rabbitmq_management命令，開(kāi)啟web管理插件，這樣我們就可以通過(guò)瀏覽器來(lái)進(jìn)行管理了。

									> rabbitmq-plugins enable rabbitmq_management

									the following plugins have been enabled:

									 mochiweb

									 webmachine

									 rabbitmq_web_dispatch

									 amqp_client

									 rabbitmq_management_agent

									 rabbitmq_management

									applying plugin configuration to rabbit@pc-201602152056... started 6 plugins.

打開(kāi)瀏覽器并訪問(wèn)：http://localhost:15672/，并使用默認(rèn)用戶(hù)guest登錄，密碼也為guest。我們可以看到如下圖的管理頁(yè)面：

Spring Boot中使用RabbitMQ的示例代碼

從圖中，我們可以看到之前章節(jié)中提到的一些基本概念，比如：connections、channels、exchanges、queue等。第一次使用的讀者，可以都點(diǎn)開(kāi)看看都有些什么內(nèi)容，熟悉一下rabbitmq server的服務(wù)端。

點(diǎn)擊admin標(biāo)簽，在這里可以進(jìn)行用戶(hù)的管理。

spring boot整合

下面，我們通過(guò)在spring boot應(yīng)用中整合rabbitmq，并實(shí)現(xiàn)一個(gè)簡(jiǎn)單的發(fā)送、接收消息的例子來(lái)對(duì)rabbitmq有一個(gè)直觀的感受和理解。

在spring boot中整合rabbitmq是一件非常容易的事，因?yàn)橹拔覀円呀?jīng)介紹過(guò)starter poms，其中的amqp模塊就可以很好的支持rabbitmq，下面我們就來(lái)詳細(xì)說(shuō)說(shuō)整合過(guò)程：

新建一個(gè)spring boot工程，命名為：“rabbitmq-hello”。

在pom.xml中引入如下依賴(lài)內(nèi)容，其中spring-boot-starter-amqp用于支持rabbitmq。

									<parent>

									  <groupid>org.springframework.boot</groupid>

									  <artifactid>spring-boot-starter-parent</artifactid>

									  <version>1.3.7.release</version>

									  <relativepath/> <!-- lookup parent from repository -->

									</parent>

									<dependencies>

									  <dependency>

									    <groupid>org.springframework.boot</groupid>

									    <artifactid>spring-boot-starter-amqp</artifactid>

									  </dependency>

									  <dependency>

									    <groupid>org.springframework.boot</groupid>

									    <artifactid>spring-boot-starter-test</artifactid>

									    <scope>test</scope>

									  </dependency>

									</dependencies>

在application.properties中配置關(guān)于rabbitmq的連接和用戶(hù)信息，用戶(hù)可以回到上面的安裝內(nèi)容，在管理頁(yè)面中創(chuàng)建用戶(hù)。
spring.application.name=rabbitmq-hello

									spring.rabbitmq.host=localhost

									spring.rabbitmq.port=5672

									spring.rabbitmq.username=spring

									spring.rabbitmq.password=123456

創(chuàng)建消息生產(chǎn)者sender。通過(guò)注入amqptemplate接口的實(shí)例來(lái)實(shí)現(xiàn)消息的發(fā)送，amqptemplate接口定義了一套針對(duì)amqp協(xié)議的基礎(chǔ)操作。在spring boot中會(huì)根據(jù)配置來(lái)注入其具體實(shí)現(xiàn)。在該生產(chǎn)者，我們會(huì)產(chǎn)生一個(gè)字符串，并發(fā)送到名為hello的隊(duì)列中。

									@component

									public class sender {

									  @autowired

									  private amqptemplate rabbittemplate;

									  public void send() {

									    string context = "hello " + new date();

									    system.out.println("sender : " + context);

									    this.rabbittemplate.convertandsend("hello", context);

									  }

									}

創(chuàng)建消息消費(fèi)者receiver。通過(guò)@rabbitlistener注解定義該類(lèi)對(duì)hello隊(duì)列的監(jiān)聽(tīng)，并用@rabbithandler注解來(lái)指定對(duì)消息的處理方法。所以，該消費(fèi)者實(shí)現(xiàn)了對(duì)hello隊(duì)列的消費(fèi)，消費(fèi)操作為輸出消息的字符串內(nèi)容。

									@component

									@rabbitlistener(queues = "hello")

									public class receiver {

									  @rabbithandler

									  public void process(string hello) {

									    system.out.println("receiver : " + hello);

									  }

									}

創(chuàng)建rabbitmq的配置類(lèi)rabbitconfig，用來(lái)配置隊(duì)列、交換器、路由等高級(jí)信息。這里我們以入門(mén)為主，先以最小化的配置來(lái)定義，以完成一個(gè)基本的生產(chǎn)和消費(fèi)過(guò)程。

									@configuration

									public class rabbitconfig {

									  @bean

									  public queue helloqueue() {

									    return new queue("hello");

									  }

									}

創(chuàng)建應(yīng)用主類(lèi)：

									@springbootapplication

									public class helloapplication {

									  public static void main(string[] args) {

									    springapplication.run(helloapplication.class, args);

									  }

									}

創(chuàng)建單元測(cè)試類(lèi)，用來(lái)調(diào)用消息生產(chǎn)：

									@runwith(springjunit4classrunner.class)

									@springapplicationconfiguration(classes = helloapplication.class)

									public class helloapplicationtests {

									  @autowired

									  private sender sender;

									  @test

									  public void hello() throws exception {

									    sender.send();

									  }

									}

完成程序編寫(xiě)之后，下面開(kāi)始嘗試運(yùn)行。首先確保rabbitmq server已經(jīng)開(kāi)始，然后進(jìn)行下面的操作：

啟動(dòng)應(yīng)用主類(lèi)，從控制臺(tái)中，我們看到如下內(nèi)容，程序創(chuàng)建了一個(gè)訪問(wèn)127.0.0.1:5672中springcloud的連接。

復(fù)制代碼代碼如下:

	o.s.a.r.c.cachingconnectionfactory       : created new connection: simpleconnection@29836d32 [delegate=amqp://springcloud@127.0.0.1:5672/]

同時(shí)，我們通過(guò)rabbitmq的控制面板，可以看到connection和channels中包含當(dāng)前連接的條目。

運(yùn)行單元測(cè)試類(lèi)，我們可以看到控制臺(tái)中輸出下面的內(nèi)容，消息被發(fā)送到了rabbitmq server的hello隊(duì)列中。

1	`sender : hello sun sep` `25` `11:06:11` `cst` `2016`

切換到應(yīng)用主類(lèi)的控制臺(tái)，我們可以看到類(lèi)似如下輸出，消費(fèi)者對(duì)hello隊(duì)列的監(jiān)聽(tīng)程序執(zhí)行了，并輸出了接受到的消息信息。

1	`receiver : hello sun sep` `25` `11:06:11` `cst` `2016`

通過(guò)上面的示例，我們?cè)趕pring boot應(yīng)用中引入spring-boot-starter-amqp模塊，進(jìn)行簡(jiǎn)單配置就完成了對(duì)rabbitmq的消息生產(chǎn)和消費(fèi)的開(kāi)發(fā)內(nèi)容。然而在實(shí)際應(yīng)用中，我們還有很多內(nèi)容沒(méi)有演示，這里不做更多的講解，讀者可以自行查閱rabbitmq的官方教程，有更全面的了解。

完整示例：chapter5-2-1

開(kāi)源中國(guó)：http://git.oschina.net/didispace/springboot-learning/tree/master/chapter5-2-1
github：https://github.com/dyc87112/springboot-learning/tree/master/chapter5-2-1

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。

原文鏈接：http://blog.didispace.com/spring-boot-rabbitmq/