Dubbo

小总结

springboot，mybatis，dubbo+zookeep，三层架构开发

大概思路布局

接口
    实体类
    service接口

提供者
    mapper.java（接口）
    mapper.xml（mybatisSQL语句）
    service实现类
    
消费者
    webController.java
    index.html

service层

Application启动文件执行以下添加以下

@SpringBootApplication  //springboot标签
@MapperScan("io.peng.mapper")   //扫描mapper文件夹
@EnableDubboConfiguration   //启动dubbo注解

---
application.properties配置文件文件添加以下

#设置服务端口号
server.port=8081
#设置上下文根
server.servlet.context-path=/

#链接数据库
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://127.0.0.1:3306/air
spring.datasource.username=root
spring.datasource.password=123456

#扫描xml文件路径
mybatis.mapper-locations=classpath:/mapper/*Mapper.xml
#mapper别名
mybatis.type-aliases-package=io.peng.money.model

#配置 Dubbo 的服务提供者名称
spring.application.name=airservice
#设置工程为服务提供者
spring.dubbo.server=true
#设置 dubbo 注册中心
spring.dubbo.registry=zookeeper://localhost:2181

#redis
spring.redis.host=localhost
spring.redis.port=6379

---
实现接口添加以下
@Component  //让spring实例化
// 使用dubbo的service，让他托管
@Service(interfaceClass = xxxxxService.class,version = "1.0.0",timeout = 15000)
public class XXXXXXXX

Controller层

Application启动文件执行以下添加以下

@SpringBootApplication  //springboot标签
@EnableDubboConfiguration   //启动dubbo注解

---
application.properties配置文件添加以下
server.port=8080    //端口
spring.application.name=web //名字
// 注册中心
spring.dubbo.registry=zookeeper://localhost:2181

---
web需要加这些
@RestController
public class xxxxxxController {
    @Reference(interfaceClass=AirQualityIndexServer.class,version="1.0.0")
    private XXXXService XXXXService;

    xxxx
}

开源地址

https://github.com/apache/dubbo

接口工程

使用SpringBoot搭建基于SSM的分布式框架。按照dubbo官方的推荐，一个基于dubbo的微服务项目至少包含三个模块。接口模块，生产者模块，消费者模块。

搭建Maven的java工程——dubbo接口

一.导入工程的核心包

<dependencies>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.11</version>
      <scope>test</scope>
    </dependency>
  </dependencies>
  <build>
    <pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->
      <plugins>
        <plugin>
          <artifactId>maven-compiler-plugin</artifactId>
          <version>3.8.0</version>
          <configuration>
            <target>1.8</target>
            <source>1.8</source>
          </configuration>
        </plugin>
      </plugins>
    </pluginManagement>
  </build>
</project>

搭建提供者项目

创建基于SpringBoot的提供者web项目，提供数据服务

导入MyBatis，dubbo,以及zookeeper等核心依赖

<dependencies>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-web</artifactId>
       </dependency>
       <dependency>
           <groupId>org.mybatis.spring.boot</groupId>
           <artifactId>mybatis-spring-boot-starter</artifactId>
           <version>2.1.4</version>
       </dependency>

       <dependency>
           <groupId>mysql</groupId>
           <artifactId>mysql-connector-java</artifactId>
           <scope>runtime</scope>
       </dependency>
       <!--springboot集成dubbo-->
       <dependency>
           <groupId>com.alibaba.spring.boot</groupId>
           <artifactId>dubbo-spring-boot-starter</artifactId>
           <version>2.0.0</version>
       </dependency>
        <!--zookeeper客户端依赖-->
       <dependency>
           <groupId>com.101tec</groupId>
           <artifactId>zkclient</artifactId>
           <version>0.10</version>
       </dependency>
       <!--myincema服务接口依赖-->
       <dependency>
           <groupId>com.powernode</groupId>
           <artifactId>mycinema-interface</artifactId>
           <version>1.0.0</version>
       </dependency>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-test</artifactId>
           <scope>test</scope>
       </dependency>
   </dependencies>

配置application.properties/yml，设置数据库连接，dubbo服务等信息

#数据库信息
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/mycinema?serverTimezone=UTC
spring.datasource.username=root
spring.datasource.password=

#设置内嵌 Tomcat 端口号
server.port=8090
#设置上下文根
server.servlet.context-path=/

#配置 dubbo 的服务提供者信息
#服务提供者应用名称(必须写，且不能重复)
spring.application.name=mycinema-provider
#设置当前工程为服务提供者
spring.dubbo.server=true
#设置注册中心
spring.dubbo.registry=zookeeper://localhost:2181

使用逆向工程生成实体类

数据访问接口，以及sql-mapper映射文件

• 在pom的中添加MyBatis逆向工程的插件

  <!--mybatis代码自动生成插件-->
  <plugin>
      <groupId>org.mybatis.generator</groupId>
      <artifactId>mybatis-generator-maven-plugin</artifactId>
      <version>1.3.7</version>
      <configuration>
          <!--配置文件的位置-->
          <configurationFile>GeneratorMapper.xml</configurationFile>
          <verbose>true</verbose>
          <overwrite>true</overwrite>
      </configuration>
  </plugin>

• 在项目的根目录下面添加插件的配置文件GeneratorMapper.xml，内容如下:

  <?xml version="1.0" encoding="UTF-8"?>
  <!DOCTYPE generatorConfiguration
          PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
          "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
  
  <generatorConfiguration>
      <!-- 指定连接数据库的JDBC驱动包所在位置，指定到你本机的完整路径 -->
      <classPathEntry location="C:\repository\mysql\mysql-connector-java\5.1.6\mysql-connector-java-5.1.6.jar"/>
      <!-- 配置table表信息内容体，targetRuntime指定采用MyBatis3的版本 -->
      <context id="tables" targetRuntime="MyBatis3">
  
          <!-- 抑制生成注释，由于生成的注释都是英文的，可以不让它生成 -->
          <commentGenerator>
              <property name="suppressAllComments" value="true" />
          </commentGenerator>
  
          <!-- 配置数据库连接信息 -->
          <jdbcConnection driverClass="com.mysql.jdbc.Driver"
                          connectionURL="jdbc:mysql://127.0.0.1:3306/mycinema"
                          userId="root"
                          password="">
          </jdbcConnection>
  
          <!-- 生成model类，targetPackage指定model类的包名， 
              targetProject指定生成的model放在接口工程下面-->
          <javaModelGenerator targetPackage="com.powernode.model"
                              targetProject="E:\mycinema-interface\src\main\java">
              <property name="enableSubPackages" value="false" />
              <property name="trimStrings" value="false" />
          </javaModelGenerator>
  
          <!-- 生成MyBatis的Mapper.xml文件，targetPackage指定mapper.xml文件的包名， 
          targetProject指定生成的mapper.xml放在当前工程src -->
          <sqlMapGenerator targetPackage="com.powernode.mapper"                targetProject="src/main/java">
              <property name="enableSubPackages" value="false" />  
          </sqlMapGenerator>
  
          <!-- 生成MyBatis的Mapper接口类文件,targetPackage指定Mapper接口类的包名， 
          targetProject指定生成的Mapper接口放当前工程src目录 -->
          <javaClientGenerator type="XMLMAPPER" targetPackage="com.powernode.mapper"    targetProject="src/main/java">
              <property name="enableSubPackages" value="false" />
          </javaClientGenerator>
  
          <!-- 数据库表名及对应的Java模型类名 -->
          <table tableName="category" domainObjectName="Category"
              enableCountByExample="false"
              enableUpdateByExample="false"
              enableDeleteByExample="false"
              enableSelectByExample="false"
              selectByExampleQueryId="false"/>
          <table tableName="movie" domainObjectName="Movie"
              enableCountByExample="false"
              enableUpdateByExample="false"
              enableDeleteByExample="false"
              enableSelectByExample="false"
              selectByExampleQueryId="false"/>
  
          <table tableName="user" domainObjectName="User"
              enableCountByExample="false"
              enableUpdateByExample="false"
              enableDeleteByExample="false"
              enableSelectByExample="false"
              selectByExampleQueryId="false"/>
      </context>
  </generatorConfiguration>

• 在maven窗口中执行插件，生成代码
  注意：执行插件时，会解析pom文件中的所有依赖，已经导入了的依赖，所以会去本地仓库查找这个包，找不到就会报错。解决方法如下:
  1.可以先注释这个包依赖，等生成代码之后再添加
  2.将mycinema-interface项目打包安装到本地仓库mvn install
  3.将生成的实体类都实现序列化接口,用于远程传输数据

  public class Movie implements Serializable {

• 插件生成的Mapper.xml文件和Mapper接口在同一个包下，但是idea不会编译，需要手动指定资源文件，修改

提供者mycinema-provider的pom.xml文件，手动指定资源路径

<resources>
    <resource>
        <directory>src/main/java</directory>
        <includes>
            <include>**/*.xml</include>
        </includes>
    </resource>
</resources>

• 在服务接口工程mycinema-interface工程中添加接口内容

  public interface CategoryService {
      List<Category> getAll();
      Category getById(Integer id);
  }
  public interface MovieService {
      List<Movie> getAll();
      Movie getById(Integer id);
  }

• 在提供者工程mycinema-provider中创建业务的实现包service.impl实现业务接口，并添加业务注解

@Component,dubbo服务注解@Service

@Component
@Service(interfaceClass = MovieService.class,version = "1.0.0",timeout = 15000)
public class MovieServiceImpl implements MovieService {  
    @Autowired    private MovieMapper movieMapper;  
    @Override    public List<Movie> getAll() {   
        return movieMapper.selectAll();   
    }   
    @Override    public Movie getById(Integer id) { 
        return movieMapper.selectByPrimaryKey(id);   
    }
}

@Component
@Service(interfaceClass = CategoryService.class,timeout = 15000,version = "1.0.0")
public class CategoryServiceImpl implements CategoryService { 
    @Autowired    private CategoryMapper categoryMapper; 
    @Override    public List<Category> getAll() {  
        return categoryMapper.selectAll();   
    } 
    @Override    public Category getById(Integer id) {  
        return categoryMapper.selectByPrimaryKey(id);   
    }
}

• 在启动类上开启dubbo配置支持注解

  @SpringBootApplication
  @MapperScan("com.powernode.mapper") 
  //扫描数据访问接口
  @EnableDubboConfiguration //开启dubbo注解支持
  public class MycinemaProviderApplication {  
      public static void main(String[] args) {   
          SpringApplication.run(MycinemaProviderApplication.class, args);    
      }
  }

• 开启zooker服务，启动提供者项目

创建服务消费者项目

mycinema-consumer

创建基于SpringBoot的web项目，添加以下必要的依赖

<dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-web</artifactId>
   </dependency>
   <!--dubbo依赖-->
   <dependency>
       <groupId>com.alibaba.spring.boot</groupId>
       <artifactId>dubbo-spring-boot-starter</artifactId>
       <version>2.0.0</version>
   </dependency>
   <!--zookeeper客户端依赖-->
   <dependency>
       <groupId>com.101tec</groupId>
       <artifactId>zkclient</artifactId>
       <version>0.10</version>
   </dependency>
   <!--服务接口依赖-->
   <dependency>
       <groupId>com.powernode</groupId>
       <artifactId>mycinema-interface</artifactId>
       <version>1.0.0</version>
   </dependency>

修改application.properties添加配置信息

#设置内嵌 Tomcat 端口号
server.port=8080
#设置上下文根
server.servlet.context-path=/
#设置 dubbo 配置
#设置服务消费者名称
spring.application.name=mycinema-consumer
#配置 dubbo 注册中心
spring.dubbo.registry=zookeeper://localhost:2181

添加Controller，依赖服务提供者提供的服务信息

@Controller
public class IndexController {
    //组件由dubbo提供，使用@Reference注解
    @Reference(interfaceClass = MovieService.class,version = "1.0.0",check = false)
    private MovieService movieService;

    @RequestMapping("/findAll")
    @ResponseBody
    public List<Movie> findAll(){
        return movieService.getAll();
    }
}

测试

集成Thymeleaf实现同步请求

一.添加Thymeleaf坐标

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-thymeleaf</artifactId>
</dependency>

二.添加视图配置

spring.thymeleaf.suffix=.html
spring.thymeleaf.prefix=classpath:/templates/

三.编写控制器

@GetMapping("/index")
  public String index(Model model){
      model.addAttribute("movies",movieService.getAll());
      return "index";
  }

四.在templates下面添加index.html

<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
    <table>
        <tr><td>编号</td><td>名称</td><td>导演</td><td>日期</td></tr>
        <tr th:each="movie:${movies}">
            <td th:text="${movie.id}"></td>
            <td th:text="${movie.title}"></td>
            <td th:text="${movie.director}"></td>
            <td th:text="${movie.datereleased}"></td>
        </tr>
    </table>
</body>
</html>

Dubbo监控中心

开源地址：https://github.com/apache/dubbo-admin

Dubbo是一个分布式服务框架，能避免单点故障和支持服务的横向扩容。一个服务通常会部署多个实例。
如何从多个服务 Provider 组成的集群中挑选出一个进行调用，就涉及到一个负载均衡的策略。

新版控制中心前后端分离了！！！
1.下载源代码
2.进入dubbo-admin-server，打包
mvn clean package
3.启动zookeeper
4.启动dubbo-admin-server,端口http:8080
java -jar dubbo-admin-server…jar
5.进入dubbo-admin-ui
下载js包
npm install
6.编译执行 npm run dev
7.http://localhost:8082