springboot集成 rabbitMQ

  1. 引入pom

      <!--rabbitmq-->
      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-amqp</artifactId>
      </dependency>
    
      <dependency>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-web</artifactId>
      </dependency>
    
  2. 配置 application.properties

    ## rabbitmq 配置(必須)
    spring.rabbitmq.host=192.168.63.112
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=admin
    spring.rabbitmq.password=admin
    spring.rabbitmq.virtual-host=light_test
    
    ## 隊(duì)列名稱
    spring.application.name=rabbitmq-provider
    spring.rabbitmq.exchageName=light_exchange
    spring.rabbitmq.queueName1=light_queue1
    
    ## 項(xiàng)目端口
    server.port=80
    
  3. 配置queue和exchage

    import org.springframework.amqp.core.*;
    import org.springframework.beans.factory.annotation.Configurable;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    
    
    /**
     * @Classname RabbitMQConfig
     * @Description TODO
     * @Date 2020/7/7 14:23
     * @Created by light
     */
    @Configurable
    public class RabbitMQConfig {
        @Value("${spring.rabbitmq.exchageName}")
        private String exchangeName;
    
    
        @Value("${spring.rabbitmq.queueName1}")
        private String queueName1;
    
    
        /**
         * 配置 exchange
         *
         * @return
         */
        @Bean
        public DirectExchange exchange() {
            return new DirectExchange(exchangeName, true, false);
        }
    
        /**
         * 配置 Queue1
         *
         * @return
         */
        @Bean
        public Queue lightQueue1() {
            return new Queue(queueName1, true);
        }
    
        /**
         * 綁定 指定的queue 到指定的 exchage 上
         * @return
         */
        @Bean
        public Binding bindingQueue1() {
           return  BindingBuilder.bind(lightQueue1())
                    .to(exchange())
                    .with(queueName1);
        }
    
    }
    
  4. 配置消費(fèi)者

    import org.springframework.amqp.rabbit.annotation.RabbitHandler;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.stereotype.Component;
    
    import java.util.Map;
    
    /**
    * @Classname RabbitMQConsumer
    * @Description TODO
    * @Date 2020/7/7 15:30
    * @Created by light
    */
    @Component
    @RabbitListener(queues = "light_queue1")
    public class RabbitMQConsumer {
       /**
        *  此方法為消費(fèi)方法
        * @param messageMap 參數(shù)為發(fā)送消息的 參數(shù)
        */
       @RabbitHandler
       public void process (Map messageMap) {
           System.out.println(messageMap.toString());
       }
    }
    
  5. 發(fā)送消息

    @Resource
    private RabbitTemplate rabbitTemplate;
    /**
     * 發(fā)送消息的方法
     */
    public void sendMq () {
        HashMap<String, String> map = new HashMap<>();
        map.put("name","light");
        map.put("id","1");
        map.put("type","1");
        rabbitTemplate.convertAndSend(exchateName,queueName1,map);
        System.out.println("發(fā)送成功");
    }
    
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市宇整,隨后出現(xiàn)的幾起案子瓶佳,更是在濱河造成了極大的恐慌,老刑警劉巖鳞青,帶你破解...
    沈念sama閱讀 221,820評論 6 515
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件霸饲,死亡現(xiàn)場離奇詭異为朋,居然都是意外死亡,警方通過查閱死者的電腦和手機(jī)厚脉,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 94,648評論 3 399
  • 文/潘曉璐 我一進(jìn)店門习寸,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人傻工,你說我怎么就攤上這事霞溪。” “怎么了中捆?”我有些...
    開封第一講書人閱讀 168,324評論 0 360
  • 文/不壞的土叔 我叫張陵鸯匹,是天一觀的道長。 經(jīng)常有香客問我轨香,道長忽你,這世上最難降的妖魔是什么? 我笑而不...
    開封第一講書人閱讀 59,714評論 1 297
  • 正文 為了忘掉前任臂容,我火速辦了婚禮科雳,結(jié)果婚禮上,老公的妹妹穿的比我還像新娘脓杉。我一直安慰自己糟秘,他們只是感情好,可當(dāng)我...
    茶點(diǎn)故事閱讀 68,724評論 6 397
  • 文/花漫 我一把揭開白布球散。 她就那樣靜靜地躺著尿赚,像睡著了一般。 火紅的嫁衣襯著肌膚如雪蕉堰。 梳的紋絲不亂的頭發(fā)上凌净,一...
    開封第一講書人閱讀 52,328評論 1 310
  • 那天,我揣著相機(jī)與錄音屋讶,去河邊找鬼冰寻。 笑死,一個(gè)胖子當(dāng)著我的面吹牛皿渗,可吹牛的內(nèi)容都是我干的斩芭。 我是一名探鬼主播,決...
    沈念sama閱讀 40,897評論 3 421
  • 文/蒼蘭香墨 我猛地睜開眼乐疆,長吁一口氣:“原來是場噩夢啊……” “哼划乖!你這毒婦竟也來了?” 一聲冷哼從身側(cè)響起挤土,我...
    開封第一講書人閱讀 39,804評論 0 276
  • 序言:老撾萬榮一對情侶失蹤琴庵,失蹤者是張志新(化名)和其女友劉穎,沒想到半個(gè)月后,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體细卧,經(jīng)...
    沈念sama閱讀 46,345評論 1 318
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡尉桩,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,431評論 3 340
  • 正文 我和宋清朗相戀三年,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了贪庙。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點(diǎn)故事閱讀 40,561評論 1 352
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡翰苫,死狀恐怖止邮,靈堂內(nèi)的尸體忽然破棺而出,到底是詐尸還是另有隱情奏窑,我是刑警寧澤导披,帶...
    沈念sama閱讀 36,238評論 5 350
  • 正文 年R本政府宣布,位于F島的核電站埃唯,受9級特大地震影響撩匕,放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜墨叛,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,928評論 3 334
  • 文/蒙蒙 一止毕、第九天 我趴在偏房一處隱蔽的房頂上張望。 院中可真熱鬧漠趁,春花似錦扁凛、人聲如沸。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,417評論 0 24
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至甥绿,卻和暖如春字币,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背共缕。 一陣腳步聲響...
    開封第一講書人閱讀 33,528評論 1 272
  • 我被黑心中介騙來泰國打工洗出, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人骄呼。 一個(gè)月前我還...
    沈念sama閱讀 48,983評論 3 376
  • 正文 我出身青樓共苛,卻偏偏與公主長得像,于是被迫代替她去往敵國和親蜓萄。 傳聞我的和親對象是個(gè)殘疾皇子隅茎,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,573評論 2 359