首页 > 其他分享 >Dubbo

Dubbo

时间:2022-11-01 23:48:15浏览次数:47  
标签:Dubbo 服务 zk dubbo 接口 web user

Dubbo

  • 是一款高性能、轻量级的开源 Java RPC 框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。
  • Dubbo 是一个分布式服务框架,致力于提供高性能和透明化的 RPC 远程服务调用方案、 服务治理方案。

面向接口代理:调用接口的方法,在 A 服务器调用 B 服务器的方法,由 dubbo 实现对 B 的
调用,无需关心实现的细节,就像 MyBatis 访问 Dao 的接口,可以操作数据库一样。不用关
心 Dao 接口方法的实现。这样开发是方便,舒服的。

注意:网络中传输对象需要进行序列化操作

dubbo 服务化最佳实践:(有直连方式以及注册中心方式)

需要三个工程:接口工程【java】、服务提供者工程【web】、服务消费者工程【web】
接口工程【java】:负责实体 bean 以及业务接口(提供者和消费者均依赖于它)
服务提供者工程【web】:负责实现接口工程中的服务接口,提供服务,暴露服务,供消费者调用
服务消费者工程【web】:负责调用提供者提供的服务    

Dubbo + Zookeeper 使用演示

  1. 安装 Zookeeper,配置 zoo.cfg

    Zookeeper 下载后直接解压即可,启动服务使用其相关命令即可

    需要对文件进行相关配置

    在安装后解压的Zookeeper目录下新建data目录,存储一些相关数据,记住该data目录路径
    
    备份 /conf/zoo_sample.cfg,将 zoo_sanple.cfg 改名为 zoo.cfg
    
    进入该配置文件,需要修改两处位置:
    1.将dataDir的默认路径改为新建的data目录路径(记得改为斜杠)
    dataDir=/tmp/zookeeper(改前)
    dataDir=D:/Java/apache-zookeeper-3.5.7-bin/data(改后) 
    2.在clientPort=2181下添加指定端口,覆盖Zookeeper默认启动的8080端口
    clientPort=2181
    admin.serverPort=8888(新增的,用来覆盖默认的)    
    
  2. 新建 maven java 工程模块 dubbo-zk-interface,写实体bean以及业务接口【接口工程】

    // 实体bean
    // 实体类进行网络通信,必须进行序列化
    public class User implements Serializable {
        private Integer id;
        private String userName;
        private String password;
        // 下略
    }    
    
    // 业务接口
    public interface UserService {
        User queryUserById(Integer id);
    }
    
  3. 新建 maven web 工程模块dubbo-zk-userservice-provider,写接口实现类,提供服务【服务提供者】

    注意:配置Tomcat的时候记得改下两个端口号,避免启动多个服务时端口号冲突

    相关依赖:
    <dependencies>
        <!--  spring 依赖  -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>4.3.16.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>4.3.16.RELEASE</version>
        </dependency>
        <!--dubbo依赖-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.2</version>
        </dependency>
        <!-- 接口工程依赖 -->
        <dependency>
            <groupId>com.luis</groupId>
            <artifactId>dubbo-zk-interface</artifactId>
            <version>1.0</version>
        </dependency>
        <!--  zookeeper依赖  -->
        <dependency>
          <groupId>org.apache.curator</groupId>
          <artifactId>curator-framework</artifactId>
          <version>4.1.0</version>
        </dependency>
    </dependencies>
    
    <build>
        <plugins>
            <plugin>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
    
    // 接口实现类
    public class UserServiceImpl implements UserService {
        @Override
        public User queryUserById(Integer id) {
            User user = new User(id, "luis", "123");
            return user;
        }
    }
    
    spring配置文件:当下命名为dubbo-zk-userservice-provider.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://dubbo.apache.org/schema/dubbo"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans.xsd
           http://dubbo.apache.org/schema/dubbo
           http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    
        <!--  声明dubbo服务提供者名称:保证唯一性  -->
        <dubbo:application name="dubbo-zk-userservice-provider"/>
    
        <!--  声明dubbo使用的协议名称以及端口号  -->
        <dubbo:protocol name="dubbo" port="20880"/>
    
        <!--  使用Zookeeper注册中心  -->
        <!--  指定注册中心地址和端口号  -->
        <dubbo:registry address="zookeeper://localhost:2181"/>
    
        <!--  暴露服务接口  -->
        <dubbo:service interface="com.luis.service.UserService" ref="userServiceImpl"/>
    
        <!--  加载接口实现类  -->
        <bean id="userServiceImpl" class="com.luis.service.impl.UserServiceImpl"/>
    </beans>
    
  4. 新建 maven web 工程模块dubbo-zk-consumer,调用服务接口【服务消费者】

    注意:配置Tomcat的时候记得改下两个端口号,避免启动多个服务时端口号冲突

    <dependencies>
        <!--  spring 依赖  -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>4.3.16.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>4.3.16.RELEASE</version>
        </dependency>
        <!--dubbo依赖-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.2</version>
        </dependency>
        <!-- 接口工程依赖 -->
        <dependency>
            <groupId>com.luis</groupId>
            <artifactId>dubbo-zk-interface</artifactId>
            <version>1.0</version>
        </dependency>
        <!--  zookeeper依赖  -->
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.1.0</version>
        </dependency>
        <!-- servlet依赖 -->
        <dependency>
          <groupId>javax.servlet</groupId>
          <artifactId>javax.servlet-api</artifactId>
          <version>3.1.0</version>
          <scope>provided</scope>
        </dependency>
        <!-- jsp依赖 -->
        <dependency>
          <groupId>javax.servlet.jsp</groupId>
          <artifactId>jsp-api</artifactId>
          <version>2.2.1-b03</version>
          <scope>provided</scope>
        </dependency>
    </dependencies>
    
    <build>
        <plugins>
            <plugin>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.1</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
    
    applicationContext.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:context="http://www.springframework.org/schema/context"
           xmlns:mvc="http://www.springframework.org/schema/mvc"
           xsi:schemaLocation="http://www.springframework.org/schema/beans
           http://www.springframework.org/schema/beans/spring-beans.xsd
           http://www.springframework.org/schema/context
           http://www.springframework.org/schema/context/spring-context.xsd
           http://www.springframework.org/schema/mvc
           http://www.springframework.org/schema/mvc/spring-mvc.xsd">
    
        <!--  声明组件扫描器  -->
        <context:component-scan base-package="com.luis.web"/>
    
        <!--  配置注解驱动  -->
        <mvc:annotation-driven/>
    
        <!--  视图解析器  -->
        <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
            <property name="prefix" value="/"/>
            <property name="suffix" value=".jsp"/>
        </bean>
    </beans>
    
    dubbo-zk-consumer.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服务消费者名称:保证唯一性  -->
        <dubbo:application name="dubbo-zk-consumer.xml"/>
    
        <!--  指定zookeeper注册中心  -->
        <dubbo:registry address="zookeeper://localhost:2181"/>
    
        <!--  引用远程接口服务  -->
        <dubbo:reference id="userService" interface="com.luis.service.UserService"/>
    </beans>
    
    web.xml配置文件
    <?xml version="1.0" encoding="UTF-8"?>
    <web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee 
             http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
             version="4.0">
        
        <!--  注册中央调度器  -->
        <servlet>
            <servlet-name>dispatcherServlet</servlet-name>
            <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
            <init-param>
                <param-name>contextConfigLocation</param-name>
                <param-value>classpath:applicationContext.xml,classpath:dubbo-zk-consumer.xml</param-value>
            </init-param>
        </servlet>
        <servlet-mapping>
            <servlet-name>dispatcherServlet</servlet-name>
            <url-pattern>/</url-pattern>
        </servlet-mapping>
    </web-app>
    
    // 控制器类
    @Controller
    public class UserController {
    
        @Autowired
        private UserService userService;
    
        @RequestMapping("/userDetail")
        public String userDetail(Integer id, Model model) {
            User user = userService.queryUserById(id);
            model.addAttribute("user", user);
            return "userDetail";
        }
    }
    
    userDetail.jsp
    <%@ page contentType="text/html;charset=UTF-8" language="java" %>
    <%
        String basePath = request.getScheme() + "://" +
                request.getServerName() + ":" + request.getServerPort() +
                request.getContextPath() + "/";
    %>
    <html>
    <head>
        <base href="<%=basePath%>">
        <title>Title</title>
    </head>
    <body>
        <h3>用户详情</h3>
        <span>用户标识:${user.id}</span>
        <span>用户姓名:${user.userName}</span>
        <span>用户密码:${user.password}</span>
    </body>
    </html>
    
  5. 测试

    先启动Zookeeper注册中心
    再启动服务提供者
    最后启动服务消费者
    在服务消费者服务地址栏进行访问:http://localhost:8080/userDetail?id=12    
    注意:多服务启动,端口不能相同
    

版本号version使用

当服务提供者对同一个接口有多个实现类时,需要用到版本号进行区分!

在服务提供者工程的配置文件中进行如下配置:

<?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://dubbo.apache.org/schema/dubbo"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo
       http://dubbo.apache.org/schema/dubbo/dubbo.xsd">

    <!--  声明dubbo服务提供者名称:保证唯一性  -->
    <dubbo:application name="dubbo-zk-userservice-provider"/>

    <!--  声明dubbo使用的协议名称以及端口号  -->
    <dubbo:protocol name="dubbo" port="20880"/>

    <!--  使用Zookeeper注册中心  -->
    <!--  指定注册中心地址和端口号  -->
    <dubbo:registry address="zookeeper://localhost:2181"/>

    <!--  暴露服务接口  -->
    <dubbo:service interface="com.luis.service.UserService" ref="userServiceImpl1"
                   version="1.0.0"/>
    <dubbo:service interface="com.luis.service.UserService" ref="userServiceImpl2" 
                   version="2.0.0/>

    <!--  加载接口实现类  -->
    <bean id="userServiceImpl1" class="com.luis.service.impl.UserServiceImpl1"/>
    <bean id="userServiceImpl2" class="com.luis.service.impl.UserServiceImpl2"/>
</beans>

在服务消费者工程的配置文件中进行如下配置:

<?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服务消费者名称:保证唯一性  -->
    <dubbo:application name="dubbo-zk-consumer.xml"/>

    <!--  指定zookeeper注册中心  -->
    <dubbo:registry address="zookeeper://localhost:2181"/>

    <!--  引用远程接口服务  -->
    <dubbo:reference id="userService1" interface="com.luis.service.UserService" version="1.0.0"/>
    <dubbo:reference id="userService2" interface="com.luis.service.UserService" version="2.0.0"/>
</beans>

标签:Dubbo,服务,zk,dubbo,接口,web,user
From: https://www.cnblogs.com/luisblog/p/16849581.html

相关文章

  • dubbo java.nio.channels.ClosedChannelException、com.alibaba.dubbo.remoting.Remot
    客户端错误:com.alibaba.dubbo.rpc.RpcException:Invokeremotemethodtimeout.method:searchUser,provider:...cause:Waitingserver-sideresponsetimeoutbyscan......
  • Dubbo的多协议、多Registry、服务分组、多版本、分组聚合
    转自:https://blog.csdn.net/dkfajsldfsdfsd/article/details/907212301、参考多协议:http://dubbo.apache.org/en-us/docs/user/demos/multi-protocols.html多Registry:ht......
  • Dubbo笔记衍生篇:MergeableClusterInvoker
    转自:https://blog.csdn.net/qq_36882793/article/details/117366243一、前言本系列为个人Dubbo学习笔记衍生篇,是正文篇之外的衍生内容,内容来源于《深度剖析ApacheDubbo......
  • dubbo学习笔记
    Dubbo背景和简介Dubbo开始于电商系统,因此在这里先从电商系统的演变讲起。单一应用框架(ORM)当网站流量很小时,只需一个应用,将所有功能如下单支付等都部署在一起,以减少......
  • spring boot+dubbo+zookeeper
    111TRANSLATEwithxEnglishArabicHebrewPolishBulgarianHindiPortugueseCatalanHmongDawRomanianChineseSimplifiedHungarianRussian......
  • 【拥有新时代的通信协议,引领云原生迈向更高的舞台】解密Dubbo3是如何从微服务升华到云
    感谢2020云原生微服务给我带来了云原生的希望!Dubbo3拥抱云原生升级总体路线我们会侧重于下面红色填充的部分,针对于Dubbo3云原生技术的领域的探索和研究:看Dubbo3带来了什么?要......
  • SpringCloud(一) - Dubbo + Zookeeper
    Dubbo和Zookeeper不是SpringCloud的东西,放在这里只是为了方便复习;1、下载安装Zookeeper和Dubbo1.1下载安装教程下载安装教程windows环境下安装zookeeper教程详解(单......
  • dubbo的一系列配置与搭建
    dubbo新的版本采用前后端分离技术,在github上下载的时候,不仅仅只是一个dubbo-admin而是将admin包分离为dubbo-admin-ui前端包和dubbo-admin-server后端包 首先,无论运......
  • Dubbo 原理和机制详解 (非常全面)
    Dubbo是一款JavaRPC框架,致力于提供高性能的RPC远程服务调用方案。作为主流的微服务框架之一,Dubbo 为开发人员带来了非常多的便利。大家好,我是 mikechen,专注分享「......
  • Dubbo-聊聊注册中心的设计
    前言Dubbo源码阅读分享系列文章,欢迎大家关注点赞SPI实现部分Dubbo-SPI机制Dubbo-Adaptive实现原理Dubbo-Activate实现原理DubboSPI-Wrapper注册中心作用在整个Duub......