JAVAEE——宜立方商城02：服務中間件dubbo、工程改造爲基於soa架構、商品列表實現

時間 2019-11-11

標籤 javaee 立方商城服務中間件 dubbo 工程改造基於 soa 架構商品列表實現欄目 Java 简体版

原文原文鏈接

1. 學習計劃

次日：商品列表功能實現css

一、服務中間件dubbo前端

二、工程改造爲基於soa架構java

三、商品列表查詢功能實現。mysql

2. 將工程改造爲SOA架構

2.1. 分析

因爲宜立方商城是基於soa的架構，表現層和服務層是不一樣的工程。因此要實現商品列表查詢須要兩個系統之間進行通訊。linux

如何實現遠程通訊？git

1、Webservice：效率不高基於soap協議。項目中不推薦使用。github

2、使用restful形式的服務：http+json。不少項目中應用。若是服務太多，服務之間調用關係混亂，須要治療服務。web

3、使用dubbo。使用rpc協議進行遠程調用，直接使用socket通訊。傳輸效率高，而且能夠統計出系統之間的調用關係、調用次數。算法

2.2. dubbo

2.2.1. 什麼是dubbo

隨着互聯網的發展，網站應用的規模不斷擴大，常規的垂直應用架構已沒法應對，分佈式服務架構以及流動計算架構勢在必行，亟需一個治理系統確保架構有條不紊的演進。spring

單一應用架構

當網站流量很小時，只需一個應用，將全部功能都部署在一塊兒，以減小部署節點和成本。

此時，用於簡化增刪改查工做量的 數據訪問框架(ORM) 是關鍵。

垂直應用架構

當訪問量逐漸增大，單一應用增長機器帶來的加速度愈來愈小，將應用拆成互不相干的幾個應用，以提高效率。

此時，用於加速前端頁面開發的 Web框架(MVC) 是關鍵。

分佈式服務架構

當垂直應用愈來愈多，應用之間交互不可避免，將核心業務抽取出來，做爲獨立的服務，逐漸造成穩定的服務中心，使前端應用能更快速的響應多變的市場需求。

此時，用於提升業務複用及整合的 分佈式服務框架(RPC) 是關鍵。

流動計算架構

當服務愈來愈多，容量的評估，小服務資源的浪費等問題逐漸顯現，此時需增長一個調度中心基於訪問壓力實時管理集羣容量，提升集羣利用率。

此時，用於提升機器利用率的 資源調度和治理中心(SOA) 是關鍵。

Dubbo就是資源調度和治理中心的管理工具。

2.2.2. Dubbo的架構

節點角色說明：

Provider: 暴露服務的服務提供方。

Consumer: 調用遠程服務的服務消費方。

Registry: 服務註冊與發現的註冊中心。

Monitor: 統計服務的調用次調和調用時間的監控中心。

Container: 服務運行容器。

調用關係說明：

0. 服務容器負責啓動，加載，運行服務提供者。

1. 服務提供者在啓動時，向註冊中心註冊本身提供的服務。

2. 服務消費者在啓動時，向註冊中心訂閱本身所需的服務。

3. 註冊中心返回服務提供者地址列表給消費者，若是有變動，註冊中心將基於長鏈接推送變動數據給消費者。

4. 服務消費者，從提供者地址列表中，基於軟負載均衡算法，選一臺提供者進行調用，若是調用失敗，再選另外一臺調用。

5. 服務消費者和提供者，在內存中累計調用次數和調用時間，定時每分鐘發送一次統計數據到監控中心。

2.2.3. 使用方法

Dubbo採用全Spring配置方式，透明化接入應用，對應用沒有任何API侵入，只需用Spring加載Dubbo的配置便可，Dubbo基於Spring的Schema擴展進行加載。

單一工程中spring的配置

<bean id="xxxService" class="com.xxx.XxxServiceImpl" />
<bean id="xxxAction" class="com.xxx.XxxAction">
    <property name="xxxService" ref="xxxService" />
</bean>

遠程服務：

在本地服務的基礎上，只需作簡單配置，便可完成遠程化：

將上面的local.xml配置拆分紅兩份，將服務定義部分放在服務提供方remote-provider.xml，將服務引用部分放在服務消費方remote-consumer.xml。

並在提供方增長暴露服務配置<dubbo:service>，在消費方增長引用服務配置<dubbo:reference>。

發佈服務：

<!-- 和本地服務同樣實現遠程服務 -->
<bean id="xxxService" class="com.xxx.XxxServiceImpl" />
<!-- 增長暴露遠程服務配置 -->
<dubbo:service interface="com.xxx.XxxService" ref="xxxService" />

調用服務：

<!-- 增長引用遠程服務配置 -->
<dubbo:reference id="xxxService" interface="com.xxx.XxxService" />
<!-- 和本地服務同樣使用遠程服務 -->
<bean id="xxxAction" class="com.xxx.XxxAction">
    <property name="xxxService" ref="xxxService" />
</bean>

2.3. 註冊中心

2.3.1. Zookeeper介紹

官方推薦使用zookeeper註冊中心。

註冊中心負責服務地址的註冊與查找，至關於目錄服務，服務提供者和消費者只在啓動時與註冊中心交互，註冊中心不轉發請求，壓力較小。使用dubbo-2.3.3以上版本，建議使用zookeeper註冊中心。

Zookeeper是Apacahe Hadoop的子項目，是一個樹型的目錄服務，支持變動推送，適合做爲Dubbo服務的註冊中心，工業強度較高，可用於生產環境，並推薦使用

Zookeeper：

一、能夠做爲集羣的管理工具使用。

二、能夠集中管理配置文件。

2.3.2. Zookeeper的安裝

安裝環境：

Linux：centos6.4

Jdk:1.7以上版本

Zookeeper是java開發的能夠運行在windows、linux環境。須要先安裝jdk。

安裝步驟：

第一步：安裝jdk

第二步：把zookeeper的壓縮包上傳到linux系統。

第三步：解壓縮壓縮包

tar -zxvf zookeeper-3.4.6.tar.gz

--分別是四個參數

x : 從 tar 包中把文件提取出來

z : 表示 tar 包是被 gzip 壓縮過的，因此解壓時須要用 gunzip 解壓

v : 顯示詳細信息

f xxx.tar.gz : 指定被處理的文件是 xxx.tar.gz

第四步：進入zookeeper-3.4.6目錄，建立data文件夾。

mkdir data

第五步：把conf下的zoo_sample.cfg更名爲zoo.cfg（由於 Zookeeper 在啓動時會找這個文件做爲默認配置文件。）

[root@localhost conf]# mv zoo_sample.cfg zoo.cfg

第六步：修改data屬性：dataDir=/root/zookeeper-3.4.6/data

第七步：啓動zookeeper

[root@localhost bin]# ./zkServer.sh start

關閉：[root@localhost bin]# ./zkServer.sh stop

查看狀態：[root@localhost bin]# ./zkServer.sh status

注意：須要關閉防火牆。

service iptables stop

永久關閉修改配置開機不啓動防火牆：

chkconfig iptables off

若是不能成功啓動zookeeper，須要刪除data目錄下的zookeeper_server.pid文件。

2.4. 工程改造

2.4.1. 拆分工程

1）將表現層工程獨立出來：

e3-manager-web

2）將原來的e3-manager改成以下結構

e3-manager

|--e3-manager-dao

|--e3-manager-interface

|--e3-manager-pojo

|--e3-manager-service（打包方式改成war）

2.4.2. 服務層工程

第一步：把e3-manager的pom文件中刪除e3-manager-web模塊。

第二步：把e3-manager-web文件夾移動到e3-manager同一級目錄。

第三步：e3-manager-service的pom文件修改打包方式

第四步：在e3-manager-service工程中添加web.xml文件

第五步：把e3-manager-web的配置文件複製到e3-manager-service中。

刪除springmvc.xml

第六步：web.xml 中只配置spring容器。刪除前端控制器

第七步：發佈服務

一、在e3-manager-Service工程中添加dubbo依賴的jar包。

<!-- dubbo相關 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.jboss.netty</groupId>
                    <artifactId>netty</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>

2、在spring的配置文件中添加dubbo的約束，而後使用dubbo:service發佈服務。

<?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:dubbo="http://code.alibabatech.com/schema/dubbo" 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://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
    http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd">

    <context:component-scan base-package="cn.e3mall.service"></context:component-scan>

    <!-- 使用dubbo發佈服務 -->
    <!-- 提供方應用信息，用於計算依賴關係 -->
    <dubbo:application name="e3-manager" />
    <dubbo:registry protocol="zookeeper"
        address="192.168.25.154:2181,192.168.25.154:2182,192.168.25.154:2183" />
    <!-- 用dubbo協議在20880端口暴露服務 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!-- 聲明須要暴露的服務接口 -->
    <dubbo:service interface="cn.e3mall.service.ItemService" ref="itemServiceImpl" />

</beans>

改造e3-manager-web工程。2.4.3. 表現層工程

第一步：刪除mybatis、和spring的配置文件。只保留springmvc.xml

第二步：修改e3-manager-web的pom文件，

一、修改parent爲e3-parent

二、添加spring和springmvc的jar包的依賴

三、刪除e3-mangager-service的依賴

四、添加dubbo的依賴

<!-- dubbo相關 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework</groupId>
                    <artifactId>spring</artifactId>
                </exclusion>
                <exclusion>
                    <groupId>org.jboss.netty</groupId>
                    <artifactId>netty</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
        </dependency>

第三步：修改springmvc.xml，在springmvc的配置文件中添加服務的引用。五、e3-mangager-web添加對e3-manager-Interface的依賴。

<?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:context="http://www.springframework.org/schema/context" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 
    xmlns:mvc="http://www.springframework.org/schema/mvc"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.2.xsd
      http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd">

    <context:component-scan base-package="cn.e3mall.controller" />
    <mvc:annotation-driven />
    <bean
        class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix" value="/WEB-INF/jsp/" />
        <property name="suffix" value=".jsp" />
    </bean>
    
    <!-- 引用dubbo服務 -->
    <dubbo:application name="e3-manager-web"/>
    <dubbo:registry protocol="zookeeper" address="192.168.25.154:2181,192.168.25.154:2182,192.168.25.154:2183"/>    
    <dubbo:reference interface="cn.e3mall.service.ItemService" id="itemService" />
    
</beans>

第四步：在e3-manager-web工程中添加tomcat插件配置。

<build>
        <plugins>
            <!-- 配置Tomcat插件 -->
            <plugin>
                <groupId>org.apache.tomcat.maven</groupId>
                <artifactId>tomcat7-maven-plugin</artifactId>
                <configuration>
                    <path>/</path>
                    <port>8081</port>
                </configuration>
            </plugin>
        </plugins>
    </build>

2.5. Dubbo監控中心

須要安裝tomcat，而後部署監控中心便可。

1、部署監控中心：

[root@localhost ~]# cp dubbo-admin-2.5.4.war apache-tomcat-7.0.47/webapps/dubbo-admin.war

二、啓動tomcat

bin/startup.sh

查看啓動信息

tail -f logs/catalina.out

三、訪問http://192.168.25.167:8080/dubbo-admin/

用戶名：root

密碼：root

若是監控中心和註冊中心在同一臺服務器上，能夠不須要任何配置。

若是不在同一臺服務器，須要修改配置文件：

/root/apache-tomcat-7.0.47/webapps/dubbo-admin/WEB-INF/dubbo.properties

3. 商品列表查詢

3.1. 展現後臺首頁

3.1.1. 功能分析

請求的url：/

參數：無

返回值：邏輯視圖String

3.1.2. Controller

@Controller
public class PageController {

    @RequestMapping("/")
    public String showIndex() {
        return "index";
    }
    
    @RequestMapping("/{page}")
    public String showPage(@PathVariable String page) {
        return page;
    }
}

3.2. 功能分析

3.2.1. 整合靜態頁面

靜態頁面位置：02.次日（三大框架整合，後臺系統搭建）\01.參考資料\後臺管理系統靜態頁面

使用方法:

把靜態頁面添加到e3-manager-web工程中的WEB-INF下：

因爲在web.xml中定義的url攔截形式爲「/」表示攔截全部的url請求，包括靜態資源例如css、js等。因此須要在springmvc.xml中添加資源映射標籤：

<mvc:resources location="/WEB-INF/js/" mapping="/js/**"/>

<mvc:resources location="/WEB-INF/css/" mapping="/css/**"/>

3.2.2. 商品列表頁面

對應的jsp爲：

item-list.jsp

請求的url：

/item/list

請求的參數：

page=1&rows=30

響應的json數據格式：

Easyui中datagrid控件要求的數據格式爲：

{total:」2」,rows:[{「id」:」1」,」name」:」張三」},{「id」:」2」,」name」:」李四」}]}

3.2.3. 響應的json數據格式EasyUIResult

public class EasyUIDataGridResult {

    private Integer total;

    private List<?> rows;

    public EasyUIResult(Integer total, List<?> rows) {
        this.total = total;
        this.rows = rows;
    }

    public EasyUIResult(Long total, List<?> rows) {
        this.total = total.intValue();
        this.rows = rows;
    }

    public Integer getTotal() {
        return total;
    }

    public void setTotal(Integer total) {
        this.total = total;
    }

    public List<?> getRows() {
        return rows;
    }

    public void setRows(List<?> rows) {
        this.rows = rows;
    }

}

3.2.4. 分頁處理

逆向工程生成的代碼是不支持分頁處理的，若是想進行分頁須要本身編寫mapper，這樣就失去逆向工程的意義了。爲了提升開發效率可使用mybatis的分頁插件PageHelper。

3.3. 分頁插件PageHelper

3.3.1. Mybatis分頁插件 - PageHelper說明

若是你也在用Mybatis，建議嘗試該分頁插件，這個必定是最方便使用的分頁插件。

該插件目前支持Oracle,Mysql,MariaDB,SQLite,Hsqldb,PostgreSQL六種數據庫分頁。

3.3.2. 使用方法

第一步：把PageHelper依賴的jar包添加到工程中。官方提供的代碼對逆向工程支持的很差，使用參考資料中的pagehelper-fix。

第二步：在Mybatis配置xml中配置攔截器插件:

<plugins>
    <!-- com.github.pagehelper爲PageHelper類所在包名 -->
    <plugin interceptor="com.github.pagehelper.PageHelper">
        <!-- 設置數據庫類型 Oracle,Mysql,MariaDB,SQLite,Hsqldb,PostgreSQL六種數據庫-->        
        <property name="dialect" value="mysql"/>
    </plugin>
</plugins>

第二步：在代碼中使用

1、設置分頁信息：
    //獲取第1頁，10條內容，默認查詢總數count
    PageHelper.startPage(1, 10);

    //緊跟着的第一個select方法會被分頁
List<Country> list = countryMapper.selectIf(1);
2、取分頁信息
//分頁後，實際返回的結果list類型是Page<E>，若是想取出分頁信息，須要強制轉換爲Page<E>，
Page<Country> listCountry = (Page<Country>)list;
listCountry.getTotal();
3、取分頁信息的第二種方法
//獲取第1頁，10條內容，默認查詢總數count
PageHelper.startPage(1, 10);
List<Country> list = countryMapper.selectAll();
//用PageInfo對結果進行包裝
PageInfo page = new PageInfo(list);
//測試PageInfo所有屬性
//PageInfo包含了很是全面的分頁屬性
assertEquals(1, page.getPageNum());
assertEquals(10, page.getPageSize());
assertEquals(1, page.getStartRow());
assertEquals(10, page.getEndRow());
assertEquals(183, page.getTotal());
assertEquals(19, page.getPages());
assertEquals(1, page.getFirstPage());
assertEquals(8, page.getLastPage());
assertEquals(true, page.isFirstPage());
assertEquals(false, page.isLastPage());
assertEquals(false, page.isHasPreviousPage());
assertEquals(true, page.isHasNextPage());

3.3.3. 分頁測試

@Test
    public void testPageHelper() throws Exception {
        //初始化spring容器
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-*.xml");
        //得到Mapper的代理對象
        TbItemMapper itemMapper = applicationContext.getBean(TbItemMapper.class);
        //設置分頁信息
        PageHelper.startPage(1, 30);
        //執行查詢
        TbItemExample example = new TbItemExample();
        List<TbItem> list = itemMapper.selectByExample(example);
        //取分頁信息
        PageInfo<TbItem> pageInfo = new PageInfo<>(list);
        System.out.println(pageInfo.getTotal());
        System.out.println(pageInfo.getPages());
        System.out.println(pageInfo.getPageNum());
        System.out.println(pageInfo.getPageSize());
    }

3.4. Service層

參數：int page ，int rows

業務邏輯：查詢全部商品列表，要進行分頁處理。

返回值：EasyUIDataGridResult

@Override
    public EasyUIDataGridResult getItemList(int page, int rows) {
        
        //設置分頁信息
        PageHelper.startPage(page, rows);
        //執行查詢
        TbItemExample example = new TbItemExample();
        List<TbItem> list = itemMapper.selectByExample(example);
        //取分頁信息
        PageInfo<TbItem> pageInfo = new PageInfo<>(list);
        
        //建立返回結果對象
        EasyUIDataGridResult result = new EasyUIDataGridResult();
        result.setTotal(pageInfo.getTotal());
        result.setRows(list);
        
        return result;
    }

3.4.1. 發佈服務

3.5. 表現層

引用服務：

1、初始化表格請求的url：/item/list

2、Datagrid默認請求參數：

一、page：當前的頁碼，從1開始。

二、rows：每頁顯示的記錄數。

三、響應的數據：json數據。EasyUIDataGridResult

@RequestMapping("/item/list")
    @ResponseBody
    public EasyUIDataGridResult getItemList(Integer page, Integer rows) {
        EasyUIDataGridResult result = itemService.getItemList(page, rows);
        return result;
    }

能夠設置服務超時時間：

服務調用超時時間默認1秒，

Debug設置源代碼：