第一个Dubbo分布式项目

Dubbo项目结构：

provider：dubbo项目的提供者，注册服务在dubbo。

提供查询部门信息（dept）功能、新增员工功能、查询员工功能。

dept和emp属于consumer（消费者）：

消费者调用查询所有部门信息的功能、根据员工Id查询员工的功能、查询所有员工的功能、添加某个员工的功能。

api：提供服务调用接口。

mapper：对数据库进行持久化操作，实现数据库信息的更新。

pojo：实体类模块。

一：创建父项目Parent

创建Parent项目并在pom文件导入父项目依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>Parent</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>pojo</module>
        <module>api</module>
        <module>mapper</module>
        <module>provider</module>
        <module>dept</module>
        <module>emp</module>
    </modules>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
    </properties>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.1.10.RELEASE</version>
    </parent>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
                <version>2.1.10.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>2.1.10.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-thymeleaf</artifactId>
                <version>2.1.10.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>2.7.3</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-recipes</artifactId>
                <version>4.2.0</version>
            </dependency>
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>4.2.0</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.1.1</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>8.0.29</version>
            </dependency>
            <dependency>
                <groupId>commons-io</groupId>
                <artifactId>commons-io</artifactId>
                <version>2.6</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

</project>

二：创建pojo子项目

创建两个实体类dept和emp并实现Serializable接口。

Dept实体类：

package com.example.pojo;

import java.io.Serializable;

public class Dept implements Serializable {

    private Integer id;
    private String name;

    public Dept() {
    }

    public Dept(Integer id, String name) {
        this.id = id;
        this.name = name;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "Dept{" +
                "id=" + id +
                ", name='" + name + '\'' +
                '}';
    }
}

Emp实体类：

package com.example.pojo;

import java.io.Serializable;

public class Emp implements Serializable {

    private Integer id;
    private String name;
    private String photo;
    private Integer did;

    public Emp() {
    }

    public Emp(Integer id, String name, String photo, Integer did) {
        this.id = id;
        this.name = name;
        this.photo = photo;
        this.did = did;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getPhoto() {
        return photo;
    }

    public void setPhoto(String photo) {
        this.photo = photo;
    }

    public Integer getDid() {
        return did;
    }

    public void setDid(Integer did) {
        this.did = did;
    }

    @Override
    public String toString() {
        return "Emp{" +
                "id=" + id +
                ", name='" + name + '\'' +
                ", photo='" + photo + '\'' +
                ", did=" + did +
                '}';
    }
}

三：创建api接口项目

创建DeptDubboService和EmpDubboService，为provider提供接口

package com.example.dubbo.service;

import com.example.pojo.Dept;


import java.util.List;

public interface DeptDubboService {

    List<Dept> findAllDept();

}

package com.example.dubbo.service;

import com.example.pojo.Emp;

import java.util.List;

public interface EmpDubboService {

    int insertEmp(Emp emp);

    List<Emp> findEmpByDeptId(Integer did);
}

四：创建mapper持久层项目

创建DeptMapper接口和对应的DeptMapper.xml配置文件、Empapper接口和EmpMapper.xml配置文件。这两个比较简单，重点在mapper的application-mybatis.yml配置文件的编写。

application-mybatis.xml文件：连接数据库的四要素+配置扫描实体类的路径

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: root
    url: jdbc:mysql://localhost:3306/mytest?useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&allowPublicKeyRetrieval=true
mybatis:
  mapper-locations: classpath:mybatis/*.xml
  type-aliases-package: com.example.pojo

五：创建provider

子项目

1）provider的启动类

注：不要忘记EnableDubbo注解和MapperScan扫描mapper的注解

package com.example;

import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableDubbo
@MapperScan("com.example.mapper")
public class ProviderApplication {

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

2）编写两个DubboService的实现类

（实现的是api的接口）

DeptDubboServiceImpl实现类

package com.example.dubbo.service.impl;

import com.example.dubbo.service.DeptDubboService;
import com.example.mapper.DeptMapper;
import com.example.pojo.Dept;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.List;

@Service
public class DeptDubboServiceImpl implements DeptDubboService {

    @Autowired
    private DeptMapper deptMapper;

    @Override
    public List<Dept> findAllDept() {
        return deptMapper.findAll();
    }

}

EmpSubboServiceImpl实现类

package com.example.dubbo.service.impl;

import com.example.dubbo.service.EmpDubboService;
import com.example.mapper.EmpMapper;
import com.example.pojo.Emp;
import org.apache.dubbo.config.annotation.Service;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.List;

@Service
public class EmpDubboServiceImpl implements EmpDubboService {

    @Autowired
    private EmpMapper empMapper;

    @Override
    public int insertEmp(Emp emp) {
        return empMapper.insertEmp(emp);
    }

    @Override
    public List<Emp> findEmpByDeptId(Integer did) {
        return empMapper.findEmpByDeptId(did);
    }
}

3）application.yml配置文件

1.配置duhbbo服务注册者的信息（name、注册地址）

（重点）

2.加载其他配置文件

dubbo:
  application:
    name: dubbo-provider
  registry:
    address: zookeeper://localhost:2181

# 加载其他配置文件
spring:
  profiles:
    active: mybatis

六：创建消费者Dept模块（consumer）

1）Dept模块的启动类

package com.examlpe;

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

@SpringBootApplication
@EnableDubbo
public class DeptApplication {

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

2）Dept的Service层（DeptService接口和DeptServiceImpl实现类）

DeptService接口

package com.examlpe.service;

import com.example.pojo.Dept;
import com.example.pojo.Emp;

import java.util.List;

public interface DeptService {

    List<Dept> findAll();

    List<Emp> findEmpByDeptId(Integer did);
}

DeptServiceImpl实现类

注：这里调用的就不是api的DeptDubboService接口，而是Dept模块自己的Service接口

package com.examlpe.service.impl;

import com.examlpe.service.DeptService;
import com.example.dubbo.service.DeptDubboService;
import com.example.dubbo.service.EmpDubboService;
import com.example.pojo.Dept;
import com.example.pojo.Emp;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

import java.util.List;

@Service
public class DeptServiceImpl implements DeptService {
    @Reference
    private DeptDubboService deptDubboService;

    @Reference
    private EmpDubboService empDubboService;

    @Override
    public List<Dept> findAll() {
        return deptDubboService.findAllDept();
    }

    @Override
    public List<Emp> findEmpByDeptId(Integer did) {
        return empDubboService.findEmpByDeptId(did);
    }
}

3）DeptContarooler

package com.examlpe.contaroller;

import com.examlpe.service.DeptService;
import com.example.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;

import java.util.List;

@Controller
public class DeptController {

    @Autowired
    private DeptService deptService;

    @GetMapping("/dept")
    public String showDept(Model model) {
        List<Dept> list = deptService.findAll();
        System.out.println(list);
        model.addAttribute("list", list);
        return "dept";
    }

    @GetMapping("/showEmp")
    public String showEmp(Integer did, Model model) {
        model.addAttribute("list", deptService.findEmpByDeptId(did));
        return "showEmp";
    }
}

4）application.yml配置文件（配置dubbo服务消费者信息）

dubbo:
  application:
    name: dubbo-dept-consumer
  registry:
    address: zookeeper://localhost:2181

5）页面展示（dept.html和showEmp.html）

<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>

<table border="1" width="500">
    <tr>
        <th>编号</th>
        <th>部门名称</th>
        <th>查看</th>
    </tr>
    <tr th:each="dept : ${list}">
        <td th:text="${dept.id}"></td>
        <td th:text="${dept.name}"></td>
        <td><a th:href="@{/showEmp(did=${dept.id})}">查看</a></td>
    </tr>
</table>
</body>
</html>

<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<table border="1" width="500">
    <tr>
        <th>姓名</th>
        <th>头像</th>
    </tr>
    <tr th:each="emp:${list}">
        <td th:text="${emp.name}"></td>
        <td><img th:src="${emp.photo}" width="80"></td>
    </tr>
</table>
</body>
</html>

七：创建消费者Emp模块

1）Emp模块的启动类

package com.example;

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

@SpringBootApplication
@EnableDubbo
public class EmpApplication {
    public static void main(String[] args) {
        SpringApplication.run(EmpApplication.class, args);
    }
}

2）Emp模块的service层和对应的service实现类

package com.example.service;

import com.example.pojo.Dept;
import com.example.pojo.Emp;
import org.springframework.web.multipart.MultipartFile;

import java.util.List;

public interface EmpService {

    List<Dept> showAll();

    int insertEmp(Emp emp, MultipartFile file);
}

package com.example.service.impl;

import com.example.dubbo.service.DeptDubboService;
import com.example.dubbo.service.EmpDubboService;
import com.example.pojo.Dept;
import com.example.pojo.Emp;
import com.example.service.EmpService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletRequest;
import java.io.File;
import java.io.IOException;
import java.util.List;
import java.util.Random;

@Service
public class EmpServiceImpl implements EmpService {

    @Reference
    private DeptDubboService deptDubboService;

    @Reference
    private EmpDubboService empDubboService;

    @Override
    public List<Dept> showAll() {
        return deptDubboService.findAllDept();
    }

    @Override
    public int insertEmp(Emp emp, MultipartFile file) {
        try {
            HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
            String path = request.getServletContext().getRealPath("/img");
            System.out.println("path:" + path);
            long currentTimeMillis = System.currentTimeMillis();
            Random random = new Random();
            String fileName = currentTimeMillis + "" + random.nextInt(1000);
            String oldName = file.getOriginalFilename();
            fileName += oldName.substring(oldName.lastIndexOf("."));
            File pathFile = new File(path);
            if (!pathFile.exists()) {
                pathFile.mkdir();
            }
            file.transferTo(new File(path, fileName));//上传图片
            emp.setPhoto("http://localhost:8081/img" + fileName);
            return empDubboService.insertEmp(emp);
        } catch (IOException e) {
            e.printStackTrace();
        }
        return 0;
    }
}

3）EmpController

package com.example.controller;

import com.example.pojo.Emp;
import com.example.service.EmpService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.multipart.MultipartFile;

@Controller
public class EmpController {

    @Autowired
    private EmpService empService;

    @GetMapping("/empAdd")
    public String empAdd(Model model) {
        model.addAttribute("list", empService.showAll());
        return "emp-add";
    }

    @PostMapping("/add")
    public String add(Emp emp, MultipartFile file) {
        empService.insertEmp(emp, file);
        return "emp-add";
    }
}

4）application.yml配置文件和Dept基本一致（注意consumer名称和端口号）

5）页面展示

<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>

<table border="1" width="500">
    <tr>
        <th>编号</th>
        <th>部门名称</th>
        <th>查看</th>
    </tr>
    <tr th:each="dept : ${list}">
        <td th:text="${dept.id}"></td>
        <td th:text="${dept.name}"></td>
        <td><a th:href="@{/showEmp(did=${dept.id})}">查看</a></td>
    </tr>
</table>
</body>
</html>

<!DOCTYPE html>
<html lang="en" xmlns:th="http://www.thymeleaf.org">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
</head>
<body>
<table border="1" width="500">
    <tr>
        <th>姓名</th>
        <th>头像</th>
    </tr>
    <tr th:each="emp:${list}">
        <td th:text="${emp.name}"></td>
        <td><img th:src="${emp.photo}" width="80"></td>
    </tr>
</table>
</body>
</html>

总结：

1.dubbo用在分布式项目，不同的provider提供不同的服务功能

。

2.透明化远程调用，就像调用本地方法一样。

3.api接口的service接口是针对provider提供的。

4.不管是consumer或是provider的EnableDubbo注解都是dubbo的。

5.provider的自动注入注解用AutoWirded；consumer的自动注入注解用Reference。

6.不同的consumer、provider启动的时候需要在配置文件设置不同的端口号，以防止启动的时候端口冲突。

7.本地项目访问服务器的MySQL的时候，要注意设置MySQL的访问权限（修改user的权限，在MySQL数据库的“mysql”Database，修改user的host为“%”）。

原文链接：https://blog.csdn.net/weixin_50991099/article/details/126861781

你可能也喜欢