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

x33g5p2x  于11个月前 转载在 Spring  
字(32.2k)|赞(0)|评价(0)|浏览(92)

介绍

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) 就行
点赞 -收藏-关注-便于以后复习和收到最新内容有其他问题在评论区讨论-或者私信我-收到会在第一时间回复如有侵权,请私信联系我感谢,配合,希望我的努力对你有帮助^_^

相关文章