SpringBoot框架和SSM框架Dubbo入门教程

转x33g5p2x  于2021-09-25 转载在 Spring  
字(32.2k)|赞(0)|评价(0)|浏览(485)

介绍

http://dubbo.apache.org/zh/docs/v2.7/user/examples/ (官方文档)

当服务越来越多时，容量的评估，小服务资源的浪费等问题逐渐显现，此时需要增加一个调度中心基于访问压力实时管理集群容量，提供集群利用率。其中，用于提高机器利用率的资源调度和治理中心是关键。

Dubbo 是阿里巴巴开源项目的一个分布式服务框架。其致力于提供高性能和透明化的 RPC 远程调用方案，以及 SOA 服务治理方案。

原理图

调用关系说明：

服务容器启动、加载和运行服务提供者；
1.
服务提供者在启动时，向注册中心注册自己提供的服务；
1.
服务消费者在启动时，向注册中心订阅自己所需的服务；
1.
注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更给消费者；
1.
服务消费者从地址列表中，基于软负载均衡算法选一台服务提供者进行调用，如果调用失败再选另一台；
1.
服务消费者和服务提供者在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

节点角色说明

节点角色说明
Container服务运行容器
Provider暴露服务的服务提供者
Consumer调用远程服务的服务消费者
Registry服务注册与发现的注册中心
Monitor统计服务的调用此处和调用时间的监控中心

Dubbo 采用全 Spring 配置方式，透明化接入应用，对应用没有任何 API 入侵，只需用 Spring 加载 Dubbo 配置即可。

官方推荐使用 Zookeeper 作为注册中心，因此本次测试使用 Zookeeper

以下教程我自己服务器为演示: 我的服务器 ip 为 49.232.169.170 (学生服务器9元1个月)

安装Zookeeper

官网下载地址：http://archive.apache.org/dist/zookeeper/

本课程使用的Zookeeper版本为3.4.6

zookeeper-3.4.6.tar

链接：https://pan.baidu.com/s/1aFhIJz6nRXtFXv3dfu6JIQ
提取码：1234

下载完成后可以获得名称为zookeeper-3.4.6.tar.gz的压缩文件。

安装步骤：(建议安装到自己 服务器或虚拟机上 这样日后学习的时候比较方便 )

第一步：安装 jdk（略 ） 这个你自己在网上找资料进行安装 使用 java -version 查询当前机器 JDK版本号

第二步：把 zookeeper 的压缩包（zookeeper-3.4.6.tar.gz）上传到 linux 系统的 /root下面

第三步：解压缩压缩包

tar -zxvf zookeeper-3.4.6.tar.gz

第四步：进入zookeeper-3.4.6目录，创建data目录

mkdir -p /root/zookeeper-3.4.6/data

第五步：进入conf目录 ，把zoo_sample.cfg 改名为zoo.cfg

cd   /root/zookeeper-3.4.6/conf 

mv zoo_sample.cfg zoo.cfg

第六步：打开zoo.cfg文件, 修改data属性：dataDir=/root/zookeeper-3.4.6/data (对应你上面创建的data)

vi  zoo.cfg

第7步管理Zookeeper服务

进入Zookeeper的bin目录，

cd   /root/zookeeper-3.4.6/bin
#启动服务命令 (1)
./zkServer.sh start

#停止服务命令
./zkServer.sh stop

#重启服务命令
./zkServer.sh restart 

#查看服务状态 (2)
./zkServer.sh status

以上就是 Zookeeper注册中心服务 的搭建 但是这还没有完 .

安装Dubbo管理控制台

我们在开发时，需要知道Zookeeper注册中心都注册了哪些服务，有哪些消费者来消费这些服务。我们可以通过部署一个管理中心来实现。其实管理中心就是一个web应用，部署到tomcat即可。

安装步骤: (建议安装到自己 服务器或虚拟机上 这样日后学习的时候比较方便 )

官方下载地址 https://github.com/apache/incubator-dubbo-ops

但是需要你将项目 自己打包成war

dubbo-admin-2.6.0

链接：https://pan.baidu.com/s/1f9eSBd69qyO-N6BLepn_zg
提取码：1234

1）将dubbo-admin-2.6.0.war文件复制到tomcat的webapps目录下

2）启动tomcat，此war文件会自动解压

3）修改WEB-INF下的dubbo.properties文件，
注意dubbo.registry.address对应的值 需要对应当前使用的Zookeeper的ip地址和端口号

如果在本地服务器安装那么 就不用修改 默认就是

dubbo.registry.address=zookeeper://localhost:2181

如果zookeeper是在其他地方安装的需要修改

dubbo.registry.address=zookeeper://zookeeperip:2181

其他的配置默认就行 如果修改了配置文件需要重启Tomcat的

还有就是 你的jdk不能低于1.8版本

如果以上都没问题那么访问 http://49.232.169.170:8080/dubbo-admin-2.6.0/ (49.232.169.170是你自己的ip)

输入默认的 用户名(root)和密码(root)

出现以上页面就代表你成功了 小提示: 在你右上角可切换为中文模式

因为我们还没有配置 服务提供者 和 消费者 现在是查询不到东西的 (先不要急)

使用Docker安装Zookeeper(推荐)

1，下载Zookeeper镜像， docker没有 3.4.6版本的我们只能下载3.4.9 不要下载最新版本会出问题的

docker pull zookeeper:3.4.9

2，启动容器并添加映射

docker run -d --name zookeeper --restart=always  -p 2181:2181  zookeeper:3.4.9

3，查看容器是否启动

docker ps

docker logs  zookeeper  (查看日志)

4, 进入容器的配置文件位置

docker exec -it zookeeper /bin/bash

cd  /conf/

vi  zoo.cfg       (修改  dataDir=/data  可能默认就是/data)

admin.serverPort=8089

mkdir -p /data    (创建dataDir的data 目录)

5, 管理Zookeeper服务

进入Zookeeper的bin目录， (在创建容器的时候就已经启动了 所以不要启动了)

cd /zookeeper-3.4.9/bin
#启动服务命令 
./zkServer.sh start

#停止服务命令
./zkServer.sh stop

#查看服务状态 (1)
./zkServer.sh status

#重启
./zkServer.sh  restart

# 查看zookeeper 日志
./zkServer.sh start-foreground

以上就是 Zookeeper注册中心服务 的搭建

查看节点注册情况

cd /zookeeper-3.4.9/bin
./zkCli.sh         
 
然后  ls /dubbo   就能看的我们提供的服务的包路径

比如: [com.example.service.UserService]

使用Docker安装Dubbo管理控制台(推荐)

注意必须和 Zookeeper 安装在一个服务器或者虚拟机上

1, 下载 dubbo-admin 镜像 (在DockerHub仓库找的 这个比较好 官方的有问题)

docker pull chenchuxin/dubbo-admin

2, 启动 dubbo-admin 默认的端口就是8080 我们将本机8111端口映射到8080

docker run -d \
--name dubbo-admin \
--restart=always \
-p 8111:8080 \
-e dubbo.registry.address=zookeeper://49.232.169.170:2181 \
-e dubbo.admin.root.password=root \
-e dubbo.admin.guest.password=guest \
chenchuxin/dubbo-admin

3, 查看容器是否启动

docker ps

4, 然后访问

http://你主机的ip:8111 我的是 http://49.232.169.170:8111 (刚配置完估计进不去 等一会)

默认账号密码是

  • 管理员root：：root
  • 游客guest：：guest

出现上面这页面就ok了

搭建服务提供者

搭建服务提供 有两种方式 使用Spring web 和 Springboot 这里推荐Springboot 这两种都会演示

Spring web 方式

创建 Maven web项目 项目名 dubbodemo_provider

添加Maven依赖

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
    <spring.version>5.0.5.RELEASE</spring.version>
  </properties>
<dependencies>
    
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-context</artifactId>
    <version>${spring.version}</version>
  </dependency>
    
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-beans</artifactId>
    <version>${spring.version}</version>
  </dependency>
    
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-webmvc</artifactId>
    <version>${spring.version}</version>
  </dependency>
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jdbc</artifactId>
    <version>${spring.version}</version>
  </dependency>
    
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-aspects</artifactId>
    <version>${spring.version}</version>
  </dependency>
    
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jms</artifactId>
    <version>${spring.version}</version>
  </dependency>
    
  <dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-context-support</artifactId>
    <version>${spring.version}</version>
  </dependency>
  <!-- dubbo相关 -->
  <dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>dubbo</artifactId>
    <version>2.6.0</version>
  </dependency>

  <dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.4.6</version>
  </dependency>
  <dependency>
    <groupId>com.github.sgroschupf</groupId>
    <artifactId>zkclient</artifactId>
    <version>0.1</version>
  </dependency>
  <dependency>
    <groupId>javassist</groupId>
    <artifactId>javassist</artifactId>
    <version>3.12.1.GA</version>
  </dependency>
  <dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>fastjson</artifactId>
    <version>1.2.47</version>
  </dependency>
</dependencies>

配置web.xml

<!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app>
  <display-name>Archetype Created Web Application</display-name>
  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath:applicationContext-service.xml</param-value>
  </context-param>
  <listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>
</web-app>

配置applicationContext-service.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:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.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 http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

    <!-- 当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样 -->
    <dubbo:application name="dubbodemo_provider" />
    <!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
    <dubbo:registry address="zookeeper://49.232.169.170:2181"/>

    <!-- 注册 协议和port 端口默认是20880 别和其他服务重复-->
    <dubbo:protocol name="dubbo" port="20885"></dubbo:protocol>
    <!-- 扫描指定包，加入@Service注解的类会被发布为服务 -->
    <dubbo:annotation package="com.itheima.service.impl" />

</beans>

编写服务

服务接口HelloService

package com.itheima.service;

public interface HelloService {
    public String sayHello();
}

服务实现类HelloServiceImpl

注意@Service不是spring的包 而是com.alibaba.dubbo.config.annotation.Service;

package com.itheima.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.itheima.service.HelloService;

@Service
public class HelloServiceImpl implements HelloService {
    public String sayHello() {
        return "hello1-我是web ";
    }
}

[外链图片转存失败,源站可能有防盗链机制,建议将( ttp://img.huitoushian.cn/博客/文章/Dubbo/img/4.jpg)]

[外链图片转存失败,源站可能有防盗]!链机制,建( ttp://img.huitoushian.cn/博客/文章/Dubbo/img/4.jpg)]

然后配置 Tomcat 运行

然后到Dubbo Amin里查看

http://img.huitoushian.cn/博客/文章/Dubbo/img/4.jpg
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-2hDEXi9Q-1631422020448)(http://img.huitoushian.cn/博客/文章/Dubbo/img/4.jpg

Springboot 方式

创建一个普通的Maven项目 项目名称 dubbo-provider-springboot

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-i8bCcM0K-1631421584537)( http://img.huitoushian.cn/博客/文章/Dubbo/img/5.jpg)]

需要的Maven

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.4.RELEASE</version>
    </parent>
    <dependencies>
<!-- 开发 web 项目必须添加的-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- dubbo starter 这里已经集成了zookeeper的客户端jar -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
        <!--fastjson json解析-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.51</version>
        </dependency>
    </dependencies>
    <!-- 自动查找主类 用于打包 -->
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

application.yml

server:
  port: 8062  #Tomcat端口号
dubbo:
  application:
    name:  dubbo-provider-springboot   #当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样
  registry:
    address: 49.232.169.170:2181   # 换成自己的zookeeperip
    protocol: zookeeper  #使用的什么注册中心
    check: false  #检测 zookeeper 是否可用 在开发阶段建议 关掉 false
    timeout: 3000
  protocol:      # 协议和port 端口默认是20880 端口号别和其他服务重复
    name: dubbo
    port: 30003
  monitor:
    protocol: register

服务搭建

User1Service

package com.example.service;

/** * 该地方只定义接口, 一般为公用接口 * 可以定义许多接口; 这里为了演示, 只定义一个 */
public interface User1Service {

    String getUserById();
}

User1ServiceImpl

package com.example.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.example.service.User1Service;
@Service //这里是dubbo的注解, 将接口暴露在外, 可以供调用, 这里就是放在了注册中心
public class User1ServiceImpl implements User1Service {


    @Override
    public String getUserById() {
        return "hello-springboot" ;
    }
}

启动类

package com.example;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

// 开启基于注解的dubbo功能
@EnableDubbo
@SpringBootApplication
public class DubboApplication {

    public static void main(String[] args) {
        SpringApplication.run(DubboApplication.class, args);
    }
}

启动启动类 查询Dubbo Admin

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-M5gXfNqI-1631421584539)( http://img.huitoushian.cn/博客/文章/Dubbo/img/7.jpg)]

以上就是Dubbo的服务搭建了

需要注意的是 如果有实体类的话必须继承 Serializable 进行序列化 因为是网络传输

如何使用这些服务呢? 我们下面将创建消费者 调用这些服务

搭建消费者

创建消费者也有两种方式 spring web 和 springboot

而且这二种 都可以访问 springboot 和spring web 创建的服务

消费者访问 服务提供者的实现类 需要服务者的接口 而且接口的包路径还必须是服务提供者的包路径

spring web方式

创建 Maven web 项目 名称 dubbodemo_consumer

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-xWNnyZIR-1631421584540)( http://img.huitoushian.cn/博客/文章/Dubbo/img/6.jpg)]

添加Maven

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
    <spring.version>5.0.5.RELEASE</spring.version>
  </properties>

  <dependencies>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.11</version>
      <scope>test</scope>
    </dependency>

    <!-- SpringMvc-->
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-web</artifactId>
      <version>${spring.version}</version>
    </dependency>

    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context</artifactId>
      <version>${spring.version}</version>
    </dependency>
      
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-beans</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jdbc</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-aspects</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-jms</artifactId>
      <version>${spring.version}</version>
    </dependency>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-context-support</artifactId>
      <version>${spring.version}</version>
    </dependency>

    <!-- 解析 jsp 和servlet-->
    <dependency>
      <groupId>javax.servlet</groupId>
      <artifactId>javax.servlet-api</artifactId>
      <version>3.1.0</version>
      <scope>provided</scope>
    </dependency>
      
    <dependency>
      <groupId>javax.servlet</groupId>
      <artifactId>jsp-api</artifactId>
      <version>2.0</version>
      <scope>provided</scope>
    </dependency>

    <!-- MVC json 解析-->

    <dependency>
      <groupId>com.fasterxml.jackson.core</groupId>
      <artifactId>jackson-annotations</artifactId>
      <version>2.9.8</version>
    </dependency>

    <dependency>
      <groupId>com.fasterxml.jackson.core</groupId>
      <artifactId>jackson-core</artifactId>
      <version>2.9.8</version>
    </dependency>

    <dependency>
      <groupId>com.fasterxml.jackson.core</groupId>
      <artifactId>jackson-databind</artifactId>
      <version>2.9.8</version>
    </dependency>

    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>fastjson</artifactId>
      <version>1.2.68</version>
    </dependency>
    <!-- dubbo相关 -->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.0</version>
    </dependency>

    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.9</version>
    </dependency>
    <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
    </dependency>
    <dependency>
      <groupId>javassist</groupId>
      <artifactId>javassist</artifactId>
      <version>3.12.1.GA</version>
    </dependency>

  </dependencies>

web.xml

<!DOCTYPE web-app PUBLIC "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN" "http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app>
  <display-name>Archetype Created Web Application</display-name>
  <servlet>
    <servlet-name>springmvc</servlet-name>
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <!-- 指定加载的配置文件 ，通过参数contextConfigLocation加载 -->
    <init-param>
      <param-name>contextConfigLocation</param-name>
      <param-value>classpath:applicationContext-web.xml</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>springmvc</servlet-name>
    <url-pattern>/</url-pattern>
  </servlet-mapping>
</web-app>

applicationContext-web.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:p="http://www.springframework.org/schema/p" xmlns:context="http://www.springframework.org/schema/context" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" 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/mvc http://www.springframework.org/schema/mvc/spring-mvc.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">

    <!-- 当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样 -->
    <dubbo:application name="dubbodemo-consumer" />
    <!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
    <dubbo:registry address="zookeeper://49.232.169.170:2181"/>
    <!-- 扫描的方式暴露接口 -->
    <dubbo:annotation package="com.itheima.controller" />

<!--启动时检查 (关闭 ) 建议在开发阶段将check值设置为false，在生产环境下改为true。 -->
    <dubbo:consumer check="false"/>


    <!--注解适配器 设置 @ResponseBody 和 @RequestBody 的请求 和响应 的模式 防止中文乱码-->
    <bean class="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter">
        <property name="messageConverters">
            <list>
                <bean id="stringHttpMessageConverter" class="org.springframework.http.converter.StringHttpMessageConverter">
                    <property name="supportedMediaTypes">
                        <list>
                            <value>text/plain;charset=UTF-8</value>
                            <value>text/html;charset=UTF-8</value>
                            <value>application/json;charset=UTF-8</value>
                        </list>
                    </property>
                </bean>
                <bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter">
                    <property name="supportedMediaTypes">
                        <list>
                            <value>text/plain;charset=UTF-8</value>
                            <value>text/html;charset=UTF-8</value>
                            <value>application/json;charset=UTF-8</value>
                        </list>
                    </property>
                </bean>
            </list>
        </property>

    </bean>

</beans>

服务提供者的接口

HelloService

package com.itheima.service;

public interface HelloService {
    public String sayHello();
}

User1Service

package com.example.service;

/** * 该地方只定义接口, 一般为公用接口 * 可以定义许多接口; 这里为了演示, 只定义一个 */
public interface User1Service {

    String getUserById();
}

controller

HelloController

package cn.consumer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.example.service.User1Service;
import com.itheima.service.HelloService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/demo")
public class HelloController {
    @Reference
    private HelloService helloService;
    @Reference   
    private User1Service user1Service;

        @GetMapping("/hello")
        @ResponseBody
        public String getName(){
            //远程调用
            String result = helloService.sayHello();
            System.out.println(result);
            return result;
        }

        @GetMapping("/user")
        @ResponseBody
        public String getName1(){
            //远程调用
            String result = user1Service.getUserById();
            System.out.println(result);
            return result;
        }

}

然后配置Tomcat启动 (注意 端口号别一样 我是这个消费者Tomcat端口是8083)

查看Dubbo Admin

可以看到每个 服务都是正常的

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-6gOszO4x-1631421584541)( http://img.huitoushian.cn/博客/文章/Dubbo/img/8.jpg)]

进入每个服务里

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-NWXzvf2q-1631421584543)( http://img.huitoushian.cn/博客/文章/Dubbo/img/9.jpg)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-pFyIO9f1-1631421584544)( http://img.huitoushian.cn/博客/文章/Dubbo/img/10.jpg)]

一个消费者 获取2个服务 提供者

在浏览器输入http://localhost:8083/demo/hello，查看浏览器输出结果

在浏览器输入http://localhost:8083/demo/user，查看浏览器输出结果

Springboot方式

创建一个普通的Maven项目 名称 dubbodemo-consumer-springboot

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-rycG4yRQ-1631421584545)( http://img.huitoushian.cn/博客/文章/Dubbo/img/11.jpg)]

添加Maven (和服务提供者一样)

<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.4.RELEASE</version>
    </parent>
    <dependencies>
        <!-- 开发 web 项目必须添加的-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <!-- dubbo starter 这里已经集成了zookeeper的客户端jar -->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
        <!--fastjson json解析-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.51</version>
        </dependency>

<!-- 使用 thymeleaf 模板引擎-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
            <version>2.2.2.RELEASE</version>
        </dependency>

    </dependencies>
    <!-- 自动查找主类 用于打包 -->
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

application.yml

server:
  port: 8068  
dubbo:
  application:
    name:  dubbo-consumer-springboot   #当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样
  registry:
    address: 49.232.169.170:2181   # 换成自己的zookeeperip
    protocol: zookeeper  #使用的什么注册中心
    check: false   #检测 zookeeper 是否可用 在开发阶段建议 关掉 false
    timeout: 3000  
  monitor:
    protocol: register
  consumer:   #检测服务 是否可用 在开发阶段建议 关掉 false
    check:  false
    timeout: 3000

添加服务提供者的接口

HelloService

package com.itheima.service;

public interface HelloService {
    public String sayHello();
}

User1Service

package com.example.service;

/** * 该地方只定义接口, 一般为公用接口 * 可以定义许多接口; 这里为了演示, 只定义一个 */
public interface User1Service {

    String getUserById();
}

添加controller

package cn.consumer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.example.service.User1Service;
import com.itheima.service.HelloService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

@Controller
@RequestMapping("/demo")
public class HelloController {
    @Reference
    private HelloService helloService;
    @Reference
    private User1Service user1Service;

        @GetMapping("/hello")
        @ResponseBody
        public String getName(){
            //远程调用
            String result = helloService.sayHello();
            System.out.println(result);
            return result;
        }

        @GetMapping("/user")
        @ResponseBody
        public String getName1(){
            //远程调用
            String result = user1Service.getUserById();
            System.out.println(result);
            return result;
        }

}

启动类

DubboApplication

package cn.consumer;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

// 开启基于注解的dubbo功能
@EnableDubbo
@SpringBootApplication
public class DubboApplication  {

    public static void main(String[] args) {
        SpringApplication.run(DubboApplication.class, args);
    }
}

启动启动类

查看Dubbo Admin 现在为止应该有2个服务 和 2个消费者 而且每一个消费者都对应着2个服务

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-6dYZnkoR-1631421584546)( http://img.huitoushian.cn/博客/文章/Dubbo/img/12.jpg)]

我们进入消费者服务里 可以看到 对应的 2个服务提供的接口

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-T6WPGP0J-1631421584547)( http://img.huitoushian.cn/博客/文章/Dubbo/img/13.jpg)]

在浏览器输入http://localhost:8068/demo/hello，查看浏览器输出结果

在浏览器输入http://localhost:8068/demo/user，查看浏览器输出结果

Dubbo相关配置说明

yml 和 xml 意思都一样 我们以xml 来解释

包扫描(配合注解)

<dubbo:annotation package="com.itheima.service" />

在Springboot 的启动类上 添加 @EnableDubbo 就代替上面的

服务提供者和服务消费者都需要配置，表示包扫描，作用是扫描指定包(包括子包)下的类。

配合Dubbo的 @Service 生成服务

协议

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

一般在服务提供者一方配置，可以指定使用的协议名称和端口号。

其中Dubbo支持的协议有：dubbo、rmi、hessian、http、webservice、rest、redis等。

推荐使用的是dubbo协议。

dubbo 协议采用单一长连接和 NIO 异步通讯，适合于小数据量大并发的服务调用，以及服务消费者机器数远大于服务提供者机器数的情况。不适合传送大数据量的服务，比如传文件，传视频等，除非请求量很低。

也可以在同一个工程中配置多个协议，不同服务可以使用不同的协议，

但是需要添加各个协议的Maven支持 自己到网上查询

例如：

<!-- 多协议配置 -->
<dubbo:protocol name="dubbo" port="20880" />
<dubbo:protocol name="rmi" port="1099" />
<!-- 使用dubbo协议暴露服务 -->
<dubbo:service interface="com.itheima.api.HelloService" ref="helloService" protocol="dubbo" />
<!-- 使用rmi协议暴露服务 -->
<dubbo:service interface="com.itheima.api.DemoService" ref="demoService" protocol="rmi" />

在Springboot里也能配置多个协议 但是需要添加各个协议的Maven 自己上百度

配置也有所变化 原来的 protocol 换成 protocols

dubbo:
  # 定义两个协议 dubbo，rest（使用jetty作为服务器）
  protocols:
    dubbo:
      name: dubbo
      port: 20880
    rest:
      name: rest
      port: 9999
      server: jetty

但是调用方式都一样 在使用的类上

@Service(protocol = "协议")

在Springboot里 有两种 Dubbo 但是效果一样

<dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>

这一种使用的是 @Service

<dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>

这一种使用的是 @DubboService

启动时检查

<dubbo:consumer check="false"/>

面这个配置需要配置在消费者一方，如果不配置默认check值为true。Dubbo 缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止 Spring 初始化完成，以便上线时，能及早发现问题。可以通过将check值改为false来关闭检查。

建议在开发阶段将check值设置为false，在生产环境下改为true。

负载均衡

特别特别简单 有两种方式 第一种在代码里配置 第二种是在 Dubbo Amin 里配置 而我们选择第二种方式

进入DubboAdmin 里

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-KWlBouIA-1631421584548)( http://img.huitoushian.cn/博客/文章/Dubbo/img/14.png)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-uOgGIz3q-1631421584549)( http://img.huitoushian.cn/博客/文章/Dubbo/img/15.jpg)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-mdu3QW5g-1631421584550)( http://img.huitoushian.cn/博客/文章/Dubbo/img/16.jpg)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-kAqYHqPz-1631421584551)( http://img.huitoushian.cn/博客/文章/Dubbo/img/17.jpg)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-WM0KjUhZ-1631421584552)( http://img.huitoushian.cn/博客/文章/Dubbo/img/18.jpg)]
1.
在创建一个相同的服务配置代码全部都相同 除了 [ Tomcat端口号,Dubbo服务的端口号]

spirngweb 和 Springboot 一样 我们以Springboot 举例 因为好创建

创建普通Maven项目 名称为 dubbo-provide-springboot1
1.
将dubbo-provide-springboot里的代码和配置文件全部复制到dubbo-provide-springboot1里
1.
修改dubbo-provide-springboot1 里的application.yml (Tomcat 端口号 和Dubbo端口 )

server:
  port: 8072
  
dubbo:
  protocol:     # 协议和port 端口默认是20880
    name: dubbo
    port: 30323

修改User1ServiceImpl里的代码 (主要是测试负载均衡 区分)

@Override
    public String getUserById() {
        return "hello-springboot1" ;
    }

启动Stringboot 的启动类
1.
查看DubboAmdin

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-IV8jYQV0-1631421584554)( http://img.huitoushian.cn/博客/文章/Dubbo/img/19.jpg)]

我们来访问 com.example.service.User1Service 这个服务

在浏览器输入http://localhost:8068/demo/user， 查看浏览器输出结果 (多次访问)

可以发现 游览器 结果 在 hello-springboot1 和 hello-springboot 来回切换 这样就代表 负载均衡成功

解决Dubbo无法发布被事务代理的Service问题

前面我们已经完成了Dubbo的入门案例，通过入门案例我们可以看到通过Dubbo提供的标签配置就可以进行包扫描，扫描到@Service注解的类就可以被发布为服务。

但是我们如果在服务提供者类上加入@Transactional事务控制注解后，服务就发布不成功了。原因是事务控制的底层原理是为服务提供者类创建代理对象，而默认情况下Spring是基于JDK动态代理方式创建代理对象，而此代理对象的完整类名为com.sun.proxy.$Proxy42（最后两位数字不是固定的），导致Dubbo在发布服务前进行包匹配时无法完成匹配，进而没有进行服务的发布。

解决方式操作步骤：

（1）修改applicationContext-service.xml配置文件，开启事务控制注解支持时指定proxy-target-class属性，值为true。其作用是使用cglib代理方式为Service类创建代理对象

<!--开启事务控制的注解支持-->
<tx:annotation-driven transaction-manager="transactionManager" proxy-target-class="true"/>

（2）修改HelloServiceImpl类，在Service注解中加入interfaceClass属性，值为HelloService.class，作用是指定服务的接口类型

此处也是必须要修改的，否则会导致发布的服务接口为SpringProxy，而不是HelloService接口

@Service(interfaceClass = HelloService.class)
@Transactional
public class HelloServiceImpl implements HelloService {
    public String sayHello(String name) {
        return "hello " + name;
    }
}

如果是Springboot 的话 就没必要 因为 Springboot2x 默认使用的就是 cglib代理方式

但是在使用类上添加指定接口还是需要的

@Service(interfaceClass = HelloService.class)

解决上面案例中问题

/*/思考一：//*上面的Dubbo入门案例中我们是将HelloService接口从服务提供者工程(dubbodemo_provider)复制到服务消费者工程(dubbodemo_consumer)中，这种做法是否合适？还有没有更好的方式？

/*/答：//*这种做法显然是不好的，同一个接口被复制了两份，不利于后期维护。更好的方式是单独创建一个maven工程 然后打包进入Maven仓库里，需要依赖此接口的工程只需要在自己工程的pom.xml文件中引入maven坐标即可。

/*/思考二：//*在服务消费者工程(dubbodemo_consumer)中只是引用了HelloService接口，并没有提供实现类，Dubbo是如何做到远程调用的？

/*/答：//*Dubbo底层是基于代理技术为HelloService接口创建代理对象，远程调用是通过此代理对象完成的。另外，Dubbo实现网络传输底层是基于Netty框架完成的。

/*/思考三：//*上面的Dubbo入门案例中我们使用Zookeeper作为服务注册中心，服务提供者需要将自己的服务信息注册到Zookeeper，服务消费者需要从Zookeeper订阅自己所需要的服务，此时Zookeeper服务就变得非常重要了，那如何防止Zookeeper单点故障呢？

/*/答：//*Zookeeper其实是支持集群模式的，可以配置Zookeeper集群来达到Zookeeper服务的高可用，防止出现单点故障。

Zookeeper集群

超级简单的 只需要在其他服务器上在安装二个 Zookeeper 就行了 因为最低三台才能集群否则

No server failure will be tolerated. You need at least 3 servers

导致你一直启动不成功

我们在虚拟机上 使用docker 来演示

  • –network host: 使用主机上的网络配置，如果不用这种模式，而用默认的bridge模式，会导致容器跨主机间通信失败

没条件的在多个虚拟机上安装也行

序号服务与端口
1192.168.66.67
2192.168.66.68
3192.168.66.69

创建挂载

mkdir -p /root/zookeeper/conf  /root/zookeeper/data

在conf创建配置文件

vi   /root/zookeeper/conf/zoo.cfg
clientPort=2181 
dataDir=/data 
dataLogDir=/data/log 
tickTime=3000 
initLimit=5 
syncLimit=2 
autopurge.snapRetainCount=3
autopurge.purgeInterval=0 
maxClientCnxns=60
server.111=192.168.66.67:2888:3888
server.222=192.168.66.68:2888:3888
server.333=192.168.66.69:2888:3888

autopurge.snapRetainCount 对应你集群的数量

然后在每个节点的 dataDir指定的目录下 创建myid文件

cd /root/zookeeper/data

touch myid && echo 111 > myid

注意 这个数字111 必须对应zoo.cfg的配置文件的 server.111 也就是 192.168.66.67这台主机

要是数字222的话，就是要在192.168.66.68 这台主机上编辑myid文件 …

touch myid && echo 222 > myid

192.168.66.69

touch myid && echo 333 > myid

拉取镜像

docker pull zookeeper:3.4.9

创建容器

docker run  --network host \
-v /root/zookeeper/data:/data \
-v /root/zookeeper/conf:/conf \
--restart=always \
--privileged=true \
--name zookeeper -d zookeeper:3.4.9

查看 docker logs zookeeper

这里注意必须全部的节点都搭建完成后 而且都能通过命令进入到容器里

docker exec -it zookeeper /bin/bas

否则只要有一个节点没有成功那么 检测运行状态状态 就会出现

JMX enabled by default
Using config: /opt/zookeeper/zookeeper-3.4.5/bin/../conf/zoo.cfg
Error contacting service. It is probably not running.

如果以上都没问题 那么 稍等一会 1分钟 (让服务之间进行通信)

然后 随便进入一个容器里 检查zookeeper运行情况 进入容器

docker exec -it zookeeper /bin/bash

cd /zookeeper-3.4.9/bin

./zkServer.sh status

如果是主节点 那么会显示 leader 子节点会显示 follower 这个由Zookeeper自行选择

如果显示 standalone 那么就代表你集群没搭建成功

开放 每个节点的 2181 2888 3888 端口 或者直接将 防火墙给关了 (重要)

以上配置完了 关闭Zookeeper 然后从新启动 容器的话重启容器

端口说明：

1、2181：对cline端提供服务

2、3888：用来选举leader的端口

3、2888：集群内机器通讯使用（Leader监听此端口）

如果一直出现

Error contacting service. It is probably not running.

检测 myid 有没有顺序配置错误 检测挂载的 zoo.cfg文件内容有没有复制的时候漏掉什么东西

搭建zookeeper集群后DubboAdmin客户端 到底连接谁?

这个也很好理解 集群分为主节点和 子节点 我们DubboAdmin客户端 连接zookeeper的主节点( leader) 就行

下 创建myid文件//

cd /root/zookeeper/data

touch myid && echo 111 > myid

注意 这个数字111 必须对应zoo.cfg的配置文件的 server.111 也就是 192.168.66.67这台主机

要是数字222的话，就是要在192.168.66.68 这台主机上编辑myid文件 …

touch myid && echo 222 > myid

192.168.66.69

touch myid && echo 333 > myid

拉取镜像

docker pull zookeeper:3.4.9

创建容器

docker run  --network host \
-v /root/zookeeper/data:/data \
-v /root/zookeeper/conf:/conf \
--restart=always \
--privileged=true \
--name zookeeper -d zookeeper:3.4.9

查看 docker logs zookeeper

这里注意必须全部的节点都搭建完成后 而且都能通过命令进入到容器里

docker exec -it zookeeper /bin/bas

否则只要有一个节点没有成功那么 检测运行状态状态 就会出现

JMX enabled by default
Using config: /opt/zookeeper/zookeeper-3.4.5/bin/../conf/zoo.cfg
Error contacting service. It is probably not running.

如果以上都没问题 那么 稍等一会 1分钟 (让服务之间进行通信)

然后 随便进入一个容器里 检查zookeeper运行情况 进入容器

docker exec -it zookeeper /bin/bash

cd /zookeeper-3.4.9/bin

./zkServer.sh status

如果是主节点 那么会显示 leader 子节点会显示 follower 这个由Zookeeper自行选择

如果显示 standalone 那么就代表你集群没搭建成功

开放 每个节点的 2181 2888 3888 端口 或者直接将 防火墙给关了 (重要)

以上配置完了 关闭Zookeeper 然后从新启动 容器的话重启容器

端口说明：

1、2181：对cline端提供服务

2、3888：用来选举leader的端口

3、2888：集群内机器通讯使用（Leader监听此端口）

如果一直出现

Error contacting service. It is probably not running.

检测 myid 有没有顺序配置错误 检测挂载的 zoo.cfg文件内容有没有复制的时候漏掉什么东西

搭建zookeeper集群后DubboAdmin客户端 到底连接谁?

这个也很好理解 集群分为主节点和 子节点 我们DubboAdmin客户端 连接zookeeper的主节点( leader) 就行
点赞 -收藏-关注-便于以后复习和收到最新内容有其他问题在评论区讨论-或者私信我-收到会在第一时间回复如有侵权，请私信联系我感谢,配合,希望我的努力对你有帮助^_^

版权说明 : 本文为转载文章, 版权归原作者所有 版权申明

原文链接 : https://blog.csdn.net/weixin_45203607/article/details/120249335

内容来源于网络，如有侵权，请联系作者删除！

Javazookeeperspring bootdubbossm

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com