分布式Dubbo快速入门

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

背景
随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，亟需一个治理系统确保架构有条不紊的演进。

单一应用架构
当网站流量很小时，只需一个应用，将所有功能都部署在一起，以减少部署节点和成本。此时，用于简化增删改查工作量的数据访问框架(ORM)是关键。

垂直应用架构
当访问量逐渐增大，单一应用增加机器带来的加速度越来越小，将应用拆成互不相干的几个应用，以提升效率。此时，用于加速前端页面开发的Web框架(MVC)是关键。

分布式服务架构
当垂直应用越来越多，应用之间交互不可避免，将核心业务抽取出来，作为独立的服务，逐渐形成稳定的服务中心，使前端应用能更快速的响应多变的市场需求。此时，用于提高业务复用及整合的分布式服务框架(RPC)是关键。

流动计算架构
当服务越来越多，容量的评估，小服务资源的浪费等问题逐渐显现，此时需增加一个调度中心基于访问压力实时管理集群容量，提高集群利用率。此时，用于提高机器利用率的资源调度和治理中心(SOA)是关键。

zookeeper安装
官方网站

http://zookeeper.apache.org/

下载地址

http://mirrors.hust.edu.cn/apache/zookeeper/

下载好我们解压出来直接启动bin目录下zkServer.bat是不行的，我们暂时将zoo_sample.cfg改成zoo.cfg然后就可以正常启动了，启动后我们可以看到默认的端口2181到时候我们的Dubbo就调用这个端口

发布Dubbo服务
Dubbo下载地址

https://github.com/apache/incubator-dubbo

下载后我们参照里面的Demo先来搞一个provider。（dubbo-provider）

1.打开eclipse新建一个maven工程（先配置个阿里云镜像，否则本地没有超级慢）

nexus-aliyun
*
Nexus aliyun
http://maven.aliyun.com/nexus/content/groups/public

2.POM.XML中添加依赖

com.alibaba
dubbo
2.6.0

com.101tec
zkclient
0.10

org.apache.curator
curator-framework
4.0.1

com.alibaba
fastjson
1.2.46

log4j
log4j
1.2.17

org.slf4j
slf4j-api
1.7.25

org.apache.commons
commons-lang3
3.4

io.netty
netty-all
4.0.35.Final

3.添加服务接口，实现服务
package com.miya.dubbo.service;
/**
* 服务提供者接口
* @author SimpleWu
*
*/
public interface MyProviderService {
public String sayHello(String name);
}
实现接口
package com.miya.dubbo.service.impl;
import com.miya.dubbo.service.MyProviderService;
/**
* 服务提供者接口实现类
* @author SimpleWu
*
*/
public class MyProviderServiceImpl implements MyProviderService {
@Override
public String sayHello(String name) {
return "服务1 ： MyProviderServiceImpl 。。 sayHello ";
}
}
4.在resources资源文件夹中添加dubbo-provider.xml

5.创建测试类发布服务
发布服务之前需要先启动zookeeper，启动后图示：
创建测试类发布服务
public static void main(String[] args){
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "dubbo-provider.xml" });
context.start();
System.out.println("服务提供者向zookeeper中心注册服务成功 暴露的端口为：20880");
try {
System.in.read();
} catch (IOException e) {
e.printStackTrace();
}
}
发布后图示：
如果看到我们的服务接口后就说明服务发布成功！
Dubbo Admin管理
1.首先在Dubbo目录里面找到dubbo-admin将他打成WAR包不能带项目路径
我们需要将WAR包发布到Tomcat里面最好独立运行，我们将Tomcat wepapps下的ROOT全部删掉将WAR包解压到里面，然后启动Tomcat（必须先开启我们的zookeeper），我们直接访问localhost:8080会弹出：
默认的账号root密码root登陆
我们可以看到这个页面
我们可以在这里管理我们的服务
目前我们点击服务是没有查询到服务的，我们将我们之前的那个服务运行发布上去可以看到
我们可以点击服务名进去管理我们的服务
在这里可以对应的去操作我们的服务，注意我们的服务就是在20880端口暴露的，这里我们的服务也是20880说明我们的服务成功发布。
消费Dubbo服务
创建一个maven项目(dubbo-consumer)开启消费者：
1.POM.XML导入依赖

com.alibaba
dubbo
2.6.0

com.101tec
zkclient
0.10

org.apache.curator
curator-framework
4.0.1

com.alibaba
fastjson
1.2.46

log4j
log4j
1.2.17

org.slf4j
slf4j-api
1.7.25

org.apache.commons
commons-lang3
3.4

io.netty
netty-all
4.0.35.Final

2.创建消费者接口
package com.miya.dubbo.service;
/**
* 服务提供者接口
* @author SimpleWu
*
*/
public interface MyProviderService {
public String sayHello(String name);
}
3.在resources下创建消费者配置文件(dubbo-consumer.xml)

4.创建消费者测试类
package com.miya.dubbo.test;
import java.io.IOException;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.miya.dubbo.service.MyProviderService;
public class ConsumerTest {
public static void main(String[] args) {
//读取消费者配置文件
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"dubbo-consumer.xml"});
context.start();
//获取消费实例
MyProviderService demoProviderService=(MyProviderService) context.getBean("myProviderService");
String result=demoProviderService.sayHello("Miya");
System.out.println("远程调用的结果："+result);
try {
System.in.read();
} catch (IOException e) {
e.printStackTrace();
}
context.close();
}
}
5.开始消费
打开zookeeper-->Tomcat发布Dubbo Admin管理中心-->启动消费者测试程序
我们可以看到消费者已经有了，图示：
抽取与依赖版本管理
抽取
在前面两个项目中我们会发现两个项目中有两个相同的接口（MyProviderServiceImpl.java），这样是不好的，我们现在参照官方demo来创建一个maven工程（dubbo-api）
我们将接口我们将这个接口放到api这个项目中去，然后将dubbo-consumer,dubbo-provider这两个工程中的接口删掉，这个时候我们这两个项目会报错因为找不到这个接口，我们可以将这两个项目添加依赖：

com.miya
dubbo-api

我们只要依赖dubbo-api就可以获取到了吗？
依赖版本统一管理
我们在dubbo-consumer,dubbo-provider这两个工程中会发现POM.xml中的版本号，如果我们需要修改版本要一个一个去修改有两个工程不是要改两次？那夸张以点，一万不是得改半条命？
这个时候我们还是创建一个maven工程（dubbo-parent），这个工程Packaging我们选择POM，这个项目负责版本统一。首先我们抽取相同的依赖，然后给他们定义统一的版本管理方式。

4.0.0
com.miya
dubbo-parent
0.0.1-SNAPSHOT
pom

0.0.1-SNAPSHOT
2.6.0
0.10
4.0.1
1.2.46
1.2.17
1.7.25
3.4
4.0.35.Final

com.miya
dubbo-api
${dubbo-api.version}

com.alibaba
dubbo
${dubbo.version}

com.101tec
zkclient
${zkclient.version}

org.apache.curator
curator-framework
${curator-framework.version}

com.alibaba
fastjson
${fastjson.version}

log4j
log4j
${log4j.version}

org.slf4j
slf4j-api
${slf4j-api.version}

org.apache.commons
commons-lang3
${commons-lang3.version}

io.netty
netty-all
${netty-all.version}

原文地址：http://blog.51cto.com/13954634/2298846

时间： 2024-07-29 20:43:12

分布式Dubbo快速入门的相关文章

Celery 分布式任务队列快速入门

本节内容 Celery介绍和基本使用 启用多个workers Celery 定时任务 与django结合 通过django配置celery periodic task 一.Celery介绍和基本使用 Celery 是一个 基于python开发的分布式异步消息任务队列,通过它可以轻松的实现任务的异步处理, 如果你的业务场景中需要用到异步任务,就可以考虑使用celery, 举几个实例场景中可用的例子: 你想对100台机器执行一条批量命令,可能会花很长时间 ,但你不想让你的程序等着结果返回,而是给你返

Celery分布式任务队列快速入门

Celery介绍 Celery是基于Python开发的分布式任务队列.它支持使用任务队列的方式在分布的机器/进程/线程上执行任务调度. 如果业务场景中需要用到异步任务,就可以考虑使用celery, 举几个实例场景中可用的例子: 你想对100台机器执行一条批量命令,可能会花很长时间 ,但你不想让你的程序等着结果返回,而是给你返回 一个任务ID,你过一段时间只需要拿着这个任务id就可以拿到任务执行结果, 在任务执行ing进行时,你可以继续做其它的事情. 你想做一个定时任务,比如每天检测一下你们所有客

分布式任务调度快速入门

分布式调度 任务调度的实现:触发器+线程池=任务调度 实现的思想: 1.调度线程:有个后台守护线程不停的轮训--触发器 2.若触发器到达临界值,则根据触发器对应出它的job,去线程池里取一个线程来执行job 3.如果线程池全忙,则阻塞等待线程 解决方案: 1.在分布式环境里,只部署一台job 2.使用分布式调度架构: Elastic-Job(当当网) ,官网:http://elasticjob.io/docs/elastic-job-lite/00-overview/ xxl-job,官网:ht

微服务的入门级微框架Spring Boot快速入门

详情请交流  QQ  709639943 00.微服务的入门级微框架Spring Boot快速入门 00.基于java的微信公众号二次开发视频教程 00.leetcode 算法 面试 00.北风网 零基础到数据(大数据)分析专家-首席分析师 00.快速上手JMeter 00.Jmeter 00.2017年Java web开发工程师成长之路 00.R语言速成实战 00.R语言数据分析实战 00.Python+Django+Ansible Playbook自动化运维项目实战 00.Java深入微服务

阿里分布式事务seata入门（采坑）

1. 阿里分布式事务seata入门(采坑) 1.1. 前言 seata是feascar改名而来,这是阿里在19年年初开源出来的分布式事务框架,当初刚出来的时候就想研究下了,一直拖到了现在,目前是0.8.0版本,看版本就知道这还是个比较新的项目,但现在已经有上万个Star了,可见阿里的影响力.但是虽然有阿里背书,该挖坑还得挖,它宣称集成它比较简单,导致的是现在它的文档优点残缺不全,好几个文档标题点进去都没内容,不知道为什么删了,可能是更新比较快,文档跟不上节奏索性删了[手动滑稽] 1.2. 快速开

Spring快速入门

时间:2017-1-29 02:15 Spring的IOCSpring的AOP,AspectJSpring的事务管理,三大框架的整合 --什么是Spring 1.Spring是分层的JavaSE/EE full-stack(一站式)轻量级开源框架.    1)分层:        *   SUN公司提供的EE的三层结构:Web层.业务层.数据访问层(持久层)        *   Struts2是Web层基于MVC设计模式框架.        *   Hibernate是持久层的一个ORM框架.

架构设计：系统间通信（36）——Apache Camel快速入门（上）

1.本专题主旨 1-1.关于技术组件 在这个专题中,我们介绍了相当数量技术组件:Flume.Kafka.ActiveMQ.Rabbitmq.Zookeeper.Thrift .Netty.DUBBO等等,还包括本文要进行介绍的Apache Camel.有的技术组件讲得比较深入,有的技术组件则是点到为止.于是一些读者朋友发来信息向我提到,这个专题的文章感觉就像一个技术名词的大杂烩,并不清楚作者的想要通过这个专题表达什么思想. 提出这个质疑的朋友不在少数,所以我觉得有必要进行一个统一的说明.这个专题

EJB3.0快速入门

1.首先介绍运行环境及相关的配置: EJB的运行环境: JAVAEE应用服务器包含Web容器和EJB容器,EJB3.0应用需要运行在EJB容器里. Tomcat目前只是Web容器,它不能运行EJB应用. Jboss作为最常用EJB容器,其自身所带Web服务器部分就是直接使用Tomcat(Jboss的默认端口也为:8080). 相关配置: 1.配置classpath:%JDK安装目录%/lib/dt.jar和tools.jar 2.JDK版本需要1.5以上. 3.为Jboss设置Jboss_HOM

Memcached快速入门

Memcached快速入门 What is Memcached Memcached 是一个高性能的分布式内存对象缓存系统,用于动态Web应用以减轻数据库负载.它通过在内存中缓存数据和对象来减少读取数据库的次数,从而提高动态.数据库驱动网站的速度. 安装 Ubuntu $ sudo apt-get install memcached $ ps aux | grep memcached memcache 26355 0.0 0.0 325400 1208 ? Sl 16:30 0:00 /usr/b