v一、前言
项目中用到了Dubbo，临时抱大腿，学习了dubbo的简单实用方法。现在就来总结一下dubbo如何提供服务，如何消费服务，并做了一个简单的demo作为参考。
v二、Dubbo是什么
Dubbo是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。简单的说，dubbo就是个服务框架，如果没有分布式的需求，其实是不需要用的，只有在分布式的时候，才有dubbo这样的分布式服务框架的需求，并且本质上是个服务调用的东东，说白了就是个远程服务调用的分布式框架（告别Web Service模式中的WSdl，以服务者与消费者的方式在dubbo上注册）
其核心部分包含:
1. 远程通讯: 提供对多种基于长连接的NIO框架抽象封装，包括多种线程模型，序列化，以及“请求-响应”模式的信息交换方式。
2. 集群容错: 提供基于接口方法的透明远程过程调用，包括多协议支持，以及软负载均衡，失败容错，地址路由，动态配置等集群支持。
3. 自动发现: 基于注册中心目录服务，使服务消费方能动态的查找服务提供方，使地址透明，使服务提供方可以平滑增加或减少机器。
摘自：http://www.cnblogs.com/Javame/p/3632473.html
v三、dubbo配置
v 1.dubbo需要依赖的jar
<?xml version="1.0" encoding="UTF-8"?> <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> <groupId>com.hjz</groupId> <artifactId>dubbo</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>pom</packaging> <modules> <module>hjz-dubbo-api</module> <module>hjz-dubbo-consumer</module> <module>hjz-dubbo-provider</module> </modules> <dependencies> <dependency> <groupId>com.alibaba</groupId> <artifactId>dubbo</artifactId> <version>2.8.4</version> </dependency> <dependency> <groupId>javassist</groupId> <artifactId>javassist</artifactId> <version>3.12.1.GA</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.6</version> </dependency> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> </dependencies> </project>
v 2.dubbo服务接口
package com.hjz.dubbo.api; public interface DubboServiceTest { public int calculate(int a, int b); }
v 3.dubbo服务生产者配置
实现dubbo服务的接口
package com.hjz.service; import org.springframework.stereotype.Service; import com.hjz.dubbo.api.DubboServiceTest; @Service("dubboServiceTest") public class DubboServiceProvider implements DubboServiceTest { @Override public int calculate(int a, int b) { return a+b; } }
dubbo服务提供者配置：classpath:dubbo-provider-example.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:context="http://www.springframework.org/schema/context" 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://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <description>dubbo公共配置</description> <!-- 扫描需要注入到spring容器中的bean --> <context:component-scan base-package="com.hjz.service" /> <!-- 引入dubbo需要的配置文件 --> <context:property-placeholder location="classpath:dubbo-example.properties" /> <!-- 同一个工程只配置一份即可 --> <dubbo:application name="hjz-dubbo" owner="hjzgg"/> <!-- 发布dubbo需要对外的协议（dubbo）和端口（20880），20880是dubbo默认提供的端口， 若一台机器发布多个dubbo服务，则此端口需要显示配置，多个dubbo服务端口需要不一样，否则会端口冲突 --> <dubbo:protocol name="dubbo" port="${dubbo.protocol.port}" serialization="java"/> <!-- 配置dubbo服务失败后的重试次数和接口超时时间 --> <dubbo:provider retries="0" timeout="${dubbo.provider.timeout}"/> <!-- dubbo注册到zookeeper，用于预发布或生产环境 --> <!-- <dubbo:registry protocol="zookeeper" address="${zookeeper.addr}" /> --> <!-- dubbo不注册到任何registry，用于开发或测试环境--> <dubbo:registry protocol="zookeeper" address="N/A" /> <dubbo:service ref="dubboServiceTest" interface="com.hjz.dubbo.api.DubboServiceTest"/> </beans>
由于是提供者作为一个web项目，所以web.xml文件如下。
<?xml version="1.0" encoding="UTF-8"?> <web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_2_5.xsd" version="2.5" xmlns="http://xmlns.jcp.org/xml/ns/javaee"> <display-name>hjz-dubbo-provider</display-name> <context-param> <param-name>contextConfigLocation</param-name> <param-value> classpath:dubbo-provider-example.xml </param-value> </context-param> <context-param> <param-name>log4jConfigLocation</param-name> <param-value>classpath:log4j.properties</param-value> </context-param> <listener> <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class> </listener> <welcome-file-list> </welcome-file-list> </web-app>
v 4.dubbo服务消费者配置
dubbo服务消费者测试类
package com.hjz.dubbo.consumer; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import com.alibaba.dubbo.common.logger.Logger; import com.alibaba.dubbo.common.logger.LoggerFactory; import com.hjz.dubbo.api.DubboServiceTest; @RunWith(SpringJUnit4ClassRunner.class) @ContextConfiguration(locations={"classpath:dubbo-consumer-example.xml"}) public class DubboServiceConsumer { private static final Logger logger = LoggerFactory.getLogger(DubboServiceConsumer.class); @Autowired private DubboServiceTest dubboServiceTest; @Test public void consumer(){ int a = 4, b = 5; logger.info("消费dubbo服务...................."); logger.info(String.format("a = %d, b = %d, a+b = %d", a, b, dubboServiceTest.calculate(a, b))); } }
dubbo服务消费者配置：dubbo-consumer-example.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:context="http://www.springframework.org/schema/context" 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://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"> <description>dubbo公共配置</description> <context:property-placeholder location="classpath:dubbo-example.properties" /> <!-- 同一个工程只配置一份即可 --> <dubbo:application name="hjz-dubbo" owner="hjzgg"/> <!-- 服务应用方调用的超时时间。默认不配置，则以服务提供方的超时时间为准。check为false表示延迟加载dubbo依赖的服务--> <dubbo:consumer retries="0" timeout="${dubbo.consumer.timeout}" check="false"/> <!-- dubbo注册到zookeeper，用于预发布或生产环境 --> <!-- <dubbo:registry protocol="zookeeper" address="${zookeeper.addr}" /> --> <!-- 像引用spring的bean服务一样引用dubbo提供的接口，用于预发布和生产环境--> <!-- <dubbo:reference id="dubboServiceTest" interface="com.hjz.dubbo.api.DubboServiceTest" /> --> <!-- dubbo直连方式，只用于开发或测试阶段 --> <dubbo:reference id="dubboServiceTest" interface="com.hjz.dubbo.api.DubboServiceTest" url="dubbo://127.0.0.1:20880" /> </beans>
v四、dubbo测试
首先启动dubbo生产者，然后运行消费者的测试类，可以看到控制台中有如下信息输出：
2016-09-25 19:36:08,502 INFO [com.hjz.dubbo.consumer.DubboServiceConsumer] - [DUBBO] 消费dubbo服务...................., dubbo version: 2.8.4, current host: 192.168.80.4
2016-09-25 19:36:08,761 INFO [com.hjz.dubbo.consumer.DubboServiceConsumer] - [DUBBO] a = 4, b = 5, a+b = 9, dubbo version: 2.8.4, current host: 192.168.80.4
v五、总结
1.如果一个工程中有dubbo消费者，也有dubbo生产者，则<dubbo:application name="hjz-dubbo" owner="hjzgg"/>配置只有一个就可以了。
2.测试环境一般采用dubbo直联方式，生产环境一般将dubbo服务注册到zookeeper。
3.配置文件中 dubbo:reference id="dubboServiceTest" 和 dubbo:service ref="dubboServiceTest"， id和ref的对应的value要一致。
4.配置文件中 dubbo:service ref="dubboServiceTest"，ref对应的value是服务的名称，例如@Service("dubboServiceTest")。
5.如果抛出下面异常，
com.caucho.hessian.client.HessianRuntimeException: com.caucho.hessian.io.HessianFieldException: com.shine.ermp.dto.UserAccountDTO.invalidDate:
java.sql.Timestamp cannot be assigned from null
dubbo服务提供者的配置文件中加上下面红色的代码。
<dubbo:protocol name="dubbo" port="20880" serialization="java"/>
v六、测试demo
https://github.com/hjzgg/dubbo_demo
注：测试demo工程是个maven工程，eclipse可以通过 Check out as Maven Project from SCM 来导入即可，URL:https://github.com/hjzgg/dubbo_demo.git
本文转自 小眼儿 博客园博客，原文链接：http://www.cnblogs.com/hujunzheng/p/5907035.html，如需转载请自行联系原作者
