【Spring】使用Spring和AMQP發(fā)送接收消息(中)

上篇講了RabbitMQ連接工廠的作用是用來創(chuàng)建RabbitMQ的連接,本篇就來講講RabbitMQ的發(fā)送消息甘邀。通過RabbitMQ發(fā)送消息最簡單的方式就是將connectionFactory Bean注入到服務(wù)層類中,并使用它創(chuàng)建Connection春叫,使用這個Connection來創(chuàng)建Channel赠堵,再使用這個Channel發(fā)布消息到Exchange中。

當(dāng)然Spring AMQP提供了RabbitTemplate來簡便我們的操作起暮,消除RabbitMQ發(fā)送和接收消息相關(guān)的樣板代碼。使用RabbitTemplate也是先在配置文件中寫相關(guān)的配置会烙,使用Rabbit命名空間的<template>元素负懦,如下:

<template id="rabbitTemplate" connection-factory="connectionFactory">

現(xiàn)在要發(fā)送消息只需要將模板bean注入到服務(wù)層類中(這里以SendServiceImpl為例),并使用它來發(fā)送Spittle持搜,使用RabbitTemplate來發(fā)送Spittle提醒密似,代碼如下:

public class SendServiceImpl implements SendService {
    private RabbitTemplate rabbit;

    @Autowired
    public SendServiceImpl (RabbitTemplate rabbit) {
        this.rabbit = rabbit;
    }

    public void sendSpittle (Spittle spittle) {
        rabbit.convertAndSend("spittle.test.exchange", "spittle.test", spittle);
    }
}

上面代碼中sendSpittle()調(diào)用RabbitTemplate的convertAndSend()方法,傳入的三個參數(shù)分別是Exchange的名稱葫盼、routing key以及要發(fā)送的對象残腌。
這里如果使用最簡單的只傳要發(fā)送的對象的重載方法,RabbitTemplate就使用默認(rèn)的Exchange和routing key贫导。按之前配置的話抛猫,這兩項默認(rèn)都為空,也可以自行在<template>元素上借助exchange和routing-key屬性配置不同的默認(rèn)值:

<template id="rabbitTemplate" connection-factory="connectionFactory"
    exchange="spittle.test.exchange" 
    routing-key="spittle.test" />

此外RabbitTemplate還有其他方法可以用來發(fā)送消息孩灯,比如用send()方法來發(fā)送org.springframework.amqp.core.Message對象闺金,如下所示:

Message message = new Message("Hello World".getBytes(), new MessageProperties());
rabbit.send("hello.exchange", "hello.routing", message);

使用send()方法的技巧在于構(gòu)造要發(fā)送的Message對象,在上面的例子中峰档,通過給定字符串的字節(jié)數(shù)組來構(gòu)建Message實例败匹。這里是字符串相對比較簡單寨昙,如果消息是復(fù)雜對象的話,則會比較復(fù)雜掀亩。也是因為這樣舔哪,所以一般會用convertAndSend()方法,它會自動將對象轉(zhuǎn)換為Message槽棍,不過它需要一個消息轉(zhuǎn)換器來幫助完成該任務(wù)捉蚤,默認(rèn)的轉(zhuǎn)換器是SimpleMessageConverter,它適用于String炼七、Serializable實例和字節(jié)數(shù)組缆巧。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市豌拙,隨后出現(xiàn)的幾起案子陕悬,更是在濱河造成了極大的恐慌,老刑警劉巖姆蘸,帶你破解...
    沈念sama閱讀 211,817評論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件墩莫,死亡現(xiàn)場離奇詭異,居然都是意外死亡逞敷,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,329評論 3 385
  • 文/潘曉璐 我一進店門灌侣,熙熙樓的掌柜王于貴愁眉苦臉地迎上來推捐,“玉大人,你說我怎么就攤上這事侧啼∨F猓” “怎么了?”我有些...
    開封第一講書人閱讀 157,354評論 0 348
  • 文/不壞的土叔 我叫張陵痊乾,是天一觀的道長皮壁。 經(jīng)常有香客問我,道長哪审,這世上最難降的妖魔是什么蛾魄? 我笑而不...
    開封第一講書人閱讀 56,498評論 1 284
  • 正文 為了忘掉前任,我火速辦了婚禮湿滓,結(jié)果婚禮上滴须,老公的妹妹穿的比我還像新娘。我一直安慰自己叽奥,他們只是感情好扔水,可當(dāng)我...
    茶點故事閱讀 65,600評論 6 386
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著朝氓,像睡著了一般魔市。 火紅的嫁衣襯著肌膚如雪主届。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 49,829評論 1 290
  • 那天待德,我揣著相機與錄音君丁,去河邊找鬼。 笑死磅网,一個胖子當(dāng)著我的面吹牛谈截,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播涧偷,決...
    沈念sama閱讀 38,979評論 3 408
  • 文/蒼蘭香墨 我猛地睜開眼簸喂,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了燎潮?” 一聲冷哼從身側(cè)響起喻鳄,我...
    開封第一講書人閱讀 37,722評論 0 266
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎确封,沒想到半個月后除呵,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 44,189評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡爪喘,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,519評論 2 327
  • 正文 我和宋清朗相戀三年颜曾,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學(xué)時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片秉剑。...
    茶點故事閱讀 38,654評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡泛豪,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出侦鹏,到底是詐尸還是另有隱情诡曙,我是刑警寧澤,帶...
    沈念sama閱讀 34,329評論 4 330
  • 正文 年R本政府宣布略水,位于F島的核電站价卤,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏渊涝。R本人自食惡果不足惜慎璧,卻給世界環(huán)境...
    茶點故事閱讀 39,940評論 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望驶赏。 院中可真熱鬧炸卑,春花似錦、人聲如沸煤傍。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,762評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽蚯姆。三九已至五续,卻和暖如春洒敏,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背疙驾。 一陣腳步聲響...
    開封第一講書人閱讀 31,993評論 1 266
  • 我被黑心中介騙來泰國打工凶伙, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人它碎。 一個月前我還...
    沈念sama閱讀 46,382評論 2 360
  • 正文 我出身青樓函荣,卻偏偏與公主長得像,于是被迫代替她去往敵國和親扳肛。 傳聞我的和親對象是個殘疾皇子傻挂,可洞房花燭夜當(dāng)晚...
    茶點故事閱讀 43,543評論 2 349

推薦閱讀更多精彩內(nèi)容

  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn)挖息,斷路器金拒,智...
    卡卡羅2017閱讀 134,633評論 18 139
  • 1. 歷史 RabbitMQ是一個由erlang開發(fā)的AMQP(Advanced Message Queue )的...
    高廣超閱讀 6,092評論 3 51
  • 講AMQP之前,先講下傳統(tǒng)的JMS的消息模型套腹,JMS中主要有三個參與者:消息的生產(chǎn)者绪抛、消費者、傳遞消息的通道(隊列...
    weknow閱讀 1,439評論 0 3
  • 來源 RabbitMQ是用Erlang實現(xiàn)的一個高并發(fā)高可靠AMQP消息隊列服務(wù)器电禀。支持消息的持久化幢码、事務(wù)、擁塞控...
    jiangmo閱讀 10,350評論 2 34
  • 1 RabbitMQ安裝部署 這里是ErLang環(huán)境的下載地址http://www.erlang.org/down...
    Bobby0322閱讀 2,225評論 0 11