• 19.在springboot中集成dubbo（zookeeper）

    一、创建一个公共接口项目

    1.选择普通的maven创建项目

    项目结构

    2.pom.xml文件

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0"
    3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    5.     <modelVersion>4.0.0modelVersion>
    6.  
    7.     <groupId>com.itgroupId>
    8.     <artifactId>022-interface-apiartifactId>
    9.     <version>1.0.0version>
    10.  
    11.  
    12. project>

    3.Student类（需要实现序列化）

    1. package com.it.entity;
    2.  
    3. import java.io.Serializable;
    4.  
    5. public class Student implements Serializable {
    6.  
    7.     private static final long serialVersionUID = -4654501682750659489L;
    8.  
    9.     private Integer id;
    10.     private String name;
    11.     private Integer age;
    12.  
    13.     @Override
    14.     public String toString() {
    15.         return "Student{" +
    16.                 "id=" + id +
    17.                 ", name='" + name + '\'' +
    18.                 ", age=" + age +
    19.                 '}';
    20.     }
    21.  
    22.     public Integer getId() {
    23.         return id;
    24.     }
    25.  
    26.     public void setId(Integer id) {
    27.         this.id = id;
    28.     }
    29.  
    30.     public String getName() {
    31.         return name;
    32.     }
    33.  
    34.     public void setName(String name) {
    35.         this.name = name;
    36.     }
    37.  
    38.     public Integer getAge() {
    39.         return age;
    40.     }
    41.  
    42.     public void setAge(Integer age) {
    43.         this.age = age;
    44.     }
    45. }

    4.service包下的StudentService接口

    1. package com.it.service;
    2.  
    3. import com.it.entity.Student;
    4.  
    5. public interface StudentService {
    6.  
    7.     //根据id查找学生
    8.     Student queryStudentById(Integer id);
    9.  
    10. }

    二、创建服务提供者

    1.新建springboot项目，不需要添加任何依赖。

    项目结构

     2.手动导入dubbo依赖，导入zookeeper依赖时需要排除导入SLF4j依赖，以避免重复导入SLF4j依赖导致报错。

    pom.xml文件

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    4.     <modelVersion>4.0.0modelVersion>
    5.     <parent>
    6.         <groupId>org.springframework.bootgroupId>
    7.         <artifactId>spring-boot-starter-parentartifactId>
    8.         <version>2.7.3version>
    9.         <relativePath/> 
    10.     parent>
    11.     <groupId>com.itgroupId>
    12.     <artifactId>023-service-providerartifactId>
    13.     <version>1.0.0version>
    14.  
    15.  
    16.     <properties>
    17.         <java.version>1.8java.version>
    18.     properties>
    19.     <dependencies>
    20.  
    21.         
    22.         <dependency>
    23.             <groupId>com.itgroupId>
    24.             <artifactId>022-interface-apiartifactId>
    25.             <version>1.0.0version>
    26.         dependency>
    27.  
    28.         
    29.         <dependency>
    30.             <groupId>org.apache.dubbogroupId>
    31.             <artifactId>dubbo-spring-boot-starterartifactId>
    32.             <version>2.7.8version>
    33.         dependency>
    34.  
    35.         
    36.         <dependency>
    37.             <groupId>org.apache.dubbogroupId>
    38.             <artifactId>dubbo-dependencies-zookeeperartifactId>
    39.             <version>2.7.8version>
    40.             <type>pomtype>
    41.             <exclusions>
    42.                 <exclusion>
    43.                     <artifactId>slf4j-log4j12artifactId>
    44.                     <groupId>org.slf4jgroupId>
    45.                 exclusion>
    46.             exclusions>
    47.         dependency>
    48.  
    49.         <dependency>
    50.             <groupId>org.springframework.bootgroupId>
    51.             <artifactId>spring-boot-starterartifactId>
    52.         dependency>
    53.  
    54.         <dependency>
    55.             <groupId>org.springframework.bootgroupId>
    56.             <artifactId>spring-boot-starter-testartifactId>
    57.             <scope>testscope>
    58.         dependency>
    59.     dependencies>
    60.  
    61.     <build>
    62.         <plugins>
    63.             <plugin>
    64.                 <groupId>org.springframework.bootgroupId>
    65.                 <artifactId>spring-boot-maven-pluginartifactId>
    66.             plugin>
    67.         plugins>
    68.     build>
    69.  
    70. project>

    3.service包下的StudentServiceImpl实现类

    1. package com.it.service.impl;
    2.  
    3. import com.it.entity.Student;
    4. import com.it.service.StudentService;
    5. import org.apache.dubbo.config.annotation.DubboService;
    6. import org.springframework.stereotype.Component;
    7.  
    8. /**
    9.  * 使用dubbo中的注解暴露服务
    10.  */
    11. @Component
    12. @DubboService(interfaceClass = StudentService.class,version = "1.0",timeout = 5000)
    13. public class StudentServiceImpl implements StudentService {
    14.     @Override
    15.     public Student queryStudentById(Integer id) {
    16.         Student student=new Student();
    17.         if (1001==id){
    18.             student.setId(1001);
    19.             student.setName("小红");
    20.             student.setAge(24);
    21.         }else if (1002==id){
    22.             student.setId(1002);
    23.             student.setName("小黄");
    24.             student.setAge(24);
    25.         }else if (1003==id){
    26.             student.setId(1003);
    27.             student.setName("小蓝");
    28.             student.setAge(21);
    29.         }
    30.  
    31.         return student;
    32.     }
    33. }

    4.springboot的核心配置文件application.properties

    1. #配置服务名称：等同于dubbo:application name="名称"
    2. spring.application.name=studentservice-provider
    3.  
    4. #配置扫描的包，扫描的@DubboService
    5. dubbo.scan.base-packages=com.it.service
    6.  
    7. #配置dubbo协议
    8. #dubbo.protocol.name=name
    9. #dubbo.protocol.port=20881
    10.  
    11. #注册中心
    12. dubbo.registry.address=zookeeper://localhost:2181

    5.主函数入口类ProviderApplication

    1. package com.it;
    2.  
    3. import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
    4. import org.springframework.boot.SpringApplication;
    5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6.  
    7. /**
    8.  * @EnableDubbo:   启动dubbo
    9.  */
    10. @SpringBootApplication
    11. @EnableDubbo
    12. public class ProviderApplication {
    13.  
    14.     public static void main(String[] args) {
    15.         SpringApplication.run(ProviderApplication.class, args);
    16.     }
    17.  
    18. }

    三、创建消费者

    1.新建springboot项目，选择添加web起步依赖。

    项目结构

     

    2.手动导入dubbo依赖，导入zookeeper依赖时需要排除导入SLF4j依赖，以避免重复导入SLF4j依赖导致报错。

    1. "1.0" encoding="UTF-8"?>
    2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    4.     <modelVersion>4.0.0modelVersion>
    5.     <parent>
    6.         <groupId>org.springframework.bootgroupId>
    7.         <artifactId>spring-boot-starter-parentartifactId>
    8.         <version>2.7.3version>
    9.         <relativePath/> 
    10.     parent>
    11.     <groupId>com.itgroupId>
    12.     <artifactId>024-consumerartifactId>
    13.     <version>1.0.0version>
    14.  
    15.     <properties>
    16.         <java.version>1.8java.version>
    17.     properties>
    18.     <dependencies>
    19.  
    20.         
    21.         <dependency>
    22.             <groupId>com.itgroupId>
    23.             <artifactId>022-interface-apiartifactId>
    24.             <version>1.0.0version>
    25.         dependency>
    26.  
    27.         
    28.         <dependency>
    29.             <groupId>org.apache.dubbogroupId>
    30.             <artifactId>dubbo-spring-boot-starterartifactId>
    31.             <version>2.7.8version>
    32.         dependency>
    33.  
    34.         
    35.         <dependency>
    36.             <groupId>org.apache.dubbogroupId>
    37.             <artifactId>dubbo-dependencies-zookeeperartifactId>
    38.             <version>2.7.8version>
    39.             <type>pomtype>
    40.             <exclusions>
    41.                 <exclusion>
    42.                     <artifactId>slf4j-log4j12artifactId>
    43.                     <groupId>org.slf4jgroupId>
    44.                 exclusion>
    45.             exclusions>
    46.         dependency>
    47.  
    48.  
    49.         <dependency>
    50.             <groupId>org.springframework.bootgroupId>
    51.             <artifactId>spring-boot-starterartifactId>
    52.         dependency>
    53.  
    54.         <dependency>
    55.             <groupId>org.springframework.bootgroupId>
    56.             <artifactId>spring-boot-starter-testartifactId>
    57.             <scope>testscope>
    58.         dependency>
    59.     dependencies>
    60.  
    61.     <build>
    62.         <plugins>
    63.             <plugin>
    64.                 <groupId>org.springframework.bootgroupId>
    65.                 <artifactId>spring-boot-maven-pluginartifactId>
    66.             plugin>
    67.         plugins>
    68.     build>
    69.  
    70. project>

    3.DubboController类

    1. package com.it.controller;
    2.  
    3. import com.it.entity.Student;
    4. import com.it.service.StudentService;
    5. import org.apache.dubbo.config.annotation.DubboReference;
    6. import org.springframework.stereotype.Controller;
    7. import org.springframework.web.bind.annotation.GetMapping;
    8. import org.springframework.web.bind.annotation.RestController;
    9.  
    10. import javax.annotation.Resource;
    11.  
    12. @RestController
    13. public class DubboController {
    14.  
    15.  
    16.     /**
    17.      * @DubboReference:引用远程接口，把创建好的代理对象，注入给StudentService
    18.      */
    19.     @DubboReference(interfaceClass = StudentService.class,version = "1.0")
    20.     private StudentService studentService;
    21.  
    22.     @GetMapping("/query")
    23.     public String queryStudentById(Integer id){
    24.         Student student = studentService.queryStudentById(1002);
    25.         return "调用远程接口来获取对象："+student;
    26.     }
    27.  
    28. }

    4.application.properties文件

    1. #指定服务名称
    2. spring.application.name=consumer-application
    3. #指定注册中心
    4. dubbo.registry.address=zookeeper://localhost:2181

     5.ConsumerApplication类

    1. package com.it;
    2.  
    3. import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
    4. import org.springframework.boot.SpringApplication;
    5. import org.springframework.boot.autoconfigure.SpringBootApplication;
    6.  
    7. @SpringBootApplication
    8. @EnableDubbo
    9. public class ConsumerApplication {
    10.  
    11.     public static void main(String[] args) {
    12.         SpringApplication.run(ConsumerApplication.class, args);
    13.     }
    14.  
    15. }

    四、启动zookeeper

    2.执行程序后，不能关闭程序，可以把该命令窗口最小化，才能保证 zookeeper是启动状态

     3.启动服务提供者

    4.启动消费者

    5.在浏览器地址框中输入url进行访问

     

  • 相关阅读:
    mac electron引入原生SDK
    sqli-labs(Less-4) extractvalue闯关
    MySQL主/从-主/主集群安装部署
    C++信息学奥赛1168：大整数加法
    数据库概念介绍
    基于stm32F103的座面声控台灯
    Java中的GUI编程
    2022-8-20 B树和B+树
    房产中介管理系统,房产中介预约看房系统,看房预约系统毕设作品
    Vue3.0 响应式reactive的原理实现
  • 原文地址：https://blog.csdn.net/weixin_59334478/article/details/126725073