2. 程式人生 > >Active整合Spring

Active整合Spring

阿新 • • 發佈：2018-11-10

1 課程計劃

第八天：

  1. Activemq整合springMQ的應用場景
  2. 新增商品同步索引庫
  3. 商品詳情頁面動態展示
  4. 展示詳情頁面使用快取

2 Activemq整合spring

2.1 使用方法

第一步：引用相關的jar包。

<dependency>

                  <groupId>org.springframework</

groupId>

                  <artifactId>spring-jms</artifactId>

            </dependency>

            <dependency

>

                  <groupId>org.springframework</groupId>

                  <artifactId>spring-context-support</artifactId>

            </

dependency>

第二步：配置Activemq整合spring。配置ConnectionFactory

在e3-manager-service建立applicationContext-activemq.xml配置檔案：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

      xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

      xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd

      http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd

      http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd

      http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd

      http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">

 

 

      <!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供 -->

      <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

            <property name="brokerURL" value="tcp://192.168.25.168:61616" />

      </bean>

      <!-- Spring用於管理真正的ConnectionFactory的ConnectionFactory -->

      <bean id="connectionFactory"

            class="org.springframework.jms.connection.SingleConnectionFactory">

            <!-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory -->

            <property name="targetConnectionFactory" ref="targetConnectionFactory" />

      </bean>

</beans>

第三步：配置生產者。

使用JMSTemplate物件。傳送訊息。

第四步：在spring容器中配置Destination。

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

      xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

      xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"

      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd

      http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd

      http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd

      http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">

 

      <!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供 -->

      <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

            <property name="brokerURL" value="tcp://192.168.25.167:61616" />

      </bean>

      <!-- Spring用於管理真正的ConnectionFactory的ConnectionFactory -->

      <bean id="connectionFactory"

            class="org.springframework.jms.connection.SingleConnectionFactory">

            <!-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory -->

            <property name="targetConnectionFactory" ref="targetConnectionFactory" />

      </bean>

      <!-- 配置生產者 -->

      <!-- Spring提供的JMS工具類，它可以進行訊息傳送、接收等 -->

      <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">

            <!-- 這個connectionFactory對應的是我們定義的Spring提供的那個ConnectionFactory物件 -->

            <property name="connectionFactory" ref="connectionFactory" />

      </bean>

      <!--這個是佇列目的地，點對點的 -->

      <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">

            <constructor-arg>

                  <value>spring-queue</value>

            </constructor-arg>

      </bean>

      <!--這個是主題目的地，一對多的 -->

      <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">

            <constructor-arg value="topic" />

      </bean>

</beans>

第五步：程式碼測試

在e3-manager-service工程建立測試類：

@Test

      public void testSpringActiveMq() throws Exception {

            //初始化spring容器

            ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-activemq.xml");

            //從spring容器中獲得JmsTemplate物件

            JmsTemplate jmsTemplate = applicationContext.getBean(JmsTemplate.class);

            //從spring容器中取Destination物件

            Destination destination = (Destination) applicationContext.getBean("queueDestination");

            //使用JmsTemplate物件傳送訊息。

            jmsTemplate.send(destination, new MessageCreator() {

                 

                  @Override

                  public Message createMessage(Session session) throws JMSException {

                        //建立一個訊息物件並返回

                        TextMessage textMessage = session.createTextMessage("spring activemq queue message");

                        return textMessage;

                  }

            });

      }

啟動消費者：

2.2 程式碼測試

2.2.1 傳送訊息

第一步：初始化一個spring容器

第二步：從容器中獲得JMSTemplate物件。

第三步：從容器中獲得一個Destination物件

第四步：使用JMSTemplate物件傳送訊息，需要知道Destination

@Test

      public void testQueueProducer() throws Exception {

            // 第一步：初始化一個spring容器

            ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-activemq.xml");

            // 第二步：從容器中獲得JMSTemplate物件。

            JmsTemplate jmsTemplate = applicationContext.getBean(JmsTemplate.class);

            // 第三步：從容器中獲得一個Destination物件

            Queue queue = (Queue) applicationContext.getBean("queueDestination");

            // 第四步：使用JMSTemplate物件傳送訊息，需要知道Destination

            jmsTemplate.send(queue, new MessageCreator() {

                 

                  @Override

                  public Message createMessage(Session session) throws JMSException {

                        TextMessage textMessage = session.createTextMessage("spring activemq test");

                        return textMessage;

                  }

            });

      }

2.2.2 接收訊息

e3-search-Service中接收訊息複製applicationContext-activemq.xml配置檔案到工程下。

第一步：把Activemq相關的jar包新增到工程中

第二步：建立一個MessageListener的實現類。

public class MyMessageListener implements MessageListener {

 

      @Override

      public void onMessage(Message message) {

           

            try {

                  TextMessage textMessage = (TextMessage) message;

                  //取訊息內容

                  String text = textMessage.getText();

                  System.out.println(text);

            } catch (JMSException e) {

                  e.printStackTrace();

            }

      }

 

}

第三步：配置spring和Activemq整合。

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

      xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p"

      xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"

      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

      xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd

      http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd

      http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd

      http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">

 

      <!-- 真正可以產生Connection的ConnectionFactory，由對應的 JMS服務廠商提供 -->

      <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

            <property name="brokerURL" value="tcp://192.168.25.167:61616" />

      </bean>

      <!-- Spring用於管理真正的ConnectionFactory的ConnectionFactory -->

      <bean id="connectionFactory"

            class="org.springframework.jms.connection.SingleConnectionFactory">

            <!-- 目標ConnectionFactory對應真實的可以產生JMS Connection的ConnectionFactory -->

            <property name="targetConnectionFactory" ref="targetConnectionFactory" />

      </bean>

      <!--這個是佇列目的地，點對點的 -->

      <bean id="queueDestination" class="org.apache.activemq.command.ActiveMQQueue">

            <constructor-arg>

                  <value>spring-queue</value>

            </constructor-arg>

      </bean>

      <!--這個是主題目的地，一對多的 -->

      <bean id="topicDestination" class="org.apache.activemq.command.ActiveMQTopic">

            <constructor-arg value="topic" />

      </bean>

      <!-- 接收訊息 -->

      <!-- 配置監聽器 -->

      <bean id="myMessageListener" class="cn.e3mall.search.listener.MyMessageListener" />

      <!-- 訊息監聽容器 -->

      <bean class="org.springframework.jms.listener.DefaultMessageListenerContainer">

            <property name="connectionFactory" ref="connectionFactory" />

            <property name="destination" ref="queueDestination" />

            <property name="messageListener" ref="myMessageListener" />

      </bean>

</beans>

第四步：測試程式碼。

@Test

      public void testQueueConsumer() throws Exception {

            //初始化spring容器

            ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-activemq.xml");

            //等待

            System.in.read();

      }

3 新增商品同步索引庫

e3-search-service（消費者）：

ItemMapper.java：

ItemMapper.xml：

ItemAddMessageListener.java：

applicationContext-activemq.xml配置消費者生效 （被多個客戶端接受使用topic）：

e3-manager-service（訊息提供者）：

applicationContext-activemq.xml：

ItemServiceImpl：

在新增商品的方法中（問題：事務還沒提交那邊已經查資料庫可能導致空指標異常）：

解決空指標異常（接受訊息時等待1秒或者在事務提交後在controller層進行訊息傳送）：

e3-search-service：

ItemAddMessageListener.java：

切換solr為單機版測試：

e3-search-service：

applicationContext-solr.xml：

啟動zookeeper單機版 redis單機版 solr單機版即可

/3.1 Producer（）

e3-manager-server工程中傳送訊息。

當商品新增完成後傳送一個TextMessage，包含一個商品id。

@Override

      public e3Result addItem(TbItem item, String desc) {

            // 1、生成商品id

            final long itemId = IDUtils.genItemId();

            // 2、補全TbItem物件的屬性

            item.setId(itemId);

            //商品狀態，1-正常，2-下架，3-刪除

            item.setStatus((byte) 1);

            Date date = new Date();

            item.setCreated(date);

            item.setUpdated(date);

            // 3、向商品表插入資料

            itemMapper.insert(item);

            // 4、建立一個TbItemDesc物件

            TbItemDesc itemDesc = new TbItemDesc();

            // 5、補全TbItemDesc的屬性

            itemDesc.setItemId(itemId);

            itemDesc.setItemDesc(desc);

            itemDesc.setCreated(date);

            itemDesc.setUpdated(date);

            // 6、向商品描述表插入資料

            itemDescMapper.insert(itemDesc);

            //傳送一個商品新增訊息

            jmsTemplate.send(topicDestination, new MessageCreator() {

                 

                  @Override

                  public Message createMessage(Session session) throws JMSException {

                        TextMessage textMessage = session.createTextMessage(itemId + "");

                        return textMessage;

                  }

            });

            // 7、e3Result.ok()

            return e3Result.ok();

      }

3.2 Consumer（）

3.2.1 功能分析

  1. 接收訊息。需要建立MessageListener介面的實現類。
  2. 取訊息，取商品id。
  3. 根據商品id查詢資料庫。
  4. 建立一SolrInputDocument物件。
  5. 使用SolrServer物件寫入索引庫。
  6. 返回成功，返回e3Result。

3.2.2 Dao層

根據商品id查詢商品資訊。

對映檔案：

<select id="getItemById" parameterType="long" resultType="cn.e3mall.common.pojo.SearchItem">

            SELECT

                  a.id,

                  a.title,

                  a.sell_point,

                  a.price,

                  a.image,

                  b. NAME category_name,

                  c.item_desc

            FROM

                  tb_item a

            JOIN tb_item_cat b ON a.cid = b.id

            JOIN tb_item_desc c ON a.id = c.item_id

            WHERE a.status = 1

              AND a.id=#{itemId}

      </select>

3.2.3 Service層

引數：商品ID

業務邏輯：

  1. 根據商品id查詢商品資訊。
  2. 建立一SolrInputDocument物件。
  3. 使用SolrServer物件寫入索引庫。
  4. 返回成功，返回e3Result。

返回值：e3Result

public e3Result addDocument(long itemId) throws Exception {

            // 1、根據商品id查詢商品資訊。

            SearchItem searchItem = searchItemMapper.getItemById(itemId);

            // 2、建立一SolrInputDocument物件。

            SolrInputDocument document = new SolrInputDocument();

            // 3、使用SolrServer物件寫入索引庫。

            document.addField("id", searchItem.getId());

            document.addField("item_title", searchItem.getTitle());

            document.addField("item_sell_point", searchItem.getSell_point());

            document.addField("item_price", searchItem.getPrice());

            document.addField("item_image", searchItem.getImage());

            document.addField("item_category_name", searchItem.getCategory_name());

            document.addField("item_desc", searchItem.getItem_desc());

            // 5、向索引庫中新增文件。

            solrServer.add(document);

            solrServer.commit();

            // 4、返回成功，返回e3Result。

            return e3Result.ok();

      }

3.2.4 Listener

public class ItemChangeListener implements MessageListener {

     

      @Autowired

      private SearchItemServiceImpl searchItemServiceImpl;

 

      @Override

      public void onMessage(Message message) {

            try {

                  TextMessage textMessage = null;

                  Long itemId = null;

                  //取商品id

                  if (message instanceof TextMessage) {

                        textMessage = (TextMessage) message;

                        itemId = Long.parseLong(textMessage.getText());

                  }

                  //向索引庫新增文件

                  searchItemServiceImpl.addDocument(itemId);

                 

            } catch (Exception e) {

                  e.printStackTrace();

            }

      }

 

}

3.2.5 Spring配置監聽

/

3.2.6 實現流程

4 商品詳情頁面展示

建立一個商品詳情頁面展示的工程。是一個表現層工程。

4.1 工程搭建

e3-item-web。打包方式war。可以參考e3-portal-web

4.1.1 Pom檔案

<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>

      <parent>

            <groupId>cn.e3mall</groupId>

            <artifactId>e3-parent</artifactId>

            <version>0.0.1-SNAPSHOT</version>

      </parent>

      <groupId>cn.e3mall</groupId>

      <artifactId>e3-item-web</artifactId>

      <version>0.0.1-SNAPSHOT</version>

      <packaging>war</packaging>

      <dependencies>

            <dependency>

                  <groupId>cn.e3mall</groupId>

                  <artifactId>e3-manager-interface</artifactId>

                  <version>0.0.1-SNAPSHOT</version>

            </dependency>

            <!-- Spring -->

            <dependency>

                  <groupId>org.springframework</groupId>

                  <artifactId>spring-context</artifactId>

            </dependency>

            <dependency>

                  <groupId>org.springframework</groupId>

                  <artif

相關推薦

Active整合Spring

1 課程計劃 第八天： Activemq整合springMQ的應用場景 新增商品同步索引庫 商品詳情頁面動態展示 展示詳情頁面使用快取 2 Activemq整合spring 2.1 使用方法 第一步：引用相關的jar包。

active mq 整合spring 並持久化到資料庫

active mq 整合spring 就直接看程式碼即可。 github ：https://github.com/734839030/spring-amq.git 下載講如何持久化到資料庫 找到  conf/activemq.xml 找到broker 節點註釋掉預設的持久化

CXF WebService整合Spring

部分 控制 utf 內容 使用 mes classpath html row 首先，CXF和spring整合需要準備如下jar包文件： 這邊我是用Spring的jar包是Spring官方提供的，並沒有使用CXF中的Spring的jar文件。 添加這麽多文件後，首先在web

整合 Spring + SpringMVC + MyBatis

provide star 實現 per ng- 獲取自增 check fas manage < 一 > POM 配置文件 ( 如果出現 JAR 包 引入錯誤, 請自行下載 ) <project xmlns="http://maven.apach

RabbitMQ整合spring

username cep virtual containe 1.7 dconf system xmlns war 1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://ww

MyBatis使用總結+整合Spring

hal bench his nic sig cti chan ive sha Java%E7%A8%8B%E5%BA%8F%E5%91%98%E7%9A%84%E6%97%A5%E5%B8%B8%E2%80%94%E2%80%94%20%E3%80%8A%E7%BC%96%

CXF整合spring，在tomcat中發布webService

load loader print protect 分享 list factor 信息 ioe 1、首先下載CXF的jar包 http://pan.baidu.com/s/1dFBwSRf 密碼: qyax。裏面自帶了需要用到的spring的jar包 2、新建一個web項目

mybatis 整合spring之mapperLocations配置的問題

any 引入 location rop myba 路徑 通過 user configure 今天嘗試spring整合mybatis時遇到這麽一個問題，就是在配置sqlSessionFactory時是否要配置mapperLocations的問題。 <bean i

整合Spring框架和Hibernate框架

slf4j erl update rep java 監聽 session hiberna .cn -------------------siwuxie095 整合 Spring 框架和 Hibernate 框架

Shiro整合Spring

static actor rate utf-8 -i pen aso not exp 首先需要添加shiro的spring整合包。 要想在WEB應用中整合Spring和Shiro的話，首先需要添加一個由spring代理的過濾器如下： <!-- The filter-

（二）整合spring cloud雲服務架構 - particle雲架構

介紹 能夠 步驟 架構 第一篇 img .net 業務 服務架構 第一篇文章簡單給大家介紹了Spring Cloud架構，我這邊結合了當前大部分企業的通用需求，包括技術的選型比較嚴格、苛刻，不僅要用業界最流行的技術，還要和國際接軌，在未來的5~10年內不能out。作為公司

（一）整合spring cloud雲服務架構 - Spring Cloud簡介

springcloud 架構 雲服務 Spring Cloud是一系列框架的有序集合。利用Spring Boot的開發模式簡化了分布式系統基礎設施的開發，如服務發現、註冊、配置中心、消息總線、負載均衡、斷路器、數據監控等（這裏只簡單的列了一部分），都可以用Spring Boot的開發風格做到一鍵啟動和部署

（三）整合spring cloud雲服務架構 - particle雲架構代碼結構構建

itl log lan 作用 購物 基本架構 集成 eight control 上一篇介紹了spring cloud雲服務架構的基本架構圖，本篇我們根據架構圖進行代碼的構建，根據微服務化設計思想，結合spring cloud本身的服務發現、治理、配置化管理、分布式等項目優秀

（四）整合spring cloud雲服務架構 - particle-common-framework代碼介紹

.cn server control 簡單的 阿裏巴巴 統計 icontrol htm 回顧 上一篇我們介紹了spring cloud雲服務架構 - particle雲架構代碼結構，簡單的按照幾個大的部分去構建代碼模塊，讓我們來回顧一下： 第一部分： 針對於普通服務的基礎

（六）整合spring cloud雲服務架構 - HongHu雲架構common-service代碼結構分析

如何 通過 -m 交互 art 實現 使用 sof 組織 當前的分布式微服務雲架構平臺使用Maven構建，所以common-service的通用服務按照maven構建獨立的系統服務，結構如下： particle-commonservice： spring cloud 系統

（五） 整合spring cloud雲服務架構 - HongHu雲架構代碼結構構建

簡單 通用組 朋友 做到 根據 ref 工作 拆分 space 本篇我們根據架構圖進行代碼的構建。根據微服務化設計思想，結合spring cloud一些優秀的項目，如服務發現、治理、配置化管理、路由負載、安全控制等優秀解決方案，使用Maven技術將框架進行模塊化、服務化、原

整合spring cloud企業分布式微服務雲架構

pri 研發 記錄 包括 space https 朋友 通用 業界 今天正式給大家介紹了Spring Cloud - HongHu企業分布式微服務雲架構，我這邊結合了當前大部分企業的通用需求，包括技術的選型比較嚴格、苛刻，不僅要用業界最流行的技術，還要和國際接軌，在未來的5

整合spring cloud雲服務架構代碼結構構建

springcloud spring springboot springmvc maven 架構 本篇我們根據架構圖進行代碼的構建。根據微服務化設計思想，結合spring cloud一些優秀的項目，如服務發現、治理、配置化管理、路由負載、安全控制等優秀解決方案，使用Maven技術將框架

整合spring cloud雲服務架構 - HongHu commonservice-eureka 項目構建過程

spring boot 現在我們針對於HongHu cloud的eureka項目做以下構建，整個構建的過程很簡單，我會將每一步都構建過程記錄下來，希望可以幫助到大家：1. 創建一個名為particle-common-eureka的maven項目，繼承particle-commonservice，具體的

整合spring cloud雲服務架構 - 雲架構代碼結構構建

jpg get 朋友 blank 思想 搭建過程 重要 我們 負載 上一篇介紹了《整合spring cloud雲服務架構 - 企業分布式微服務雲架構圖》，本篇我們根據架構圖進行代碼的構建。根據微服務化設計思想，結合spring cloud一些優秀的項目，如服務發現、治理、配