RabbitMQ的學習(五)：（最全面）Spring整合RabbitMQ進行RPC遠端呼叫
阿新 • • 發佈：2018-12-18
前面用java簡單對rabbitmq進行了學習，但rabbitmq的功能遠非如此，配合Spring或Springboot進行開發，才是java工程師做的工作，下面直接進行實戰：
一、建立SSM專案
PS初期web專案下載地址(單純的web，用於練習)：
https://download.csdn.net/download/shenhaiyushitiaoyu/10810264
專案名：RabbitMQWeb
SSM(未包含RabbitMQ)的目錄結構為：
以下是檔案內容：
- applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd"> <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer" > <property name="location" value="classpath:database.properties"></property> </bean> <!-- 定義資料來源dataSource --> <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" > <property name="driverClassName" value="${jdbc.driver}" /> <property name="url" value="${jdbc.url}" /> <property name="username" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}"/> </bean> <!-- 使用JNDI方式 --> <!-- <bean id="dataSource" class="org.springframework.jndi.JndiObjectFactoryBean" > <property name="jndiName" value="java:comp/env/jdbc/house"></property> </bean> --> <!-- 定義會話工廠sessionFactory --> <bean id="sessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean" > <property name="configLocation" value="classpath:mybatis-config.xml" /> <property name="dataSource" ref="dataSource"></property> </bean> <!-- 定義會話模板sqlSessionTemplate --> <bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate" scope="prototype" > <constructor-arg name="sqlSessionFactory" ref="sessionFactory" /> </bean> </beans>
- database.properties
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/house?useUnicode=true&characterEncoding=utf-8
jdbc.username=root
jdbc.password=root
- log4j.properties
# # Log4J Settings for log4j 1.2.x (via jakarta-commons-logging) # # The five logging levels used by Log are (in order): # # 1. DEBUG (the least serious) # 2. INFO # 3. WARN # 4. ERROR # 5. FATAL (the most serious) # Set root logger level to WARN and append to stdout # log4j.rootLogger=DEBUG, stdout, R log4j.appender.stdout=org.apache.log4j.ConsoleAppender log4j.appender.stdout.Target=System.out log4j.appender.stdout.layout=org.apache.log4j.PatternLayout log4j.appender.stdout.layout.ConversionPattern=%d %5p (%c:%L) - %m%n log4j.appender.R=org.apache.log4j.DailyRollingFileAppender log4j.appender.R.File=logs/syslog.log log4j.appender.R.DatePattern='.'yyyy-MM-dd log4j.appender.R.layout=org.apache.log4j.PatternLayout log4j.appender.R.layout.ConversionPattern=%d{yyyy/MM/dd HH\:mm\:ss} [%p] [%t] %c.%M(%F\:%L) - %m%n log4j.logger.noModule=FATAL log4j.logger.com.opensymphony.xwork2=ERROR log4j.logger.org.apache.struts2=ERROR
- mybatis-config.xml
<?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd"> <configuration> <!-- 設定相關資訊,需放在最前面 --> <settings> <setting name="logImpl" value="log4j"/> </settings> <!-- 設定別名 --> <typeAliases> </typeAliases> <!-- 管理對映檔案 --> <mappers> </mappers> </configuration>
- springmvc.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-3.2.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc.xsd">
<!-- BeanNameUrlHandlerMapping 將URL與controller進行對映 -->
<!-- <bean name="/login" class="controller.LoginController"> </bean> -->
<!-- DefaultAnnotationHandlerMapping 將URL與controller進行對映 -->
<context:component-scan base-package="test" />
<mvc:annotation-driven />
<!-- 檢視解析器 -->
<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver" >
<property name="prefix" value="/WEB-INF/jsp/"></property>
<property name="suffix" value=".jsp"></property>
</bean>
<!-- 靜態資原始檔進行處理,防止在訪問圖片、js、css檔案時作為請求進行攔截 -->
<mvc:resources location="/resources/" mapping="/resources/**"></mvc:resources>
<!-- 檔案上傳 -->
<bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver" >
<!-- <property name="maxUploadSize" value="2048000"></property> -->
<property name="defaultEncoding" value="UTF-8"></property>
<property name="maxUploadSize">
<value>102400000</value>
</property>
<property name="maxInMemorySize">
<value>10240000</value>
</property>
</bean>
</beans>
為減少練習時間，可以先下載這個web demo(這樣就可以直接在web基礎上練習不需要搭建MVC專案浪費時間)：
https://download.csdn.net/download/shenhaiyushitiaoyu/10810264
二、建立生產者和消費者：
注：本例是用direct交換器練習
- 消費者：MessageConsumer
import org.apache.log4j.Logger;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
public class MessageConsumer implements MessageListener {
private Logger logger = Logger.getLogger(MessageConsumer.class);
@Override
public void onMessage(Message message) {
logger.info("消費者和生產者專案---consumer receive message------->: "+message);
}
}
- 生產者：MessageProducer
import java.io.IOException;
import javax.annotation.Resource;
import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.stereotype.Service;
@Service
public class MessageProducer {
@Resource(name="amqpTemplate")
private AmqpTemplate amqpTemplate;
public void sendMessage(Object message) throws IOException {
amqpTemplate.convertAndSend("queueTestKey", message); //queueTestKey:路由鍵 名稱
}
}
- 配置檔案：
1-建立spring-rabbitmq.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/rabbit
http://www.springframework.org/schema/rabbit/spring-rabbit-1.2.xsd">
<!--配置connection-factory，指定連線rabbit server引數 -->
<rabbit:connection-factory id="connectionFactory"
username="guest" password="guest" host="localhost" port="5672" />
<!--通過指定下面的admin資訊，當前producer中的exchange和queue會在rabbitmq伺服器上自動生成 -->
<rabbit:admin id="connectAdmin" connection-factory="connectionFactory" />
<!--定義queue -->
<rabbit:queue name="queueTest" durable="true" auto-delete="false"
exclusive="false" declared-by="connectAdmin" />
<!-- 定義direct exchange，繫結queueTest -->
<rabbit:direct-exchange name="exchangeTest" durable="true" auto-delete="false" declared-by="connectAdmin">
<rabbit:bindings>
<rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding>
</rabbit:bindings>
</rabbit:direct-exchange>
<!--定義rabbit template用於資料的接收和傳送 -->
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="exchangeTest" />
<!--訊息接收者 com.consumer.MessageConsumer這個需要根據實際情況改過來-->
<bean id="messageReceiver" class="com.consumer.MessageConsumer"></bean>
<!-- queue litener 觀察 監聽模式 當有訊息到達時會通知監聽在對應的佇列上的監聽物件 -->
<rabbit:listener-container connection-factory="connectionFactory">
<rabbit:listener queues="queueTest" ref="messageReceiver" />
</rabbit:listener-container>
<!-- 其他的生產者，消費者，往下繼續新增即可 -->
</beans>
- applicationContext.xml檔案新增內容：
<!-- 匯入rabbit.xml檔案 -->
<import resource="classpath:spring-rabbitmq.xml"/>
圖示：
- 編寫測試controller：
import java.io.IOException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import com.producer.MessageProducer;
@Controller
@RequestMapping("test")
public class ReceiveRequestController {
@Autowired
private MessageProducer producer;
@RequestMapping("test")
public void test(){
try {
producer.sendMessage("測試進來啦啊 啊啊 啊");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
把專案新增到comcat中，啟動後，瀏覽器輸入：
http://localhost:8080/RabbitMQWeb/test/test
可以看到效果為：
至此已完成相關配置。只要懂得直接交換器的使用 其他兩個交換器和其他的消費者，生產者就知道如何使用了。目前我的專案目錄為：
demo下載地址：
https://download.csdn.net/download/shenhaiyushitiaoyu/10846118
下一篇我們將介紹兩個系統間的通訊，兩個系統通訊後，就可以對目前的大型專案進行拆分，做叢集，分散式就很有幫助了。