使用Spring和AMQP傳送接收訊息（中）

上篇講了rabbitmq連線工廠的作用是用來建立rabbitmq連線，本篇就來講講rabbitmq的傳送訊息。通過rabbitmq傳送訊息最簡單的方式就是將connectionfactory bean注入到服務層類中，並使用它建立connection，使用這個connection來建立channel，再使用這個channel發布訊息到exchange中。

當然spring amqp提供了rabbittemplate來簡便我們的操作，消除rabbitmq傳送和接收訊息相關的樣板**。使用rabbittemplate也是先在配置檔案中寫相關的配置，使用rabbit命名空間的元素，如下：

id="rabbittemplate"
connection-factory="connectionfactory">

現在要傳送訊息只需要將模板bean注入到服務層類中（這裡以sendserviceimpl為例），並使用它來傳送spittle，使用rabbittemplate來傳送spittle提醒，**如下：

public
class
sendserviceimpl
implements
sendservice 
public
void
sendspittle (spittle spittle) 
}

上面**中sendspittle()呼叫rabbittemplate的convertandsend()方法，傳入的三個引數分別是exchange的名稱、routing key以及要傳送的物件。

這裡如果使用最簡單的只傳要傳送的物件的過載方法，rabbittemplate就使用預設的exchange和routing key。按之前配置的話，這兩項預設都為空，也可以自行在元素上借助exchange和routing-key屬性配置不同的預設值：

"rabbittemplate" connection-factory
="connectionfactory"
exchange=
"spittle.test.exchange" 
routing-key
="spittle.test"
/>

此外rabbittemplate還有其他方法可以用來傳送訊息，比如用send()方法來傳送org.springframework.amqp.core.message物件，如下所示：

message
message = new message("hello world".getbytes(), new messageproperties());
rabbit.send("hello.exchange", "hello.routing", message);

使用send()方法的技巧在於構造要傳送的message物件，在上面的例子中，通過給定字串的位元組陣列來構建message例項。這裡是字串相對比較簡單，如果訊息是複雜物件的話，則會比較複雜。也是因為這樣，所以一般會用convertandsend()方法，它會自動將物件轉換為message，不過它需要乙個訊息轉換器來幫助完成該任務，預設的轉換器是******messageconverter，它適用於string、serializable例項和位元組陣列。

使用Spring和AMQP傳送接收訊息（中）

使用spring傳送郵件

Spring使用Velocity傳送Email

spring 傳送郵件

使用Spring和AMQP傳送接收訊息（中）

使用spring傳送郵件

Spring使用Velocity傳送Email

spring 傳送郵件

相關推薦