Dubbo入门

早就听说了dubbo的好处，但是在项目中一直没有使用的机会，所以一直不知道怎么使用。今天晚上有空，简单的学习一下

就当入个门，以后项目中遇到的话，那么使用起来就比较简单了，至于介绍的话，我就不总结了，其实就是很好的解决了分布式

管理的问题，并且操作起来非常的方便。

下面这张图是从官网上截图的

节点角色说明：

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

调用关系说明：

  • 0. 服务容器负责启动，加载，运行服务提供者。
  • 1. 服务提供者在启动时，向注册中心注册自己提供的服务。
  • 2. 服务消费者在启动时，向注册中心订阅自己所需的服务。
  • 3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
  • 4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
  • 5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

(1) 连通性：

  • 注册中心负责服务地址的注册与查找，相当于目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小
  • 监控中心负责统计各服务调用次数，调用时间等，统计先在内存汇总后每分钟一次发送到监控中心服务器，并以报表展示
  • 服务提供者向注册中心注册其提供的服务，并汇报调用时间到监控中心，此时间不包含网络开销
  • 服务消费者向注册中心获取服务提供者地址列表，并根据负载算法直接调用提供者，同时汇报调用时间到监控中心，此时间包含网络开销
  • 注册中心，服务提供者，服务消费者三者之间均为长连接，监控中心除外
  • 注册中心通过长连接感知服务提供者的存在，服务提供者宕机，注册中心将立即推送事件通知消费者
  • 注册中心和监控中心全部宕机，不影响已运行的提供者和消费者，消费者在本地缓存了提供者列表
  • 注册中心和监控中心都是可选的，服务消费者可以直连服务提供者

(2) 健状性：

  • 监控中心宕掉不影响使用，只是丢失部分采样数据
  • 数据库宕掉后，注册中心仍能通过缓存提供服务列表查询，但不能注册新服务
  • 注册中心对等集群，任意一台宕掉后，将自动切换到另一台
  • 注册中心全部宕掉后，服务提供者和服务消费者仍能通过本地缓存通讯
  • 服务提供者无状态，任意一台宕掉后，不影响使用
  • 服务提供者全部宕掉后，服务消费者应用将无法使用，并无限次重连等待服务提供者恢复

(3) 伸缩性：

  • 注册中心为对等集群，可动态增加机器部署实例，所有客户端将自动发现新的注册中心
  • 服务提供者无状态，可动态增加机器部署实例，注册中心将推送新的服务提供者信息给消费者

(4) 升级性：

  • 当服务集群规模进一步扩大，带动IT治理结构进一步升级，需要实现动态部署，进行流动计算，现有分布式服务架构不会带来阻力：

上面这些基本的概念看完，然后我们开始直接上代码吧。

我们先编写服务端代码：

这是代码结构

下面是代码：

DemoService.javapackage com.hotusm.dubbo.provider;

import java.util.List;

public interface DemoService {

    String sayHello();

    List<?> getAllUser();
}DemoServiceImpl.java

package com.hotusm.dubbo.provider;



import java.util.ArrayList;
import java.util.List;
import java.util.Random;




import com.hotusm.dubbo.model.entity.User;




public class DemoServiceImpl implements DemoService {




public String sayHello() {


return "hello dubbo";
	}




public List<?> getAllUser() {
		List<User> list=new ArrayList<User>();
		Random r=new Random();
		for(int i=0;i<10;i++){
			list.add(new User(""+r.nextInt(100)));
		}


return list;
	}


}


服务提供者的配置文件：


<?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://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <!-- 具体的实现bean -->
    <bean id="demoService" class="com.hotusm.dubbo.provider.DemoServiceImpl" />  

    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="xixi_provider"  />  

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

    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2182" />   

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

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:service interface="com.hotusm.dubbo.provider.DemoService" ref="demoService" /> 

</beans>


然后我们就可以写一个测试类，将服务提供者给发布。


package junit;

import java.io.IOException;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Provider {

    public static void main(String[] args) {
        ClassPathXmlApplicationContext atx=new ClassPathXmlApplicationContext("spring-context.xml");
        atx.start();

        try {
            System.out.println("server start... press any key to quit");
            System.in.read();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }
}


dubbo有一个客户端，我们可以再客户端中看到提供者和消费者的情况，但是这个客户端需要自己安装


我们可以看到这里已经可以查看到服务提供者的信息了，点击进去还可以看到更多详细的信息，这里就不演示了。


接下来我们再做一个消费者的例子，




注意这里的包名，实体名称，接口名称还是需要一样的，这点和webservice是一样的。


最主要还是配置文件


<?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="hehe_consumer" />  

    <!-- 使用zookeeper注册中心暴露服务地址 -->
    <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
    <dubbo:registry address="zookeeper://127.0.0.1:2182" />  

    <!-- 生成远程服务代理，可以像使用本地bean一样使用demoService -->
    <dubbo:reference id="demoService"
        interface="com.hotusm.dubbo.provider.DemoService" />  

</beans>


测试代码：


import java.io.IOException;
import java.util.List;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.hotusm.dubbo.provider.DemoService;

public class Consumer {

    public static void main(String[] args) {
         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
                    new String[] { "spring-context-consumer.xml" });
            context.start();  

            DemoService demo = (DemoService) context.getBean("demoService"); //
            System.out.println(demo.sayHello());
            List<?> list = demo.getAllUser();
            System.out.println(list);
            try {
                System.out.println("connection... press any key to quit ");
                System.in.read();
            } catch (IOException e) {
                e.printStackTrace();
            }

    }
}


我们可以在控制台看到：


hello dubbo
[User [name=37], User [name=95], User [name=68], User [name=59], User [name=14], User [name=51], User [name=44], User [name=62], User [name=71], User [name=94]]
connection... press any key to quit 


这样我们的例子也就写完了，dubbo也算是入门了吧。


下面再讲讲dubbo的管理页面怎么配置。


dubbo管理控制台开源部分主要包含： 提供者  路由规则  动态配置  访问控制  权重调节  负载均衡  负责人，等管理功能。




1、下载dubbo


我是测试安装在windows上的，先删除tomcat/webapps下自带的ROOT文件夹内容（替换tomcat的启动主页），将下载的war包解压到webapps/ROOT（可以先让tomcat自动解压 再把内容拷贝到root中去），如果是linux的话命令如下：


2、配置:


( windows 环境  解压的war包中自带有dubbo.properties 文件，直接修改就可以；  linux上的话将dubbo.properties放在当前用户目录下，)修改zookeeper的地址


    

  1. vim webapps/ROOT/WEB-INF/dubbo.properties
    2. 



3、配置信息如下：


dubbo.registry.address=zookeeper://localhost:2181
dubbo.admin.root.password=root
dubbo.admin.guest.password=guest



这边使用的是zookeeper的注册中心。


启动tomcat：


说明：确定zookeeper启动后再去启动tomcat。


访问：


http://localhost:8080/dubbo-admin-2.5.4-SNAPSHOT    （这是我的tomcat的访问路径）


出现以下界面说明安装配置成功，登录密码为root/root




附war包下载地址：http://pan.baidu.com/s/1jHQiesY  密码：5eoq
				


				
时间： 2024-10-12 22:07:28 

		


		


	

	
	

		


		
Dubbo入门的相关文章


						

		

			

                Dubbo入门---搭建一个最简单的Demo框架
			

		

		

									

				Dubbo背景和简介 Dubbo开始于电商系统,因此在这里先从电商系统的演变讲起. 单一应用框架(ORM) 当网站流量很小时,只需一个应用,将所有功能如下单支付等都部署在一起,以减少部署节点和成本. 缺点:单一的系统架构,使得在开发过程中,占用的资源越来越多,而且随着流量的增加越来越难以维护 垂直应用框架(MVC) 垂直应用架构解决了单一应用架构所面临的扩容问题,流量能够分散到各个子系统当中,且系统的体积可控,一定程度上降低了开发人员之间协同以及维护的成本,提升了开发效率. 缺点:但是在垂直架构			

		

	

				

		

			

                Dubbo入门简介（一）
			

		

		

									

				Dubbo入门简介(一) 一.什么是Dubbo Dubbo是阿里巴巴开源出来的一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案.通过扩展spring schema 和 注解标签,可以和spring无缝集成(http://blog.csdn.net/achilles12345/article/details/41789527) 核心组件: Remoting:提供对多种基于长连接的NIO框架抽象封装,包括多种线程模型,序列化,以及“请求-响应”模式的信息交			

		

	

				

		

			

                Dubbo入门实例
			

		

		

									

				现在用到了分布式框架Dubbo,随笔谢谢Dubbo入门的实例 解释:注册中心,服务注册的地方,通俗的说就是服务所在的位置 我这里的是在192.168.2.168上面 需要用到的jar包 这是客服端和服务端都需要的jar包,我们新建Maven工程. 项目结构图: 服务端: 一个接口(接口中的方法在实现时方法名开始不能以get开头,莫名报错):     public interface UserService { public void daoGet(); } 实现类(这里必须要实现Serieali			

		

	

				

		

			

                基于MAVEN使用IDEA创建dubbo入门项目图文教程
			

		

		

									

				花了很长时间没有找到一个很详细的图文教程来学习dubbo入门框架,故记录下来. 一: 项目工程目录 简单介绍项目目录结构: 二: 创建父工程 具体操作步骤: 1,打开IDEA,按下面步骤来 File->New->Project 2, 3.等IDEA加载完成进行下一步 File -> New-> Moudle 4, 5,选择本地maven仓库 6,改名字 三: 创建dubbo-common 1,New -> File -> Moudle 2, 3, 4, 四: 创建dub			

		

	

				

		

			

                企业级应用，如何实现服务化三（dubbo入门案例）
			

		

		

									

				今天是六一儿童节,从千里之外的广州,回到了贵州老家,真好!好山好水好心情,好了接着写点东西.这是企业级应用,如何实现服务化系列的第三篇.在上一篇:企业级应用,如何实现服务化二(dubbo架构)中,认识了dubbo的整体架构,和dubbo四大特点:连通性.健壮性.伸缩性.升级性.下面先来实现一个入门级的demo,直观感受一下. 1.案例说明 通过一个简单的案例,演示dubbo入门使用.案例中只有服务提供者,服务消费者. 2.案例实现 2.1.创建项目 2.2.配置pom.xml导入依赖 <?xml			

		

	

						

		

			

                dubbo入门示例
			

		

		

									

				本文主要介绍阿里dubbo的基本使用,关于dubbo的相关基础概念请自行参考dubbo官网:http://www.dubbo.io dubbo是一个服务治理的框架,在如今大规模的分布式应用和SOA架构中,服务治理的问题显的尤为的重要. 以我个人使用dubbo的场景来总结,dubbo主要解决如下问题: 1.项目服务化后,项目之间的高性能通讯问题.(项目被拆分成多个服务模块后必然会涉及模块之间的通讯) 2.服务的URL管理,当项目拆分为N个服务并且不断增加时,如何有效的管理的服务URL 3.服务发现			

		

	

				

		

			

                dubbo入门介绍及结合spring搭建（源码放送）
			

		

		

									

				前言 关于dubbo的介绍网上有很多博文有入门级的说明,但在这里,将会提供给大家dubbo的入门介绍,dubbo结合spring项目的简单搭建,以及提供demo源代码的免费下载. dubbo的官方网址是:http://dubbo.io/ dubbo框架使用的demo源码下载地址:http://download.csdn.net/detail/fighterandknight/9514559 dubbo是什么? Dubbo是一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案,以及			

		

	

				

		

			

                Dubbo入门到实战
			

		

		

									

				前沿:在当下流行的分布式架构中Dubbo是非常流行的一门技术,借着这几天有空学习学习,并在后面的项目中进行实战,为后面的分布式项目做铺垫. Dubbox简介 Dubbox 是一个分布式服务框架,其前身是阿里巴巴开源项目Dubbo ,被国内电商及互联网项目中使用,后期阿里巴巴停止了该项目的维护,当当网便在Dubbo基础上进行优化,并继续维护,为了与原有的Dubbo区分,故将其命名为Dubbox. Dubbox 致力于提供高性能和透明化的RPC远程服务调用方案,以及SOA服务治理方案.简单的说,du			

		

	

				

		

			

                dubbo 入门教程 基于zookeeper
			

		

		

									

				从上午发布的安装zookeeper 遇到的第一个错误开始 一直在搞dubbo 中午吃了饭 睡了会觉 .中间错误一个又一个 慢慢的都解决了.小有成就,哈哈.算这个星期天没有白费吧. 学习的过程值得留恋.分享一下吧 只是之前听网友提过dubbo这个东西 一直都没有百度和使用过.前天答应老板 我们框架中留一个口出来 给dubbo .今天天气热 就在宿舍研究吧. 首先是百度 知道是做什么的 后来就开始找教程 但是大家都知道 百度的教程 基本都是一个模板.看了大概有20篇 基本就换换字 代码 都是一样的.