Dubbo学习总结(4)——Dubbo基于Zookeeper实现分布式实例

Wesley13
• 阅读 310

入门实例解析

第一:provider-提供服务和相应的接口


创建DemoService接口

[java]  view plain copy print ?

  1. <span style="font-size:18px;">package com.unj.dubbotest.provider;

  2. import java.util.List;

  3. /**

  4. * 定义服务接口,该接口需要单独打包,在服务提供方和消费方共享

  5. *

  6. * @author lishehe-2015年6月22日

  7. *

  8. */

  9. public interface DemoService {

  10. /*

  11. * sayHello方法

  12. */

  13. String sayHello(String name);

  14. /*

  15. * 获取用户信息方法

  16. */

  17. public List getUsers();

  18. }

创建本接口的实现类

[java]  view plain copy print ?

  1. <span style="font-size:18px;">package com.unj.dubbotest.provider.impl;

  2. import java.util.ArrayList;

  3. import java.util.List;

  4. import com.unj.dubbotest.provider.DemoService;

  5. /*

  6. * 实现类DemoServiceImpl-李社河-2015年6月22日

  7. */

  8. public class DemoServiceImpl implements DemoService {

  9. //声明sayHello方法

  10. public String sayHello(String name) {

  11. return "Hello " + name;

  12. }

  13. /**

  14. * 获取用户信息getUsers-李社河-2015年6月22日

  15. */

  16. public List getUsers() {

  17. List list = new ArrayList();

  18. User u1 = new User();

  19. //jack信息

  20. u1.setName("jack");

  21. u1.setAge(20);

  22. u1.setSex("m");

  23. //tom信息

  24. User u2 = new User();

  25. u2.setName("tom");

  26. u2.setAge(21);

  27. u2.setSex("m");

  28. //rose信息

  29. User u3 = new User();

  30. u3.setName("rose");

  31. u3.setAge(19);

  32. u3.setSex("w");

  33. list.add(u1);

  34. list.add(u2);

  35. list.add(u3);

  36. return list;//返回数据集合

  37. }

  38. }

创建provider.xml文件

[html]  view plain copy print ?

  1. <span style="font-size:18px;">

  2. <beans xmlns="http://www.springframework.org/schema/beans"

  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

  4. xsi:schemaLocation="http://www.springframework.org/schema/beans

  5. http://www.springframework.org/schema/beans/spring-beans.xsd

  6. http://code.alibabatech.com/schema/dubbo

  7. http://code.alibabatech.com/schema/dubbo/dubbo.xsd

  8. ">

  9. <bean id="demoService" class="com.unj.dubbotest.provider.impl.DemoServiceImpl" />

  10. <dubbo:application name="xixi_provider" />

  11. <dubbo:registry address="zookeeper://127.0.0.1:2181" />

  12. <dubbo:protocol name="dubbo" port="20880" />

  13. <dubbo:service interface="com.unj.dubbotest.provider.DemoService"

  14. ref="demoService" />

  15. </beans></span>

创建启动类

[java]  view plain copy print ?

  1. <span style="font-size:18px;">public class Provider {

  2. public static void main(String[] args) throws Exception {

  3. //启动spring容器,把服务器启动之后注册到Zookeeper

  4. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(

  5. new String[] { "applicationContext.xml" });

  6. context.start();

  7. System.in.read(); // 为保证服务一直开着,利用输入流的阻塞来模拟

  8. }

  9. }

创建dubboconsumer(消费者)

注意 provider项目中的DemoService接口打包demo-service-api.jar放在class path中

创建consumer.xml配置文件

applicationContext.xml

[html]  view plain copy print ?

  1. <span style="font-size:18px;">

  2. <beans xmlns="http://www.springframework.org/schema/beans"

  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

  4. xsi:schemaLocation="http://www.springframework.org/schema/beans

  5. http://www.springframework.org/schema/beans/spring-beans.xsd

  6. http://code.alibabatech.com/schema/dubbo

  7. http://code.alibabatech.com/schema/dubbo/dubbo.xsd

  8. ">

  9. <dubbo:application name="hehe_consumer" />

  10. <dubbo:registry address="zookeeper://127.0.0.1:2181" />

  11. <dubbo:reference id="demoService"

  12. interface="com.unj.dubbotest.provider.DemoService" />

  13. </beans></span>

创建consumer启动类

[java]  view plain copy print ?

  1. <span style="font-size:18px;">package com.alibaba.dubbo.demo.pp;

  2. import java.util.List;

  3. import org.springframework.context.support.ClassPathXmlApplicationContext;

  4. import com.unj.dubbotest.provider.DemoService;

  5. /**

  6. * Consumer执行起始类

  7. * @author 李社河-2015年6月22日

  8. *

  9. */

  10. public class Consumer {

  11. public static void main(String[] args) throws Exception {

  12. //初始化Consumer中的spring容器

  13. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(

  14. new String[] { "applicationContext.xml" });

  15. context.start();

  16. // 获取远程服务代理

  17. DemoService demoService = (DemoService) context.getBean("demoService");

  18. //执行远程方法

  19. String hello = demoService.sayHello("tom");

  20. //打印信息

  21. System.out.println(hello);

  22. //同样执行远程方法,打印相关信息

  23. List list = demoService.getUsers();

  24. if (list != null && list.size() > 0) {

  25. for (int i = 0; i < list.size(); i++) {

  26. System.out.println(list.get(i));

  27. }

  28. }

  29. System.in.read();// 为保证服务一直开着,利用输入流的阻塞来模拟

  30. }

  31. }

启动好zookeeper、tomcat之后我们执行运行Provider.class、Consumer.class

成功调到远程服务-----执行Consumer之后结果

Dubbo学习总结(4)——Dubbo基于Zookeeper实现分布式实例

我们在看管理后台的信息

提供者

Dubbo学习总结(4)——Dubbo基于Zookeeper实现分布式实例

消费者

Dubbo学习总结(4)——Dubbo基于Zookeeper实现分布式实例

实例升级--Dubbo服务集群容错实践

手机应用是以聊天室为基础的,我们需要收集用户的操作行为,然后计算聊天室中在线人数,并实时在手机应用端显示人数,整个系统的架构如图所示:

Dubbo学习总结(4)——Dubbo基于Zookeeper实现分布式实例

上图中,主要包括了两大主要流程:日志收集并实时处理流程、调用读取实时计算结果流程,我们使用基于Dubbo框架开发的服务来提供实时计算结果读取聊天人数的功能。上图中,实际上业务接口服务器集群也可以基于Dubbo框架构建服务,就看我们想要构建什么样的系统来满足我们的需要。

如果不使用注册中心,服务消费方也能够直接调用服务提供方发布的服务,这样需要服务提供方将服务地址暴露给服务消费方,而且也无法使用监控中心的功能,这种方式成为直连。

如果我们使用注册中心,服务提供方将服务发布到注册中心,而服务消费方可以通过注册中心订阅服务,接收服务提供方服务变更通知,这种方式可以隐藏服务提供方的细节,包括服务器地址等敏感信息,而服务消费方只能通过注册中心来获取到已注册的提供方服务,而不能直接跨过注册中心与服务提供方直接连接。这种方式的好处是还可以使用监控中心服务,能够对服务的调用情况进行监控分析,还能使用Dubbo服务管理中心,方便管理服务,我们在这里使用的是这种方式,也推荐使用这种方式。使用注册中心的Dubbo分布式服务相关组件结构,如下图所示:

Dubbo学习总结(4)——Dubbo基于Zookeeper实现分布式实例

点赞
收藏
评论区
推荐文章
blmius blmius
2年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
Stella981 Stella981
2年前
KVM调整cpu和内存
一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid
Easter79 Easter79
2年前
Twitter的分布式自增ID算法snowflake (Java版)
概述分布式系统中,有一些需要使用全局唯一ID的场景,这种时候为了防止ID冲突可以使用36位的UUID,但是UUID有一些缺点,首先他相对比较长,另外UUID一般是无序的。有些时候我们希望能使用一种简单一些的ID,并且希望ID能够按照时间有序生成。而twitter的snowflake解决了这种需求,最初Twitter把存储系统从MySQL迁移
Wesley13 Wesley13
2年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败,请联系管理员!');中国在东8区所以加8方法二:selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
Wesley13 Wesley13
2年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Stella981 Stella981
2年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Wesley13 Wesley13
2年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
4个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这