Dubbo分布式服务框架入门使用

2022-09-21 09:05:41

一、Dubbo入门写个demo

概念：

Provider
暴露服务方称之为“服务提供者”。
Consumer
调用远程服务方称之为“服务消费者”。
Registry
服务注册与发现的中心目录服务称之为“服务注册中心”。
Monitor
统计服务的调用次数和调用时间的日志服务称之为“服务监控中心”。
Dubbo分布式服务框架入门使用

想了解更为深层的概念推荐详细解说杨老师：

　　https://www.cnblogs.com/yjmyzz/p/dubbox-demo.html

服务定义
服务是围绕服务提供方和服务消费方的，服务提供方实现服务，而服务消费方调用服务。

服务注册
对于服务提供方，它需要发布服务，而且由于应用系统的复杂性，服务的数量、类型也不断膨胀；对于服务消费方，它最关心如何获取到它所需要的服务，而面对复杂的应用系统，需要管理大量的服务调用。而且，对于服务提供方和服务消费方来说，他们还有可能兼具这两种角色，即既需要提供服务，有需要消费服务。
通过将服务统一管理起来，可以有效地优化内部应用对服务发布/使用的流程和管理。服务注册中心可以通过特定协议来完成服务对外的统一。Dubbo提供的注册中心有如下几种类型可供选择：

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

服务监控
无论是服务提供方，还是服务消费方，他们都需要对服务调用的实际状态进行有效的监控，从而改进服务质量。

以下皆是个人理解，如若有错误，还望指出，谢谢！

　　dubbo就是个服务框架，如果没有分布式的需求，其实是不需要用的，只有在分布式的时候，才有dubbo这样的分布式服务框架的需求，并且本质上是个服务调用的东东，说白了就是个远程服务调用的分布式框架（告别Web Service模式中的WSdl，以服务者与消费者的方式在dubbo上注册）

下面就来说说入门使用dubbo，本文使用的注册中心是Zookeeper注册中心，在Linux系统下，开发工具是Intellij Idea,使用springboot微服务框架

　　准备工作：下载注册中心Zookeeper，下载地址 http://www.apache.org/dyn/closer.cgi/zookeeper/

第一步：

　　启动注册中心Zookeeper

　　windows下

　　　　直接找到文件apach-zookeeper-3.4.5\bin，目录下的zkServer.cmd双击启动

　　linux下

　　　　同样找到文件目录 ，本人的是在 /usr/java/zookeeper/bin       使用 ./zkServer.sh start启动 ，启动需要一定时间，所以可以反复查看运行状态，输入 ./zkServer.sh status

第二步：

　　访问Dubbo

　　widows下

　　　　直接访问http://localhost:8080即可

　　linux下

　　　　关闭防火墙 service iptables stop

　　　　启动注册中心

　　　　启动Tomcat,找到安装目录输入./startup.sh

　　　　访问http://装有注册中心的linux系统IP:8080

　　　　

　　到这里已经可以查看登陆到Zookeeper注册中心:

　　　　1,首先可以先查看下tomcate猫的启动状态 ，输入　　http://当前启动注册中心的机器ip地址:8080                                    （ tomcat默认8080端口）

　　　　2，输入　　http://当前启动注册中心的机器ip地址:8080/dubbo-admin/  进入到注册中心

　　　　3，注册中心会提示你输入密码 默认账号是root,密码是root，登陆成功后进入以下界面

　　　　Dubbo分布式服务框架入门使用

　　　　4,登陆注册中心后，什么都没有，下面就开始写代码

　　　　4.1 服务提供者

　　　　　  4.1.1在pom.xml中加入依赖

　　　　  <dubbo.version>2.5.3</dubbo.version>

         <zookeeper.version>3.4.7</zookeeper.version>

         <zkclient.version>0.1</zkclient.version>                        

　　　　　　　<!-- dubbo相关 -->

            <dependency>

                <groupId>com.alibaba</groupId>

                <artifactId>dubbo</artifactId>

                <version>${dubbo.version}</version>

            </dependency>

            <dependency>

                <groupId>org.apache.zookeeper</groupId>

                <artifactId>zookeeper</artifactId>

                <version>${zookeeper.version}</version>

            </dependency>

            <dependency>

                <groupId>com.github.sgroschupf</groupId>

                <artifactId>zkclient</artifactId>

                <version>${zkclient.version}</version>

　　　　　　　</dependency>

　　　　4.1.2 　

　　　　　　　逻辑代码还是像平时一样，该怎么写就怎么写，但要注意：

　　　　　　　　　　服务提供者必须把Interface接口写成一个包，并且暴露出来

　　　　　　　　　在本项目中再去实现service的接口，并且注入的@service必须为 alibaba下提供的service,但是这有弊端，就是不能跟事务@Transactional共同使用，具体解释看文章结尾，

　　　　　　　　　例如：

　　　　　　　　　　 import com.alibaba.dubbo.config.annotation.Service;//引入的包是albaba提供的bean

　　　　　　　　　　 @Service

　　　　　　        public class StudentService implements StudentService{
　　　　　　　　　　　　　　//实现本项目下接口包的方法
　　　　　　　　　　　}

　　　 4.1.3  向注册中心中给提供者的注册下

　　　　　　如果你使用是springboot微服务框架

　　　　　　在application.properties总配置文件中加入 注册

#注册到zookeeper 中服务的名字

spring.dubbo.application.name=lwh_provider

#注册中心的地址，ip为启动了zookeeper的linux服务器的ip,2181是注册中心的默认端口

spring.dubbo.registry.address=zookeeper://192.168.25.129:2181

#使用dubbo协议

spring.dubbo.protocol.name=dubbo

#dubbo服务在哪个端口暴露

spring.dubbo.protocol.port=20880

#去哪里扫描dubbo的服务组件，这是你service接口的实现类的包名,也就是上面提到的为什么把接口暴露出来

spring.dubbo.scan=com.lwh.service.impl

　　　　　　如果你使用是spring，那就再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">

    <!--定义了提供方应用信息，用于计算依赖关系；在 dubbo-admin 或 dubbo-monitor 会显示这个名字，方便辨识-->

    <dubbo:application name="demotest-provider" owner="programmer" organization="dubbox"/>

    <!--使用 zookeeper 注册中心暴露服务，注意要先开启 zookeeper-->

    <dubbo:registry address="zookeeper://localhost:2181"/>

    <!-- 用dubbo协议在20880端口暴露服务 -->

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

    <!--使用 dubbo 协议实现定义好的 api.PermissionService 接口-->

    <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" protocol="dubbo" />

    <!--具体实现该接口的 bean-->

    <bean id="demoService" class="com.alibaba.dubbo.demo.impl.DemoServiceImpl"/>

</beans>

　　　5 服务消费者

　　　　5.1 跟提供者一样，加入依赖

　　　　 5.2 代码依旧跟以前一样写

　　　　　　但是注意的是写action时：你使用的service接口中的方法是提供者暴露出来的那个接口，所以，注入不能是@Autowired按类型注入了

　　　　　　而是使用 alibaba提供的@Reference注入，例如：

 import com.alibaba.dubbo.config.annotation.Reference;

 @Controller

 public class StudentAction {

     @Reference

     private StudentService studentService;

 }

　　　　 5.3 向注册中心中给消费者的注册下

　　　　　　如果你使用是springboot微服务框架

　　　　　　在application.properties总配置文件中加入 注册

#消费者 在注册中心注册的名字

spring.dubbo.application.name=lwh_Consumer

#注册中心的地址

spring.dubbo.registry.address=zookeeper://192.168.25.129:2181

#去哪里扫描消费者

spring.dubbo.scan=com.lwh.action

　　　　　   如果你使用是spring，那就再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">

    <dubbo:application name="demotest-consumer" owner="programmer" organization="dubbox"/>

    <!--向 zookeeper 订阅 provider 的地址，由 zookeeper 定时推送-->

    <dubbo:registry address="zookeeper://localhost:2181"/>

    <!--使用 dubbo 协议调用定义好的 api.PermissionService 接口-->

    <dubbo:reference id="permissionService" interface="com.alibaba.dubbo.demo.DemoService"/>

</beans>

然后让两个项目跑起来后，再去登陆注册中心会发现自己发布的已经注册到注册中心去了

提供者

Dubbo分布式服务框架入门使用

消费者

Dubbo分布式服务框架入门使用

到此为止，dubbo的入门就结束了，实际中有多提供者多消费者情况，比这要复杂的多，当然只有这样才能体现dubbo的特性。

二、下面来说说关于Dubbo使用alibaba下的@Service注入发布Dubbo服务时，同时使用了@Transactional注解加入事务后Dubbo服务不能发布的问题，

也就是说不能同时使用@com.alibaba.dubbo.config.annotation.Service和@Transactional

　　原因：因为当你使用事务后，spring bean中事务是使用事务代理的，简单说就是执行者不是本体，而是代理类，那么，问题来了，这个时候Dubbo的AnnotationBean扫描类执行扫描代码时，就获取不到对应的注解，自然而然就发布不服务了。

　　解决方案：

　　　　　经过网络上再三寻找方法，发现有四种解决方案，但是个人觉得可执行的只有两种：

　　　　　方法一（个人认为实用型）：

　　　　　　使用了@Transactional注解加入事务后，就不要使用@com.alibaba.dubbo.config.annotation.Service提供的@Service注解了，使用spring提供的@Service,然后自己写个xml文件去配置Dubbo的服务

dubbo.xml:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
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-4.2.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.2.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.2.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.2.xsd
http://www.springframework.org/schema/util
http://www.springframework.org/schema/util/spring-util-4.2.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

<!-- 配置包扫描器 -->
<context:component-scan base-package="com.lwh"/>
<!-- 使用dubbo发布服务 -->
<!-- 提供方应用信息，用于计算依赖关系 -->
<dubbo:application name="dubbo_p" />
<dubbo:registry protocol="zookeeper"
address="192.168.25.129:2181" />
<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20880" />
<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.lwh.provider.service.UserService" ref="UserServiceImpl" timeout="600000"/>
</beans>

　　　　方法二（反正我试了没用）

                　接着使用alibaba提供的dubbo@Service发布dubbo服务，但是不使用spring提供的@Transactioncal注解加入的事务，使用自己配置的方式去加入事务，这里就不提供代码了

　　　　方法三（简直疯了，居然改源码）

　　　　　  修改Dubbo的源码，也就是让注解的事务代理，强制去让他自己处理

　　　　Dubbo分布式服务框架入门使用

　　　　    

以上是个人所理解，技术有限，如若有错误，希望能够提出交流，谢谢！

上一篇：kafka系列二：多节点分布式集群搭建


下一篇：多源最短路（codevs 1077）