dubbo+zookeeper的使用配置详解「终于解决」

dubbo+zookeeper的使用配置详解「终于解决」dubbo+zookeeper的使用配置详解在现在众多电商、app横行的时代,基本都用到了分布式。而在众多rpc框架中dubbo是最好的选择。dubbo推荐的注册中心是zookeeper,这两个东西一般配合使用。下面开始讲解他们的使用和配置。一、ssm项目使用dubbo大家都知道ssm项目使用的是xml文件进行配置。所以可以在resources下新建provider.xml,我在提供者项目下…

大家好,欢迎来到IT知识分享网。

dubbo+zookeeper的使用配置详解

在现在众多电商、app横行的时代,基本都用到了分布式。而在众多rpc框架中dubbo是最好的选择。dubbo推荐的注册中心是zookeeper,这两个东西一般配合使用。下面开始讲解他们的使用和配置。

一、ssm项目使用dubbo

大家都知道ssm项目使用的是xml文件进行配置。所以可以在resources下新建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://code.alibabatech.com/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
           http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

<!-- 指定当前服务的名字(同样的服务名字相同,不要和别的服务同名) -->
<dubbo:application name="user-service-provider"></dubbo:application>

    <!-- 指定注册中心的位置 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>

    <!-- 指定通信规则(通信协议和通信端口) -->
    <dubbo:protocol name="dubbo" port="20880"></dubbo:protocol>

    <!-- 暴露服务 -->
    <dubbo:service interface="com.atguigu.gmall.service.UserService" ref="userServiceImpl" version="1.0.0"></dubbo:service>
    <!-- 将服务的实现交给spring容器管理 -->
    <bean id="userServiceImpl" class="com.atguigu.gmall.service.impl.UserServiceImpl"></bean>

    <!-- 暴露服务 -->
    <dubbo:service interface="com.atguigu.gmall.service.UserService" ref="userServiceImpl2" version="2.0.0"></dubbo:service>
    <!-- 将服务的实现交给spring容器管理 -->
    <bean id="userServiceImpl2" class="com.atguigu.gmall.service.impl.UserServiceImpl2"></bean>

    <!-- 指定监控中心,registry意为通过注册中心自动寻找监控中心 -->
    <dubbo:monitor protocol="registry"></dubbo:monitor>
</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"
       xmlns:context="http://www.springframework.org/schema/context"
       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
           http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!-- 扫描impl包中的注解 -->
    <context:component-scan base-package="com.atguigu.gmall.service.impl"></context:component-scan>

    <!-- 配置消费者服务名称 -->
    <dubbo:application name="order-service-consumer"></dubbo:application>

    <!-- 配置注册中心地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>

    <!-- 对于接口配置,两个要点
        1)、精确优先(方法级优先,接口级次之,全局配置再次之)
        2)、消费者设置优先(如果级别一样,则消费者优先,提供方次之)
    -->
    <!-- timeout:超时设置,默认时间为1s -->
    <!-- retries:重试次数,不包含第一次调用
        超时设置遵循幂等设计:幂等(重复调用多次跟调用一次一样,设置重试次数。如查询、删除、修改)
                            非幂等(重复调用会造成不一样的结果,不设置重试次数。如新增)
    -->
    <!-- 声明需要调用的远程服务的接口,生成远程服务代理 -->
    <dubbo:reference interface="com.atguigu.gmall.service.UserService" id="userService" timeout="1000" retries="3" version="*">
        <dubbo:method name="getUserAddressList" timeout="5000"></dubbo:method>
    </dubbo:reference>

    <!-- dubbo:consumer为dubbo:interface的通用配置 -->
    <dubbo:consumer check="false" timeout="2000"></dubbo:consumer>

    <!-- 指定监控中心,registry意为通过注册中心自动寻找监控中心 -->
    <dubbo:monitor protocol="registry"></dubbo:monitor>
</beans>

二、springboot使用dubbo

springboot使用dubbo有三种方式,下面一一给大家解释。

1.使用xml文件配置
这种方式跟ssm整合dubbo一样,配置文件内容不变,将文件放到resources下。
在这里插入图片描述
但是要注意在启动类上使用@ImportResourcr注解加载该配置文件,如下图所示:
在这里插入图片描述

2.在application.properties配置dubbo信息
在这里插入图片描述
然后在提供者用dubbo的@Service注解暴露服务,在消费者用dubbo的@Reference从注册中心获取对象。具体如下图所示:

提供者
在这里插入图片描述
消费者
在这里插入图片描述
3.使用配置类方式
大家知道springboot的配置一般有两种方式,一种是在application.properties配置文件里配置,还有就是使用配置类的方式,其实两种方式是一样的,只不过写的地方不同,原理都是在容器中注入bean。你可以在你项目中合适的位置新建一个类名,下面贴出代码:

提供者

package com.atguigu.gmall.config;

import com.alibaba.dubbo.config.*;
import com.atguigu.gmall.service.UserService;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.ArrayList;
import java.util.List;

@Configuration
public class MyDubboConfig {

    @Bean
    public ApplicationConfig applicationConfig(){
        ApplicationConfig applicationConfig = new ApplicationConfig();
        applicationConfig.setName("user-service-provider");
        return applicationConfig;
    }

    //    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
    @Bean
    public RegistryConfig registryConfig(){
        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setAddress("zookeeper://127.0.0.1:2181");
        return registryConfig;
    }

    @Bean
    public ProtocolConfig protocolConfig(){
        ProtocolConfig protocolConfig = new ProtocolConfig();
        protocolConfig.setName("dubbo");
        protocolConfig.setPort(20880);
        return protocolConfig;
    }

//    <dubbo:reference interface="com.atguigu.gmall.service.UserService" id="userService" timeout="1000" retries="3" version="*">
//        <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
//    </dubbo:reference>
    @Bean
    public ServiceConfig<UserService> serviceConfig(UserService userService){
        ServiceConfig<UserService> serviceConfig = new ServiceConfig<>();
        serviceConfig.setInterface(UserService.class);
        serviceConfig.setRef(userService);
//        serviceConfig.setVersion("1.0.0");

        MethodConfig methodConfig = new MethodConfig();
        methodConfig.setName("getUserAddressList");
        methodConfig.setTimeout(2000);

        List<MethodConfig> methodList = new ArrayList<MethodConfig>();
        methodList.add(methodConfig);
        serviceConfig.setMethods(methodList);
        return serviceConfig;
    }

    @Bean
    public MonitorConfig monitorConfig(){
        MonitorConfig monitorConfig = new MonitorConfig();
        monitorConfig.setProtocol("registry");
        return monitorConfig;
    }
}

消费者

package com.atguigu.gmall.config;

import com.alibaba.dubbo.config.*;
import com.atguigu.gmall.service.UserService;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.ArrayList;
import java.util.List;

@Configuration
public class MyDubboConfig {

    @Bean
    public ApplicationConfig applicationConfig(){
        ApplicationConfig applicationConfig = new ApplicationConfig();
        applicationConfig.setName("order-service-consumer");
        return applicationConfig;
    }

//    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
    @Bean
    public RegistryConfig registryConfig(){
        RegistryConfig registryConfig = new RegistryConfig();
        registryConfig.setAddress("zookeeper://127.0.0.1:2181");
        return registryConfig;
    }

//    <dubbo:reference interface="com.atguigu.gmall.service.UserService" id="userService" timeout="1000" retries="3" version="*">
//        <dubbo:method name="getUserAddressList" timeout="1000"></dubbo:method>
//    </dubbo:reference>
    @Bean
    public ReferenceConfig<UserService> referenceConfig(UserService userService){
        ReferenceConfig<UserService> referenceConfig = new ReferenceConfig<UserService>();
        referenceConfig.setInterface(UserService.class);
        referenceConfig.setId("userService");
        referenceConfig.setVersion("1.0.0");

        MethodConfig methodConfig = new MethodConfig();
        methodConfig.setName("getUserAddressList");
        methodConfig.setTimeout(1000);

        List<MethodConfig> methodList = new ArrayList<MethodConfig>();
        methodList.add(methodConfig);
        referenceConfig.setMethods(methodList);
        return referenceConfig;
    }

    @Bean
    public MonitorConfig monitorConfig(){
        MonitorConfig monitorConfig = new MonitorConfig();
        monitorConfig.setProtocol("registry");
        return monitorConfig;
    }
}

总结:大家可以看到springboot的三种方式中在application.properties配置是无法进行方法级别的配置。另外两种是一样的,除了写法没啥区别。个人比较推荐使用xml进行配置。至于原因嘛。我好像发现配置类的方式使用版本号配置并不生效,也有可能是我配置错误,当然使用哪种方式因人而异。在博文中如果有什么错误欢迎大家指正,评论。也欢迎大家评论交流。谢谢大家!!

另外在附上我在本文提到的四个项目的百度云地址。
链接:https://pan.baidu.com/s/1BsCEjtJIzoXxmwPH2y30Gg
提取码:u549

以及dubbo+zookeeper项目学习视频地址:https://www.bilibili.com/video/av30612478

免责声明:本站所有文章内容,图片,视频等均是来源于用户投稿和互联网及文摘转载整编而成,不代表本站观点,不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益,请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权,请联系删除,如若转载,请注明出处:https://yundeesoft.com/25799.html

(0)

相关推荐

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注微信