dubbo学习之路

学习Dubbo

刚刚学习了Thrift，趁热打铁继续学习下Dubbo，也是先从认识开始，由于有了昨天对RPC远程调用的基础，理解起来还是比较快速的，看了其他各位大神的教程自己也尝试写了个Demo,虽然不懂原理上的东西，至少会用了。记录下自己学习Dubbo的过程

Dubbo是什么

Dubbo是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。Dubbo包括三个核心部分：远程通讯、集群容错、自动发现(都是文档上总结的，其实原理是什么我也不懂)

Dubbo可以做什么

Dubbo可以实现透明化的远程方法调用，就像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。

服务自动注册与发现，不再需要写死服务提供方地址，注册中心基于接口名查询服务提供者的IP地址，并且能够平滑添加或删除服务提供者。

Dubbo的节点角色

Provider: 暴露服务的服务提供方。
Consumer: 调用远程服务的服务使用方。
Registry: 服务注册与发现的注册中心。
Monitor: 统计服务的调用次调和调用时间的监控中心。
Container: 服务运行容器。

Dubbo的启动过程

看了许多文档，自己也尝试理解了下Dubbo的工作过程

Dubbo主要分为服务提供方和服务使用方，接口对两者透明，其中，接口实现对服务使用方隐藏。服务使用方只需要根据自己的需要从注册机上找到服务提供方注册的服务使用即可

1、服务提供方启动，向注册中心注册IP地址以及端口号

2、服务提供方向注册中心订阅注册服务

3、服务使用方启动，根据接口协议向注册中心订阅服务提供方注册的服务，注册中心会将存货的服务告诉服务使用方，并且，当有注册的服务发生变化时，通知服务使用方

4、服务使用方根据需要，从拿到的可用服务中选择调用的服务，发起调用

第一个demo的创建过程

先贴出我的Demo项目结构

服务提供方(服务器)

服务使用方(客户端)

创建服务提供方

项目为maven项目，pom.xml文件太长，作为附件上传

创建服务提供方的接口

IHelloString.java

package com.demo.service;

public interface IHelloString {
/**
* 实现将传入的字符串逆向输出
* @param str
* @return
*/
public String reverseString(String str);
}

创建接口的实现

HelloStringImpl.java

package com.demo.service.impl;

import com.demo.service.IHelloString;

public class HelloStringImpl implements IHelloString {

public String reverseString(String str) {
StringBuffer sb=new StringBuffer();
for (int i = str.length()-1; i >=0; i--) {
sb.append(str.charAt(i));
}
String res=sb.toString();
return res;
}

}

创建主程序

Main.java

package com.demo.app;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Main {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "applicationProvider.xml" });
context.start();
System.out.println("按任意键退出");
System.in.read();
}
}

配置文件部分

applicationProvider.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="hello-world" />

<!-- 使用zookeeper注册，需要在本地配置zookeeper，目前不会，采用下面的 -->
<!--
<dubbo:registry protocol="zookeeper" address="127.0.0.1:2181" />
<dubbo:protocol name="dubbo" port="20880" />  -->

<!-- 这里使用multicast广播注册中心暴露服务地址 -->
<dubbo:registry address="multicast://224.0.0.1:9090" />

<!-- 和本地服务一样实现远程服务 -->
<bean id="stringService" class="com.demo.service.impl.HelloStringImpl" />

<!-- 在这里声明需要暴露的服务接口 -->
<dubbo:service interface="com.demo.service.IHelloString " ref="stringService" executes="10" />

</beans>

创建服务使用方(客户端)

创建客户端对象

Consumer.java

package com.demo.consumer;

import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.demo.service.IHelloString;
import com.demo.service.IProcessData;

public class Consumer {

public void reverseString(){
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "applicationConsumer.xml" });
context.start();
IHelloString stringService = (IHelloString) context.getBean("stringService");
System.out.println(stringService.reverseString("hello world"));
}
}

创建测试程序

AppTest.java

package com.demo.test;

import com.demo.consumer.Consumer;

public class AppTest {
public static void main(String[] args) {
Consumer consumer = new Consumer();
consumer.reverseString();
}
}

客户端的配置文件

applicationConsumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://code.alibabatech.com/schema/dubbo  http://code.alibabatech.com/schema/dubbo/dubbo.xsd ">

<!-- 服务使用方应用名，用于计算依赖关系，不是匹配条件,不要和提供方一样，以免造成不必要的麻烦  -->
<dubbo:application name="consumer-of-helloworld-app" />

<!-- 不使用zookeeper注册，因为暂时不会 -->
<!-- <dubbo:registry protocol="zookeeper" address="127.0.0.1:2181" /> -->
<!-- 使用multicast广播注册中心暴露服务地址,这里额地址要与提供方一样 -->
<dubbo:registry address="multicast://224.0.0.1:9090" />
<dubbo:consumer timeout="5" />
<!-- 生成远程服务代理，和本地bean一样使用stringService -->
<dubbo:reference id="stringService" interface="cn.zto.service.IHelloString" />
</beans>

首先运行Main.java，然后运行AppTest.java，看到客户端控制台输出结果则表示构建的Demo成功

中途遇到的问题

遇到解析不了XML文件的错误SAXException

解决方案：

1、在maven的本地仓库下找到

maven->com->alibaba->dubbo->2.5.3->dubbo-2.5.3.jar (具体的看自己的本地仓库) 解压它获得dubbo.xsd文件

2、然后打开Eclipse：1. Window->Preferences->XML->XML Catalog->User Specified Entries窗口中,选择Add 按纽

3、location为.xsd文件所在位置，根据自己的实际情况看

4、修改key值和配置文件的http://code.alibabatech.com/schema/dubbo/dubbo.xsd 相同

附上客户端和服务器端的pom.xml文件

服务器端的pom.xml

pom.xml

<?xml version="1.0" ?>
<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.dubbo</groupId>
<artifactId>dubbo-Service</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>dubbo-Service</name>
<url>http:</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.1.1</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
</dependency>
<dependency>
<groupId>org.javassist</groupId>
<artifactId>javassist</artifactId>
<version>3.18.1-GA</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.15</version>
<exclusions>
<exclusion>
<groupId>com.sun.jdmk</groupId>
<artifactId>jmxtools</artifactId>
</exclusion>
<exclusion>
<groupId>com.sun.jmx</groupId>
<artifactId>jmxri</artifactId>
</exclusion>
<exclusion>
<artifactId>jms</artifactId>
<groupId>javax.jms</groupId>
</exclusion>
<exclusion>
<artifactId>mail</artifactId>
<groupId>javax.mail</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
<version>2.5.6.SEC03</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.6</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.6.1</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.5</version>
<type>pom</type>
</dependency>
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.4</version>
</dependency>
</dependencies>
</project>

客户端的pom.xml文件

pom.xml

<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>demo.dubbo.consume</groupId>
<artifactId>dubbo-Consumer</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>dubbo-Consumer</name>
<url>http:</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>commons-logging</groupId>
<artifactId>commons-logging</artifactId>
<version>1.1.1</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
</dependency>
<dependency>
<groupId>org.javassist</groupId>
<artifactId>javassist</artifactId>
<version>3.18.1-GA</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.15</version>
<exclusions>
<exclusion>
<groupId>com.sun.jdmk</groupId>
<artifactId>jmxtools</artifactId>
</exclusion>
<exclusion>
<groupId>com.sun.jmx</groupId>
<artifactId>jmxri</artifactId>
</exclusion>
<exclusion>
<artifactId>jms</artifactId>
<groupId>javax.jms</groupId>
</exclusion>
<exclusion>
<artifactId>mail</artifactId>
<groupId>javax.mail</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
<version>2.5.6.SEC03</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.6</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.6.1</version>
</dependency>
<dependency>
<groupId>com.github.adyliu</groupId>
<artifactId>zkclient</artifactId>
<version>2.0</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.5</version>
<type>pom</type>
</dependency>
<dependency>
<groupId>com.dubbo</groupId>
<artifactId>dubbo-Service</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
</dependencies>
</project>