bjsxt學習筆記：Dubbo的最基礎使用

時間 2019-11-09

標籤 bjsxt 學習筆記 dubbo 基礎使用欄目 Dubbo 简体版

原文原文鏈接

1、Dubbo誕生背景（摘自Dubbo官網-入門-背景）html

2、Dubbo架構圖（摘自Dubbo官網-入門-架構）java

3、Dubbo核心依賴（jar包）：dubbo、zkclientweb

4、Dubbo項目搭建的方式：配置文件式、註解式spring

5、Dubbo項目配置文件的核心配置：apache

　　(一)配置文件式架構

　　　　1. 服務提供方（下示例）：①應用名②協議(建議dubbo協議)③註冊中心④暴露的服務接口⑤註冊暴露的服務接口的實現類bean對象app

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       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.xsd
                            http://code.alibabatech.com/schema/dubbo
                            http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!--配置提供服務方應用信息，用於計算依賴關係-->
    <dubbo:application name="provide-xml"/>
    <!--配置協議（用dubbo協議在20880端口(dubbo協議默認端口)暴露服務）-->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!--配置註冊中心，以暴露服務地址-->
    <dubbo:registry address="zookeeper://192.168.110.11:2181"/>
    <!--配置暴露服務的接口-->
    <dubbo:service interface="com.bjsxt.dubbo.service.ITPService_xml" ref="dataServiceImpl"/>
    <!--註冊暴露的服務接口的實現類的bean對象-->
    <bean id="dataServiceImpl" class="com.bjsxt.dubbo.service.impl.ITPServiceImpl_xml"/>
</beans>

　　　　2. 服務消費方(下示例)：①應用名②註冊中心③提供方暴露的服務接口框架

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       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.xsd
                            http://code.alibabatech.com/schema/dubbo
                            http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!--配置消費方應用名，用於計算依賴關係，不是匹配條件，不要與提供方同樣-->
    <dubbo:application name="consumer-xml"></dubbo:application>
    <!--配置註冊中心，暴露發現服務地址-->
    <dubbo:registry address="zookeeper://192.168.110.11:2181"/>
    <!--聲明所要調用的服務提供方暴露的服務接口（前提：已經將該接口複製到消費方的業務層中）-->
    <dubbo:reference interface="com.bjsxt.dubbo.service.ITPService_xml" id="iTPService"/>
</beans>

　　(二)註解式maven

　　　　1. 服務提供方（下示例）：①應用名②協議③註冊中心④dubbo註解掃描ide

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       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.xsd
                            http://code.alibabatech.com/schema/dubbo
                            http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!--配置提供服務方應用信息，用於計算依賴關係-->
    <dubbo:application name="provide-annotation"/>
    <!--配置協議（用dubbo協議在20880端口(dubbo協議默認端口)暴露服務）-->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!--配置註冊中心，以暴露服務地址-->
    <dubbo:registry address="zookeeper://192.168.110.11:2181"/>
    <!--配置dubbo註解掃描(註解式：利用dubbo的註解@Service來代替配置式的另外兩個配置)-->
    <dubbo:annotation package="com.bjsxt.dubbo.service.impl"/>
</beans>

　　　　2. 服務消費方(下示例)：①應用名②註冊中心③dubbo註解掃描④聲明調用暴露的服務接口的業務層實現類bean對象

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       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.xsd
                            http://code.alibabatech.com/schema/dubbo
                            http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!--配置消費方應用名，用於計算依賴關係，不是匹配條件，不要與提供方同樣-->
    <dubbo:application name="consumer-annotation"></dubbo:application>
    <!--配置註冊中心，暴露發現服務地址-->
    <dubbo:registry address="zookeeper://192.168.110.11:2181"/>
    <!--配置dubbo註解掃描-->
    <dubbo:annotation package="com.bjsxt.dubbo.service.impl"/>
    <!--配置服務消費者調用提供方暴露的服務接口的業務實現類bean對像-->
    <bean id="iTServiceConsumerImpl_SSM" class="com.bjsxt.dubbo.service.impl.ITServiceConsumerImpl_SSM"/>
</beans>

6、示例-簡單實現Dubbo項目：

　　(〇)本人測試項目的環境搭建：

　　　　①maven下Java的quickstart模板②沒有用SSM框架③註冊中心選用zookeeper，安裝在Linux虛擬機中

　　　　④沒有面向對象三層架構中的持久層，只有數據類pojo/entity（測試數據本身在服務方暴露的服務接口的實現類的測試方法中自設定）

　　(一)配置文件式

　　　　1. 項目代碼：

　　　　　　(1)服務提供方：

　　　　　　　　①數據類pojo/entity

package com.bjsxt.dubbo.pojo;

import lombok.Data;
import java.io.Serializable;

@Data
public class TestData implements Serializable {
    private Integer uid;
    private String uname;
}

　　　　　　　　②業務層service

　　　　　　　　　　i. 暴露的服務接口

package com.bjsxt.dubbo.service;

import com.bjsxt.dubbo.pojo.TestData;
import java.util.List;

public interface ITPService_xml {
    //查詢測試數據
    List<TestData> selectTestData();
}

　　　　　　　　　 ii. 暴露的服務接口的實現類

package com.bjsxt.dubbo.service.impl;

import com.bjsxt.dubbo.pojo.TestData;
import com.bjsxt.dubbo.service.ITPService_xml;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
/**
 * spring框架中的@Autowired註解、@Resource註解和@Service註解
 * @Autowired註解 省去了 在xml中<bean>配置的 <property> 和在對應<bean> 類中 屬性的set、get方法
 * @Resource註解  和@Autowired註解 極爲類似
 * @Service註解   省去了 在xml中<bean>的配置 ！ 實現 xml零配置
 * 詳情：再說~
 */
@Service
public class ITPServiceImpl_xml implements ITPService_xml {
    //查詢測試數據(省略持久層，自定義測試數據)
    @Override
    public List<TestData> selectTestData() {
        ArrayList<TestData> list=new ArrayList<>();
        TestData testData=new TestData();
        testData.setUid(0);
        testData.setUname("fuck");
        list.add(testData);
        return list;
    }
}

　　　　　　(2)服務消費方：

　　　　　　　　①數據類pojo/entity：同上

　　　　　　　　②業務層service：將服務提供方暴露的服務接口的代碼複製過來，便可

　　　　2. 啓動方式：

　　　　　　(1)服務提供方：

　　　　　　　　①API加載配置文件（本人沒寫這種方式）（能夠參考下面的服務消費方的啓動方式，也能夠看Dubbo官網給出的示例代碼）：

import org.springframework.context.support.ClassPathXmlApplicationContext;
 
public class Provider {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"http://10.20.160.198/wiki/display/dubbo/provider.xml"});
        context.start();
        System.in.read(); // 按任意鍵退出
    }
}

　　　　　　　　②利用dubbo服務運行容器的main方法：

　　　　　　　　　　前提：將spring配置文件安放在META-INF目錄下的spring目錄中，不然dubbo服務運行容器找不到spring配置文件

package com.bjsxt.dubbo;

import com.alibaba.dubbo.container.Main;
public class AppTest {
    /**
     * 經過加載spring配置文件，以啓動dubbo的服務運行容器Container
     * （該容器是spring類型的容器，
     *      dubbo配置式啓動方法，除了直接加載spring配置文件，
     *      再就是下面的經過dubbo中的Main類加載spring配置文件
     *          ——該方法需要將spring配置文件放在「META-INF」目錄下的「spring」目錄中）
     */
    public static void main(String[] args) {Main.main(args);}
}

【運行結果·圖】（前提：已經啓動zookeeper註冊中心，註冊中心啓動成功圖略）（注：運行後，須手動關閉）

　　　　　　(2)服務消費方：API加載配置文件

package com.bjsxt.dubbo;

import com.bjsxt.dubbo.pojo.TestData;
import com.bjsxt.dubbo.service.ITPService_xml;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.util.List;
/**
 * 這裏只是簡單的測試一下，不涉及web，服務提供方也不涉及持久層
 */
public class AppTest {
    @Test
    public void test(){
        /*加載spring配置文件*/
        ApplicationContext ac=new ClassPathXmlApplicationContext("spring-consumer.xml");
        /*經過配置文件反射獲取暴露的服務接口的業務層對象*/
        ITPService_xml itpService_xml = ac.getBean("iTPService", ITPService_xml.class);
        /*獲取服務返回值*/
        List<TestData> list=itpService_xml.selectTestData();
        /*輸出*/
        System.out.println(list);
    }
}

【運行結果·圖】

　　(二)註解式

　　　　1. 項目代碼：

　　　　　　(1)服務提供方：

　　　　　　　　①數據類pojo/entity：同上

　　　　　　　　②業務層service：同上

　　　　　　(2)服務消費方：

　　　　　　　　①數據類pojo/entity：同上

　　　　　　　　②業務層service：

　　　　　　　　　　i. 將服務提供方暴露的服務接口的代碼複製過來

　　　　　　　　　 ii. 建立調用服務接口的消費方接口，及其實現類

package com.bjsxt.dubbo.service;

import com.bjsxt.dubbo.pojo.TestData;
import java.util.List;

public interface ITServiceConsumer_SSM {
    //顯示測試數據
    List<TestData> show();
}

package com.bjsxt.dubbo.service.impl;

import com.alibaba.dubbo.config.annotation.Reference;
import com.bjsxt.dubbo.pojo.TestData;
import com.bjsxt.dubbo.service.ITService_SSM;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class ITServiceConsumerImpl_SSM implements com.bjsxt.dubbo.service.ITServiceConsumer_SSM {
    @Reference
    private ITService_SSM itService_ssm;
    @Override
    public List<TestData> show() {
        return itService_ssm.selecte();
    }
}