安裝注冊(cè)中心zookeeper

解壓zookeeper-3.4.13.tar
根目錄新建文件夾data
修改conf目錄下zoo.sample.cfg為zoo.cfg
修改配置項(xiàng)dataDir=../data
啟動(dòng)服務(wù)
zkServe.cmd
連接服務(wù)
zkCli.cmd

安裝啟動(dòng)監(jiān)控中心

https://github.com/apache/dubbo-admin

producer

producer.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:dubbo="http://code.alibabatech.com/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
        http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <!-- 1、指定當(dāng)前服務(wù)/應(yīng)用的名字（同樣的服務(wù)名字相同冷蚂，不要和別的服務(wù)同名） -->
    <dubbo:application name="provider"></dubbo:application>

    <!-- 2粱侣、指定注冊(cè)中心的位置 -->
    <!-- <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry> -->
    <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181"></dubbo:registry>

    <!-- 3、指定通信規(guī)則（通信協(xié)議 通信端口） -->
    <dubbo:protocol name="dubbo" port="10086"></dubbo:protocol>

    <!-- 4卫袒、暴露服務(wù)   ref：指向服務(wù)的真正的實(shí)現(xiàn)對(duì)象 -->
    <dubbo:service interface="org.common.interfaces.UserService"
                   ref="user" timeout="10000" version="1.0.0">
        <dubbo:method name="getUserNum" timeout="10000"></dubbo:method>
    </dubbo:service>

    <!--統(tǒng)一設(shè)置服務(wù)提供方的規(guī)則  -->
    <dubbo:provider timeout="10000"></dubbo:provider>

    <!-- 服務(wù)的實(shí)現(xiàn) -->
    <bean id="user" class="org.producer.User"></bean>

    <!-- 連接監(jiān)控中心 -->


</beans>

注冊(cè)

package org.producer;

import java.io.IOException;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class MainApplication {

    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext ioc = new ClassPathXmlApplicationContext("provider.xml");
        ioc.start();
        System.in.read();
    }

}

consumer

consumer.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:dubbo="http://dubbo.apache.org/schema/dubbo"
       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-4.3.xsd
        http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <context:component-scan base-package="org"></context:component-scan>


    <dubbo:application name="consumer"></dubbo:application>

    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>

    <!--  配置本地存根-->

    <!--聲明需要調(diào)用的遠(yuǎn)程服務(wù)的接口；生成遠(yuǎn)程服務(wù)代理  -->
    <!--
        1）单匣、精確優(yōu)先 (方法級(jí)優(yōu)先夕凝，接口級(jí)次之，全局配置再次之)
        2）户秤、消費(fèi)者設(shè)置優(yōu)先(如果級(jí)別一樣码秉，則消費(fèi)方優(yōu)先，提供方次之)
    -->
    <!-- timeout="0" 默認(rèn)是1000ms-->
    <!-- retries="":重試次數(shù)鸡号，不包含第一次調(diào)用转砖，0代表不重試-->
    <!-- 冪等（設(shè)置重試次數(shù)）【查詢、刪除鲸伴、修改】府蔗、非冪等（不能設(shè)置重試次數(shù)）【新增】 -->
    <dubbo:reference interface="org.common.interfaces.UserService"
                     id="userService" timeout="50000" retries="3" version="*">
        <!-- <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method> -->
    </dubbo:reference>

    <!-- 配置當(dāng)前消費(fèi)者的統(tǒng)一規(guī)則：所有的服務(wù)都不檢查 -->
    <dubbo:consumer check="false" timeout="50000"></dubbo:consumer>


    <!-- <dubbo:monitor address="127.0.0.1:7070"></dubbo:monitor> -->

</beans>

調(diào)用

import java.io.IOException;

import org.common.interfaces.UserService;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class MainApplication {
    @SuppressWarnings("resource")
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
        UserService orderService = applicationContext.getBean(UserService.class);
        System.out.println(orderService.getUserNum());
        System.out.println("調(diào)用成功....");

    }
}

參考
https://blog.csdn.net/u014427391/article/details/96754952