dubbo的demo,dubbo教程文档
00-1010 1.Dubbo是什么?2.Dubbo能做什么?3.杜博的建筑4。dubbo的用法。服务提供者:服务消费者:
目录
Dubbo是一个分布式服务框架,致力于提供高性能、透明的RPC远程服务调用方案和SOA服务治理方案。简单来说,dubbo是一个服务框架。如果没有分布式的需求,其实没必要。只有分布式的时候,才有dubbo这样的分布式服务框架的需求,本质上是服务调用。说白了就是远程服务调用的分布式框架(告别Web服务模式的WSdl,在dubbo上注册为服务器和消费者)。其核心部分包含:1。Telecommunication 3360提供了基于长连接的各种NIO框架的抽象封装,包括各种线程模型、序列化和“请求-响应”模式下的信息交换方法。2.集群容错:提供基于接口方法的透明远程过程调用,包括多协议支持,以及软负载均衡、故障容错、地址路由、动态配置等集群支持。3.Auto-discovery 3360基于注册表的目录服务,让服务消费者动态搜索服务提供者,地址透明,让服务提供者平滑增减机器。
00-1010 1.透明的远程方法调用,就像调用本地方法一样,只需要简单的配置,不需要任何API的介入。2.软负载均衡和容错机制,可以替代内网中的F5等硬件负载均衡器,降低成本和单点。3.自动服务注册和发现,不再需要写服务提供商的地址,注册中心可以根据接口名称查询服务提供商的IP地址,可以平滑添加或删除服务提供商。
Dubbo采用全spring配置模式,透明访问应用,对应用没有API入侵。用Spring加载Dubbo的配置就行了,Dubbo是基于Spring的Schema扩展加载的。在使用Web Service之前,我觉得可以通过soapui或者LR,通过模拟消息来测试测试接口的功能或者性能。但是现在使用dubbo,接口之间不能直接交互。我试图通过模拟消费者地址测试,结果不堪入目。然后我用jmeter通过了junit测试,但是我还需要向Dubbo注册。如果我不提供源代码,这个测试用例就不好写了。
1. Dubbo是什么?
dubbo架构示意图如下:
节点角色描述:
Provider:公开服务的服务提供者。Consumer:调用远程服务的服务消费者。注册表:是服务注册和发现的注册表。Monitor:统计服务调用次数和调用次数的监控中心。容器:服务运行容器。
我觉得这样很好,角色明确,可以根据每个节点角色的状态来决定服务是否正常。
呼叫关系描述:
1.服务容器负责启动、加载和运行服务提供者。1.当服务提供者启动时,它向注册中心注册它自己的服务。2.当服务消费者启动时,他们向注册中心订阅他们需要的服务。3.注册中心将服务提供商的地址列表返回给消费者。如有变更,注册中心将基于长连接向消费者推送变更数据。4.服务消费者根据软负载平衡算法,从提供者地址列表中选择一个提供者进行调用。如果呼叫失败,请选择另一个呼叫。5.服务消费者和提供者,在内存中累计通话次数和通话次数,每分钟定时向监控中心发送统计数据。
Dubbo的容错性是显而易见的,性能还没有测出来。我们系统的一个页面需要掉线五次。本来想建议做个缓存,但是业务关系不能采纳。我们还需要研究dubbo的性能调优…
2. Dubbo能做什么?
Dubbo采用全Spring配置模式,透明访问应用,对应用没有API入侵。用Spring加载Dubbo的配置就行了,Dubbo是基于Spring的Schema扩展加载的。如果不想使用Spring配置,而是想通过API调用(不推荐)
我们来看看:写的弹簧配置方法。
00-1010 1.下载zookeeper注册中心,下载地址:http://www.apache.org/dyn/closer.cgi/zookeeper/.下载完成后,解压,进入D:apach-zookeeper-3.4.5in,双击zkServer.cmd启动注册中心服务。
2.定义服务接口:(这个接口需要单独打包,在服务提供者和消费者之间共享)
下面这个例子不错,写的很详细,可以作为范本。
包com . unj . dubbo test . provider;导入Java . util . list;公共接口演示服务{
String sayHello(String name); public List getUsers(); }在服务提供方实现接口:(对服务消费方隐藏实现)
package com.unj.dubbotest.provider; import java.util.ArrayList; import java.util.LinkedList; import java.util.List; public class DemoServiceImpl implements DemoService{ public String sayHello(String name) { return "Hello " + name; } public List getUsers() { List list = new ArrayList(); User u1 = new User(); u1.setName("jack"); u1.setAge(20); u1.setSex("男"); User u2 = new User(); u2.setName("tom"); u2.setAge(21); u2.setSex("女"); User u3 = new User(); u3.setName("rose"); u3.setAge(19); u3.setSex("女"); list.add(u1); list.add(u2); list.add(u3); return list; }
用Spring配置声明暴露服务:
<?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 "> <!-- 具体的实现bean --> <bean id="demoService" class="com.unj.dubbotest.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:2181" /> <!-- 用dubbo协议在20880端口暴露服务 --> <dubbo:protocol name="dubbo" port="20880" /> <!-- 声明需要暴露的服务接口 --> <dubbo:service interface="com.unj.dubbotest.provider.DemoService" ref="demoService" /> </beans>
加载Spring配置,启动服务:
package com.unj.dubbotest.provider; import org.springframework.context.support.ClassPathXmlApplicationContext; public class Provider { public static void main(String[] args) throws Exception { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"applicationContext.xml"}); context.start(); System.in.read(); // 为保证服务一直开着,利用输入流的阻塞来模拟 } }
服务消费者:
applicationContext-dubbo.xml 中注册自己需要调用的接口,我刚开始测试的时候需要的接口很多,所以把这个文件写的满满的,后来熟悉了把接口按业务类型分开,写了N多个 applicationContext-dubbo-*.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="hehe_consumer" /> <!-- 使用zookeeper注册中心暴露服务地址 --> <!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> --> <dubbo:registry address="zookeeper://127.0.0.1:2181" /> <!-- 生成远程服务代理,可以像使用本地bean一样使用demoService --> <dubbo:reference id="demoService" interface="com.unj.dubbotest.provider.DemoService" /> </beans>
2.加载Spring配置,并调用远程服务:
package com.alibaba.dubbo.demo.pp; import java.util.List; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.unj.dubbotest.provider.DemoService; public class Consumer { public static void main(String[] args) throws Exception { ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext( new String[] { "applicationContext.xml" }); context.start(); DemoService demoService = (DemoService) context.getBean("demoService"); // String hello = demoService.sayHello("tom"); // ? System.out.println(hello); // // List list = demoService.getUsers(); if (list != null && list.size() > 0) { for (int i = 0; i < list.size(); i++) { System.out.println(list.get(i)); } } // System.out.println(demoService.hehe()); System.in.read(); } }
调用结果为:
dubbo管理页面:
这个管理页面还需要部署一个环境的,一开始我还以为是dubbo自带的,找了半天没有找到….
应用页面:
提供者页面:
消费者页面:
服务页面:
测试是否成功,我觉得只要看看状态是否正常,就ok了 ….
案例代码下载:http://xiazai.jb51.net/202204/yuanma/provider_jb51.rar
到此这篇关于dubbo详解及demo实例的文章就介绍到这了,更多相关demo实例内容请搜索盛行IT以前的文章或继续浏览下面的相关文章希望大家以后多多支持盛行IT!
郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。