阿里dubbo框架使用系列：服务提供者和消费者的创建和使用

新建一个maven工程



创建一个服务接口

package com.pcx.dubbo_facade;

public interface DemoService {
String sayHello(String name);
}

运行 clean install打包dubbo-facade



接下来创建 dubbo-provider 工程



在pom.xml里面引用刚才的服务接口的jar包

<span style="white-space:pre">		</span><dependency>
<groupId>com.pcx</groupId>
<span style="white-space:pre">	</span><artifactId>dubbo-facade</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>

编写服务实现类

package com.pcx.dubbo_prodiver;

import org.springframework.stereotype.Service;

import com.pcx.dubbo_facade.DemoService;

@Service("demoService")
public class DemoServiceImpl implements DemoService {

public String sayHello(String name) {
return "Hello " + name;
}

}

在resource目录下编写两个spring配置文件

dubbo-provider.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://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> 
<!-- 定义应用名称 -->
<dubbo:application name="dubbo-demo-provider" />

<!--zk注册中心的地址-->
<dubbo:registry protocol="zookeeper" address="192.168.1.10:2181" />

<!-- 用dubbo协议在21000端口暴露服务 -->
<dubbo:protocol name="dubbo" port="21000" />

<!-- 配置服务接口 -->
<dubbo:service interface="com.pcx.dubbo_facade.DemoService" ref="demoService" />

</beans>

spring-context.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:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd" default-autowire="byName" default-lazy-init="false">

<!-- 采用注释的方式配置bean -->
<context:annotation-config />

<!-- 配置要扫描的包的路径 -->
<context:component-scan base-package="com.pcx" />

<import resource="dubbo-provider.xml" />
</beans>

在src/test/java路径下编写测试类启动dubbo服务

package com.pcx.dubbo_prodiver;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class DubboProvider {
private static final Log log = LogFactory.getLog(DubboProvider.class);

public static void main(String[] args) {
try {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring-context.xml");
context.start();
} catch (Exception e) {
log.error("== DubboProvider context start error:",e);
}
synchronized (DubboProvider.class) {
while (true) {
try {
DubboProvider.class.wait();
} catch (InterruptedException e) {
log.error("== synchronized error:",e);
}
}
}
}
}

运行这个测试类，我们可以在dubbo控制台看到我们暴露的服务



创建一个新工程名为dobbo-consumer



在pom.xml下依赖我们的服务接口的jar包

<span style="white-space:pre"> </span><dependency>
<groupId>com.pcx</groupId>
<artifactId>dubbo-facade</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>

在src/main/resource/目录下新增两个spring配置文件

dubbo-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://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"> 
<!-- 消费方应用名 -->
<dubbo:application name="dubbo-demo-consumer" />

<!-- 填写zk注册中心的地址 -->
<dubbo:registry protocol="zookeeper" address="192.168.1.10:2181" />

<!-- 引用服务提供接口的路径 -->
<dubbo:reference interface="com.pcx.dubbo_facade.DemoService" id="demoService" check="false" />

</beans>

spring-context.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:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd" >

<import resource="dubbo-consumer.xml" />

</beans>

编写调用服务的测试类在src/test/java

package com.pcx.dubbo_consumer;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.pcx.dubbo_facade.DemoService;

public class Consumer {
private static final Log log = LogFactory.getLog(Consumer.class);

public static void main(String[] args) throws InterruptedException {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring-context.xml");
context.start();
DemoService demoService = (DemoService)context.getBean("demoService");
String hello = demoService.sayHello("world");
log.info("打印"+hello);

Thread.sleep(100000);

}

}

运行测试类



调用成功

此时可以在dubbo控制台看到相关信息