美文网首页
Dubbo入门Demo

Dubbo入门Demo

作者: DrinkwaterGor | 来源:发表于2018-03-10 09:24 被阅读0次

Dubbo是阿里巴巴公司开源的一个高性能优秀的服务框架，使得应用可通过高性能的 RPC 实现服务的输出和输入功能，可以和Spring框架无缝集成。

RPC

首先了解RPC的概念

RPC（Remote Procedure Call）—远程过程调用.
它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。
RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。
在OSI网络通信模型中，RPC跨越了传输层和应用层。
RPC使得开发包括网络分布式多程序在内的应用程序更加容易。

RPC采用客户机/服务器模式。
请求程序就是一个客户机，而服务提供程序就是一个服务器。
首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。
在服务器端，进程保持睡眠状态直到调用信息到达为止。
当一个调用信息到达，服务器获得进程参数，计算结果，发送答复信息，然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。

简而言之 , 提供计算服务m的程序发布在服务机服务器A上 , 而需要请求该服务m的程序发布客户机服务器B上 , 两者属于不同服务器不能共用一个内存空间 , 所以不能直接调用 , 而需要通过网络来表达调用的语义以及传递的数据 .

Dubbo架构

image.png

Provider

暴露服务方称之为“服务提供者”。

Consumer

调用远程服务方称之为“服务消费者”。

Registry

服务注册与发现的中心目录服务称之为“服务注册中心”。

Monitor

统计服务的调用次数和调用时间的日志服务称之为“服务监控中心”。

Dubbo注册中心

注册中心的作用简单而言是提供一个目录 , 收录了服务提供者的服务列表与地址 , 让服务消费者寻址可以找到自己的需要的服务

目前Dubbo支持四种注册中心：

  • Multicast注册中心
  • Zookeeper注册中心
  • Redis注册中心
  • Simple注册中心

本demo使用的注册中心是zookeeper

DEMO

zookeeper注册中心的安装

本案例使用zookeeper作为服务暴露的注册中心 , 项目启动之前 , 需要先安装启动zookeeper . 至于zookeeper安装和启动在zookeeper3.4.5安装一文中已经介绍非常详尽, 这里不再做讲述 .

服务端程序

新建maven项目 , 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>dubbo.demo.provider</groupId>
  <artifactId>dubbo-demo-provider</artifactId>
  <version>0.0.1-SNAPSHOT</version>

  <name>dubbo-demo-provider</name>
  <url>http://maven.apache.org</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <junit.version>3.8.1</junit.version>
    <spring-framework.version>4.2.5.RELEASE</spring-framework.version>
    <com.alibaba.dubbo.version>2.4.10</com.alibaba.dubbo.version>
    <com.101tec.zkclient.version>0.3</com.101tec.zkclient.version>
  </properties>

  <dependencies>
  
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>${junit.version}</version>
      <scope>test</scope>
    </dependency>
    
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>${spring-framework.version}</version>
    </dependency>

    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>${com.alibaba.dubbo.version}</version>
        <exclusions>
            <exclusion>
                <artifactId>spring</artifactId>
                <groupId>org.springframework</groupId>
            </exclusion>
        </exclusions>
    </dependency>

    <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>${com.101tec.zkclient.version}</version>
    </dependency>
  </dependencies>
</project>

定义一个服务的接口：（DemoService.java）

package com.demo.dubbo.provider.service;
/**
 * @Description:服务接口
 */
public interface DemoService {
    
    String sayHello();
    
}

实现该服务接口：（DemoServiceImpl.java）

package com.demo.dubbo.provider.service.impl;

import org.springframework.stereotype.Service;

import com.demo.dubbo.provider.service.DemoService;

/**
 * @Description:服务接口实现
 */
@Service
public class DemoServiceImpl implements DemoService{

    public String sayHello() {
        return "hello";
    }
}

spring的配置：（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"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:util="http://www.springframework.org/schema/util"
    xmlns:aop="http://www.springframework.org/schema/aop"
    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
        http://www.springframework.org/schema/context
        http://www.springframework.org/schema/context/spring-context.xsd
        http://www.springframework.org/schema/util
        http://www.springframework.org/schema/util/spring-util.xsd"
        >
    
    
    <!--定义暴露服务提供方的应用名称,方便辨识-->
    <dubbo:application name="dubboDemoProvider" owner="DrinkwaterGor" organization="dubboDemoProvider"/>
    
    <!--使用 zookeeper 注册中心暴露服务，注意要先开启 zookeeper-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    
    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20880" />
    
    <!--声明暴露什么服务-->
    <dubbo:service interface="com.demo.dubbo.provider.service.DemoService" ref="demoService" protocol="dubbo" />
    
    <!--服务接口的实现类 bean-->
    <bean id="demoService" class="com.demo.dubbo.provider.service.impl.DemoServiceImpl"/>


</beans>

Provider.java 提供服务：（Provider.java）

package com.demo.dubbo.provider;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;


/**
 * Hello world!
 */
public class Provider {
    
    public static void main(String[] args) throws IOException {
        
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:provider.xml");
        System.out.println(context.getDisplayName());
        context.start();
        System.out.println("服务端已经启动...");
        System.in.read();
        
    }
}

客户端程序

新建一个maven项目, 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>dubbo.demo.consumer</groupId>
  <artifactId>dubbo-demo-consumer</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <packaging>war</packaging>

  <name>dubbo-demo-consumer</name>
  <url>http://maven.apache.org</url>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <junit.version>3.8.1</junit.version>
    <spring-framework.version>4.2.5.RELEASE</spring-framework.version>
    <com.alibaba.dubbo.version>2.4.10</com.alibaba.dubbo.version>
    <com.101tec.zkclient.version>0.3</com.101tec.zkclient.version>
  </properties>

  <dependencies>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>${junit.version}</version>
      <scope>test</scope>
    </dependency>
    
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>${spring-framework.version}</version>
    </dependency>

    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>dubbo</artifactId>
        <version>${com.alibaba.dubbo.version}</version>
        <exclusions>
            <exclusion>
                <artifactId>spring</artifactId>
                <groupId>org.springframework</groupId>
            </exclusion>
        </exclusions>
    </dependency>

    <dependency>
        <groupId>com.101tec</groupId>
        <artifactId>zkclient</artifactId>
        <version>${com.101tec.zkclient.version}</version>
    </dependency>
    
    <dependency>
      <groupId>dubbo.demo.provider</groupId>
      <artifactId>dubbo-demo-provider</artifactId>
      <version>0.0.1-SNAPSHOT</version>
    </dependency>
  </dependencies>
  
</project>

对服务端依赖

<dependency>
      <groupId>dubbo.demo.provider</groupId>
      <artifactId>dubbo-demo-provider</artifactId>
      <version>0.0.1-SNAPSHOT</version>
    </dependency>

spring的配置：（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="dubboDemoConsumer" owner="DrinkwaterGor" organization="dubboDemoConsumer"/>
    
    <!--向 zookeeper 订阅 provider 的地址，由 zookeeper 定时推送-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    
    <!--声明需要调用哪种服务-->
    <dubbo:reference id="demoService" interface="com.demo.dubbo.provider.service.DemoService"/>
    
</beans>

Consumer.java消费服务：（Consumer.java）

package com.demo.dubbo.consumer;


import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.demo.dubbo.provider.service.DemoService;


/**
 * Hello world!
 *
 */
public class Consumer {
    
    public static void main(String[] args) {
        
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:consumer.xml");
        System.out.println(context.getDisplayName());
        context.start();
        System.out.println("消费者开启");
        DemoService demoService = context.getBean(DemoService.class);
        System.out.println("消费者开始消费");
        System.out.println(demoService.sayHello());
    }
    
}

测试

  1. 先maven install 服务端maven项目
  2. 再maven install 消费者maven项目
  3. 然后启动zookeeper, 注意项目中spring配置的zookeeper地址端口要对应上真实zookeeper的地址与端口
  4. 运行Provider.java , 向zookeeper暴露服务
  5. 运行Consumer.java , 向zookeeper获取服务地址
  6. 查看运行结果

服务者

org.springframework.context.support.ClassPathXmlApplicationContext@bbc1fe5
服务端已经启动...

消费者

org.springframework.context.support.ClassPathXmlApplicationContext@656a6512
消费者开启
消费者开始消费
hello

本案例代码示例:
https://gitee.com/bogor/dubbo_introduction_demo

参考:
http://blog.csdn.net/noaman_wgs/article/details/70214612

相关文章

网友评论

      本文标题：Dubbo入门Demo

      本文链接：https://www.haomeiwen.com/subject/ouomfftx.html

      延伸阅读

      深度阅读

      • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

      栏目导航

      热点阅读

      关于我们|服务条款|联系我们|Dubbo入门Demo|投稿指南|网站地图|RSS订阅|排版工具|手机版

      提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

      Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

      备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

      本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

      所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！