码迷，mamicode.com
首页 > 其他好文 > 详细

dubbo-zookeeper

时间：2017-07-19 16:45:20      阅读：237      评论：0      收藏：0      [点我收藏+]

标签：time   repo   scope   hot   name   logging   spin   text   exp   

 说到分布式，大家可能很快就能想到阿里巴巴的dubbo,zoookeeper集群，目前spring-cloud也是比较热门的，spring-cloud是基于spinrg-boot之上进行协作的，

 接下来就先说一下使用dubbo远程接口调用和zookeeper集群

 1、首先创建一个maven工程，命名为：dubbo-interface，该工程主要是进行接口的声明

 在其工程下创建一个包名为：com.dubbo.test.inter.service，包下创建一个接口类名为：TestService，其内容为如下：

public interface TestService {
    public String getName(String name);
}
TestService接口类中的接口也就是我们需要暴露的远程接口，第一个工程创建完成。
 
2、创建一个maven工程，命名为dubbo-provider,该工程主要是实现dubbo-interface工程中的接口。并且将接口暴露。
 创建好工程后，在pom.xml文件中引入需要的jar包，如下：
<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.test</groupId>
      <artifactId>dubbo_provider</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <packaging>war</packaging>
      <dependencies>
          <!-- 此处为provider工程 依赖 dubbo-interface工程 的依赖配置 -->
            <dependency>
                  <groupId>com.dubbo.test.interface</groupId>
                  <artifactId>dubbo_service_interface</artifactId>
                  <version>0.0.1-SNAPSHOT</version>
            </dependency>
            <!-- 配置Spring -->
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-aop</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-aspects</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-beans</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-context</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-context-support</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-core</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-expression</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-instrument</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-instrument-tomcat</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-messaging</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-orm</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-oxm</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-test</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-tx</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-web</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-webmvc</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-webmvc-portlet</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <dependency>
                  <groupId>org.springframework</groupId>
                  <artifactId>spring-websocket</artifactId>
                  <version>4.3.1.RELEASE</version>
            </dependency>
            <!-- end -->
            <!-- dubbo -->
            <dependency>
                  <groupId>org.apache.zookeeper</groupId>
                  <artifactId>zookeeper</artifactId>
                  <version>3.4.8</version>
            </dependency>
            <dependency>
                  <groupId>com.alibaba</groupId>
                  <artifactId>dubbo</artifactId>
                  <version>2.5.3</version>
            </dependency>
            <dependency>
                  <groupId>com.101tec</groupId>
                  <artifactId>zkclient</artifactId>
                  <version>0.4</version>
            </dependency>
            <dependency>
                  <groupId>org.javassist</groupId>
                  <artifactId>javassist</artifactId>
                  <version>3.18.1-GA</version>
            </dependency>
            <dependency>
                  <groupId>org.slf4j</groupId>
                  <artifactId>slf4j-api</artifactId>
                  <version>1.6.1</version>
            </dependency>
            <dependency>
                  <groupId>org.slf4j</groupId>
                  <artifactId>slf4j-log4j12</artifactId>
                  <version>1.6.1</version>
                  <scope>test</scope>
            </dependency>
            <dependency>
                  <groupId>log4j</groupId>
                  <artifactId>log4j</artifactId>
                  <version>1.2.16</version>
            </dependency>
            <dependency>
                  <groupId>commons-io</groupId>
                  <artifactId>commons-io</artifactId>
                  <version>2.5</version>
            </dependency>
            <dependency>
                  <groupId>commons-logging</groupId>
                  <artifactId>commons-logging</artifactId>
                  <version>1.2</version>
            </dependency>
            <!-- end -->
      </dependencies>
      <!-- 项目发布仓库 -->
      <!--<distributionManagement>
            <repository>
                  <id>releases</id> 
                  <name>Nexus Release Repository</name>
                  <url>http://localhost:8081/nexus/content/repositories/releases/</url>
            </repository>
            <snapshotRepository>
                  <id>snapshots</id>
                  <name>Nexus Snapshot Repository</name>
                  <url>http://localhost:8081/nexus/content/repositories/snapshots/</url>
            </snapshotRepository>
      </distributionManagement>-->
      <!--注意：我这里把项目的发布仓库注释了，因为这里涉及到maven中settings.xml文件的配置以及nexus，只需要满足上面依赖的jar包存在就ok--> 
</project>
 
接下来创建一个包，名为com.dubbo.test.provider，然后创建一个TestServiceImpl实现TestService接口，并且实现其接口类的方法。内容如下：
package com.dubbo.test.provider;
import com.dubbo.test.inter.service.TestService;
 
public class TestServiceImpl implements TestService{
    /*
     * @see com.dubbo.test.inter.service.TestService#getName(java.lang.String)
     */
    public String getName(String name) {
        return "hello " + name + ", success!!";
    }
}
 
接着就是比较重要的一步，那就是spring整合dubbo的配置，主要配置接口的暴露，因为jar包都已经依赖进来了。创建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:aop="http://www.springframework.org/schema/aop"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
 
    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="dubbo-service"/>
    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://localhost:2181"/>
    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />
    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="com.dubbo.test.inter.service.TestService"
        ref="testService" />
    <bean id="testService" class="com.dubbo.test.provider.TestServiceImpl"/>   
</beans>
 
到目前，dubbo的远程接口提供者已经实现了，接下来创建一个测试类，命名为：DubboTest，内容如下：
package com.test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
 
public class DubboTest {   
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring-dubbo-provider.xml");
        context.start();
        System.out.println("服务启动成功！！！" + context.getBean("testService"));
    } 
}
dubbo-provider测试方式： ①首先启动zookeeper服务 ②然后在运行DubboTest中的main方法，main方法启动后，TestService类中的接口就被暴露了  否则是肯定不能连上zookeeper的。
 
3、前两步已经把interface和provider创建好了，并且测试通过了，接下来我们来实现它的消费者。
 创建一个maven工程名为： dubbo-consumer,该工程主要是远程调用dubbo-provider工程中暴露的接口来实现我们需要的业务开发。
 首先pom文件的配置，这里我就不多说了，跟dubbo-provider工程中的pom.xml文件内容一模一样。
 
 接下来就是spring整合dubbo，主要配置怎样使用到dubbo-provider工程中暴露的接口。创建一个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:aop="http://www.springframework.org/schema/aop"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
   
    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="dubbo_provider"/>
    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://localhost:2181"/>
    <dubbo:consumer timeout="5000" />
    <dubbo:reference id="testService" interface="com.dubbo.test.inter.service.TestService"/>
</beans>  
 
最后就是测试了，创建一个DubboTest类，实现如下：
package com.test;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.dubbo.test.inter.service.TestService;
 
public class DubboTest {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("spring-dubbo-consumer.xml");
        context.start();
        TestService testService = context.getBean(TestService.class);
        System.out.println(testService.getName("xxx"));
        System.out.println("dubbo success!!!!!");
    }
}
 
到目前三个工程都已近完成了，接下来就是终极测试：
重点：
①启动zookeeper服务
②启动dubbo-provider工程中的main方法，暴露接口
③启动dubbo-consumer工程中的main方法，调用接口实现自己业务。
 
后续将会 继续把集成的知识点 和 其他的知识点补全（在web端查看暴露的服务并且设置）
 

dubbo-zookeeper

标签：time   repo   scope   hot   name   logging   spin   text   exp   

原文地址：http://www.cnblogs.com/liysoftware/p/7206509.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！