這裡的生產者，用來對外提供服務，可配置多個同類服務構成服務叢集

provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!-- consumer's application name, used for tracing dependency relationship (not a matching criterion),
    don't set it same as provider -->
    <!-- 配置服務名-->
    <dubbo:application name="demo-provider"/>

    <!-- 配置zookeeper註冊地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    
    <!--讀物協議為dubbo，埠號，IP地址-->
	<dubbo:protocol name="dubbo" port="20880" host="127.0.0.1"/>

    <!--提供服務的具體實現類-->
	<bean id="testService" class="com.bx.dubbodemo.TestServiceImpl" />
	
    <!--對外提供服務的藉口，及介面的實現類-->
	<dubbo:service interface="com.bx.dubbo_api.TestService" ref="testService"></dubbo:service>
   

</beans>
 

 提供服務的啟動類

provider.java

package com.bx.dubbodemo;

import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
 * dubbo叢集服務第一個服務
 * @author Administrator
 *
 */
public class Provider {
    /**
     * To get ipv6 address to work, add
     * System.setProperty("java.net.preferIPv6Addresses", "true");
     * before running your application.
     */
    public static void main(String[] args) throws Exception {
        /*載入容器*/
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:provider.xml");
        /*啟動容器*/
        context.start();
        System.out.println("20880:服務啟動……");
        /*使系統阻塞在這裡，以提供服務*/
        System.in.read(); // press any key to exit
    }
}
 

服務介面的實現類

TestServiceImpl.java

package com.bx.dubbodemo;

import com.bx.dubbo_api.TestService;

public class TestServiceImpl implements TestService{

	public String get(String msg) {
		// TODO Auto-generated method stub
		return "20880號技師服務中";
	}

}

服務介面類：TestService.java

package com.bx.dubbo_api;

public interface TestService {
	String get(String msg);
}
 

下來是消費者的相關配置

consumer.xml：

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

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!-- consumer's application name, used for tracing dependency relationship (not a matching criterion),
    don't set it same as provider -->
     <!--服務名-->
    <dubbo:application name="demo-consumer"/>

    <!-- 要連結的zookeeper地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>

    <!--要呼叫的服務介面 -->
    <dubbo:reference id="testService" check="false" interface="com.bx.dubbo_api.TestService"/>

</beans>

消費類：Consumer.java:

package com.dubbodemo.consumer;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.bx.dubbo_api.TestService;

public class Consumer {
	 public static void main(String[] args) {
	        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:consumer.xml");
	        context.start();
	       TestService demoService = (TestService) context.getBean("testService"); // get remote service proxy
	        String hello = demoService.get("fuwu"); // call remote method
	        System.out.println(hello); // get result
	    }
}