我們就來編寫一個RabbitMQ的入門案例,首先第一步呢,先要去創建一個Project,那么至于Project的創建方式呢,我們都可以,比如用Spring官網創建的方式,創建項目也可以,你也可以在IDEA當中,Eclipse當中,自己去new一個Project,然后自己手動添加配置,也是可以的,第一個步驟,創建項目,那我就直接在Eclipse上去創建了,點右鍵new一個Project,要創建的是一個Maven Project,然后給項目起一個groupId,com.learn,artifactId叫springcloud-mq,然后他的項目類型仍然是Package,項目創建好以后,我們要做一些修改,首先pom文件,pom文件這里是一個空的,那么怎么辦呢,我們可以從之前講過的項目,把它的pom文件引入過來,JDK是1.8的,Springboot的WEB啟動器我們要,我們還需要一個配置文件application.properties全局配置文件有了,我們還得去創建我們的啟動類,我們怎么去使用消息隊列,RabbitMQ,第一件事我們肯定是需要去導入相應的jar包,坐標去哪兒查找呢,我們打開spring的官網https://spring.io/然后我們找誰呢,去找springboothttps://spring.io/projects/spring-boot然后在SpringBoot當中呢如果你項目中用的是Apache的ActiveMQ,你就點他<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId> </dependency>把這個坐標拿過來,修改pom文件,添加RabbitMQ坐標,這一步搞定以后呢,接下來我們看,打開Maven Dependecies,可以看到Spring整合的amqp的jar包了org\springframework\amqp\spring-amqp\1.7.7.RELEASE\spring-amqp-1.7.7.RELEASE.jar還有com\rabbitmq\amqp-client\4.0.3\amqp-client-4.0.3.jar其實就是rabbitmq所指使用的jar包,接下來我們就可以去編寫代碼了,那么在編寫代碼之前呢,我們還要對配置文件做一個修改,修改全局配置文件,添加RabbitMQ相關的配置,那我們在全局配置文件里,要對RabbitMQ做什么配置呢,我們來看一下,首先我們可以給我們的項目起個名稱,可以通過配置文件來配置,spring.application.name,這是給項目起名稱,當然這個不是必須的,你這個配不配都可以,只是講到了這里就說一下,這樣你的應用在服務當中,就叫springcloud-mq了,當然和我們的項目名是一樣的,這個配完了以后,接下來就是和rabbitmq相關的配置了spring.application.name=springcloud-mq我們的項目要去連接我們的MQ,首先要知道MQ的地址和端口,還有運行時的密碼,其實我們要配置的就是這四項spring.rabbitmq.host=59.110.158.145 spring.rabbitmq.port=5672 spring.rabbitmq.username=guest spring.rabbitmq.password=guest來配一個IP,ip怎么配呢,spring.rabbitmq.host,就是你RabbitMQ安裝的地址,第二個是端口spring.rabbitmq.port,注意這是rabbit的端口,但是你要搞清楚,15672這是什么,這就是我們在安裝RabbitMQ的時候,裝的一個界面管理工具,這個是工具的一個端口,15672是RabbitMQ Management的端口,然后回過來,spring.rabbitmq.username,我們在安裝RabbitMQ的時候,新建了用戶了,告訴當前的用戶名是什么,我們是guest,有用戶名就有密碼,我們的密碼是guest,那么這四項就是對MQ的一個配置,其實很好理解,你看他們的key有一個共同的特點,都是spring.rabbitmq,后面分別是host,port,username,port,所以這個也很好記,這樣我們配置文件就搞定了 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.learn</groupId><artifactId>springcloud-mq</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>1.5.12.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><thymeleaf.version>3.0.9.RELEASE</thymeleaf.version><thymeleaf-layout-dialect.version>2.2.2</thymeleaf-layout-dialect.version></properties><dependencies><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><!-- <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency> --></dependencies><!-- 這個插件,可以將應用打包成一個可執行的jar包 --><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project> #server.port=8010 spring.application.name=springcloud-mq spring.rabbitmq.host=59.110.158.145 spring.rabbitmq.username=guest spring.rabbitmq.password=guest spring.rabbitmq.port=5672 package com.learn;import org.springframework.amqp.rabbit.annotation.EnableRabbit; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication;/*** 自動配置* @author Leon.Sun*/ @SpringBootApplication @EnableRabbit public class SpringBootMQApplication {public static void main(String[] args) {// Spring應用啟動起來SpringApplication.run(SpringBootMQApplication.class,args);}}

?

總結

以上是生活随笔為你收集整理的消息队列入门案例-环境搭建的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。