Dubbo的最小Demo

dubbo-example/.gitignore

@@ -0,0 +1 @@
/.settings/

dubbo-example/.project

@@ -0,0 +1,17 @@
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
	<name>dubbo-example</name>
	<comment></comment>
	<projects>
	</projects>
	<buildSpec>
		<buildCommand>
			<name>org.eclipse.m2e.core.maven2Builder</name>
			<arguments>
			</arguments>
		</buildCommand>
	</buildSpec>
	<natures>
		<nature>org.eclipse.m2e.core.maven2Nature</nature>
	</natures>
</projectDescription>

dubbo-example/dubbo-service-provider/.gitignore

@@ -0,0 +1,3 @@
/.settings/
/target/
/.classpath

dubbo-example/dubbo-service-provider/.project

@@ -0,0 +1,23 @@
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
	<name>dubbo-service-provider</name>
	<comment></comment>
	<projects>
	</projects>
	<buildSpec>
		<buildCommand>
			<name>org.eclipse.jdt.core.javabuilder</name>
			<arguments>
			</arguments>
		</buildCommand>
		<buildCommand>
			<name>org.eclipse.m2e.core.maven2Builder</name>
			<arguments>
			</arguments>
		</buildCommand>
	</buildSpec>
	<natures>
		<nature>org.eclipse.jdt.core.javanature</nature>
		<nature>org.eclipse.m2e.core.maven2Nature</nature>
	</natures>
</projectDescription>

dubbo-example/dubbo-service-provider/pom.xml

@@ -0,0 +1,29 @@
<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>com.ai.ipu.example</groupId>
		<artifactId>dubbo-example</artifactId>
		<version>1.0-SNAPSHOT</version>
	</parent>
	<artifactId>dubbo-service-provider</artifactId>
	<name>dubbo-service-provider</name>
	<description>dubbo服务提供者</description>
	
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
	</properties>
	<dependencies>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>com.ai.ipu.server</groupId>
			<artifactId>ipu-service</artifactId>
		</dependency>
	</dependencies>
</project>

dubbo-example/dubbo-service-provider/src/main/java/com/ai/ipu/dubbo/provider/DubboServiceProviderStart.java

@@ -0,0 +1,17 @@
package com.ai.ipu.dubbo.provider;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class DubboServiceProviderStart {
    public final static String MODE = "simple";
    public final static String DUBBO_PROVIDER_CONFIG = "dubbo-provider-" + MODE + ".xml";
    public final static String DUBBO_CONSUMER_CONFIG = "dubbo-consumer-" + MODE + ".xml";
    
    @SuppressWarnings("resource")
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] {DUBBO_PROVIDER_CONFIG});
        context.start();
        System.in.read(); // press any key to exit
    }
}

dubbo-example/dubbo-service-provider/src/main/java/com/ai/ipu/dubbo/provider/HelloService.java

@@ -0,0 +1,6 @@
package com.ai.ipu.dubbo.provider;
public interface HelloService {
    
    public String hello(String name);
}

dubbo-example/dubbo-service-provider/src/main/java/com/ai/ipu/dubbo/provider/impl/HelloServiceImpl.java

@@ -0,0 +1,10 @@
package com.ai.ipu.dubbo.provider.impl;
import com.ai.ipu.dubbo.provider.HelloService;
public class HelloServiceImpl implements HelloService{
    public String hello(String name) {
        return "hello" + name;
    }
}

dubbo-example/dubbo-service-provider/src/main/resources/dubbo-provider-simple.xml

@@ -0,0 +1,32 @@
<?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://code.alibabatech.com/schema/dubbo 
	http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!-- 全局配置 start=========================== -->
    <dubbo:application name="ipu-service-demo" logger="log4j"> <!-- 日志适配 -->
    	<dubbo:parameter key="dump.directory" value="/tmp" /> <!-- 线程栈自动dump -->
    </dubbo:application>
    <!-- 过滤器配置，服务延迟暴露 -->
    <dubbo:provider filter="IpuDubboServiceGlobalFilter" delay="-1" /><!-- server="netty4"  -->
    <!-- 服务协议 -->
    <dubbo:protocol name="dubbo" port="20880"/>
    <!-- 广播的方式注册 -->
    <dubbo:registry address="127.0.0.1:20880"/>
    <!-- 提供simple注册中心 -->
    <dubbo:service interface="com.alibaba.dubbo.registry.RegistryService" ref="registryService" registry="N/A" ondisconnect="disconnect" callbacks="1000">
        <dubbo:method name="subscribe"><dubbo:argument index="1" callback="true" /></dubbo:method>
        <dubbo:method name="unsubscribe"><dubbo:argument index="1" callback="false" /></dubbo:method>
    </dubbo:service>
    <!-- 简单注册中心实现，可自行扩展实现集群和状态同步 -->
    <bean id="registryService" class="com.alibaba.dubbo.registry.simple.SimpleRegistryService" />
    <!-- 全局配置 end=========================== -->
    
    <!-- 服务注册配置 start=========================== -->
    <dubbo:service interface="com.ai.ipu.dubbo.provider.HelloService" ref="helloService" token="true"/>
    <bean id="helloService" class="com.ai.ipu.dubbo.provider.impl.HelloServiceImpl"/>
    <!-- 服务注册配置 end =========================== -->
</beans>

dubbo-example/dubbo-service-provider/src/test/java/com/ai/ipu/dubbo/provider/HelloServiceTest.java

@@ -0,0 +1,24 @@
package com.ai.ipu.dubbo.provider;
import junit.framework.TestCase;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class HelloServiceTest extends TestCase {
    private ClassPathXmlApplicationContext context;
    @Override
    protected void setUp() throws Exception {
        // TODO Auto-generated method stub
        context = new ClassPathXmlApplicationContext(new String[] { DubboServiceProviderStart.DUBBO_CONSUMER_CONFIG });
        context.start();
    }
    
    public void testHello() {
        // TODO Auto-generated method stub
        HelloService helloService = (HelloService)context.getBean("helloService"); // 获取远程服务代理
        String result = helloService.hello("测试名称"); // 执行远程方法
        System.out.println(result); // 显示调用结果
    }
}

dubbo-example/dubbo-service-provider/src/test/resources/dubbo-consumer-simple.xml

@@ -0,0 +1,19 @@
<?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://code.alibabatech.com/schema/dubbo 
	http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
	<!-- 全局配置 start=========================== -->
	<dubbo:application name="ipu-service-demo" />
	<!-- 关闭重试，延长超时 -->
	<dubbo:consumer retries="0" timeout="2000"/>	<!-- client="netty4" -->
	<dubbo:registry address="127.0.0.1:20880" />
	<!-- 全局配置 end=========================== -->
	<!-- 服务注册配置 start=========================== -->
	<dubbo:reference id="helloService"
		interface="com.ai.ipu.dubbo.provider.HelloService" />
	<!-- 服务注册配置 end =========================== -->
</beans>

dubbo-example/pom.xml

@@ -0,0 +1,35 @@
<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>com.ai.ipu.server</groupId>
		<artifactId>ipu-service-libs</artifactId>
		<version>3.1-SNAPSHOT</version>
	</parent>
	
	<groupId>com.ai.ipu.example</groupId>
	<artifactId>dubbo-example</artifactId>
	<version>1.0-SNAPSHOT</version>
	<packaging>pom</packaging>
	
	<name>dubbo-example</name>
	<description>dubbo范例</description>
	<modules>
		<module>dubbo-service-provider</module>
	</modules>
	
	<repositories>
		<repository>
			<id>ipu</id>
			<name>ipu repository</name>
			<url>http://114.215.100.48:9090/nexus/content/groups/public/</url>
			<releases>
				<enabled>true</enabled>
			</releases>
			<snapshots>
				<enabled>true</enabled>
				<updatePolicy>always</updatePolicy>
			</snapshots>
		</repository>
	</repositories>
</project>