zoukankan      html  css  js  c++  java
  • springboot+dubbo + zookeeper 案例

    配置:
    dubbo.application.name=function-two
    #注册中心的协议和地址
    dubbo.registry.protocol=zookeeper
    dubbo.registry.address=127.0.0.1:2181
    #通信规则(通信协议和接口)
    dubbo.protocol.name=dubbo
    dubbo.protocol.port=20881
    #连接监控中心
    dubbo.monitor.protocol=registry

    实现类: 生产者
    import com.alibaba.dubbo.config.annotation.Service;
    import com.sc.fun.service.WorldService;
    import lombok.extern.log4j.Log4j2;

    /**
    * @author Administrator
    * @description: TODO
    * @date 2021/7/20 13:46
    */
    @Service(interfaceClass = WorldService.class)
    @Log4j2
    public class WorldServiceImpl implements WorldService {

    @Override
    public String sayWorld() {
    log.info("world");
    return "world";
    }
    }

    实现类:消费者
    import com.alibaba.dubbo.config.annotation.Reference;
    import com.sc.fun.service.HelloService;
    import com.sc.fun.service.SCApiService;
    import com.sc.fun.service.WorldService;
    import org.springframework.stereotype.Service;

    /**
    * @author Administrator
    * @description: TODO
    * @date 2021/7/21 16:18
    */
    @Service
    public class SCApiServiceImpl implements SCApiService {

    @Reference
    private HelloService helloService;

    @Reference
    private WorldService worldService;

    @Override
    public String sayHelloWorld() {
    String h = helloService.sayHello();
    String w = worldService.sayWorld();
    return "i say : " + h + w;
    }
    }

    jar坐标
    <?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>com.sc</groupId>
    <artifactId>demo</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
    <module>common</module>
    <module>function-one</module>
    <module>function-two</module>
    <module>function-api</module>
    <module>function-gateway</module>
    </modules>

    <!-- 本项目的父模块使用spring-boot框架 -->
    <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.2.RELEASE</version>
    </parent>

    <!-- 项目自定义属性 -->
    <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <java.version>1.8</java.version>
    <!-- 依赖的版本号:在定义版本时,要注意的是不同的依赖版本之间会有影响,有些最新的版本不支持其他依赖的低版本一起使用-->
    <mysql.driver.version>5.1.29</mysql.driver.version>
    <org.mybatis.spring.boot.version>1.3.1</org.mybatis.spring.boot.version>
    <alibaba.druid.version>1.1.9</alibaba.druid.version>
    <spring.cloud.version>Finchley.SR1</spring.cloud.version>
    <dubbo.version>2.6.2</dubbo.version>
    <dubbo.start.version>0.2.0</dubbo.start.version>
    <curator.version>4.0.1</curator.version>
    <zookeeper.version>3.4.13</zookeeper.version>
    <curator.recipes.version>2.8.0</curator.recipes.version>
    <zkclient.version>0.10</zkclient.version>
    </properties>

    <!-- 项目依赖项 -->
    <dependencyManagement> <!-- dependencyManagement只是声明依赖,并不实现引入 -->
    <dependencies>
    <!-- Spring Cloud -->
    <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-dependencies</artifactId>
    <version>${spring.cloud.version}</version>
    <type>pom</type>
    <scope>import</scope>
    </dependency>
    </dependencies>
    </dependencyManagement>

    <dependencies>
    <!-- Spring Boot -->
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter</artifactId>
    <version>2.0.2.RELEASE</version>
    </dependency>
    <!-- <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.0.2.RELEASE</version>
    </dependency>-->
    <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-gateway</artifactId>
    <version>2.0.2.RELEASE</version>
    </dependency>
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>
    <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
    </dependency>
    <!-- 添加junit4依赖 单元测试-->
    <dependency>
    <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>4.12</version>
    <scope>test</scope>
    </dependency>
    <!-- 切面 -->
    <dependency>
    <groupId>org.aspectj</groupId>
    <artifactId>aspectjweaver</artifactId>
    <version>1.8.8</version>
    </dependency>
    <!-- 简化Entity代码(实体类添加@Data,编译时为所有字段添加@ToString/@EqualsAndHashCode/@Getter/为非final字段添加@Setter) -->
    <dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <version>1.16.20</version>
    </dependency>
    <!-- 添加mybatis依赖-->
    <dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>${org.mybatis.spring.boot.version}</version>
    </dependency>
    <!-- 添加mysql驱动依赖 -->
    <dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <scope>runtime</scope>
    <version>${mysql.driver.version}</version>
    </dependency>
    <!-- 添加数据库连接池依赖 -->
    <dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>${alibaba.druid.version}</version>
    </dependency>
    <!--zk客户端-->
    <dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-framework</artifactId>
    <version>${curator.version}</version>
    </dependency>
    <dependency>
    <groupId>org.apache.curator</groupId>
    <artifactId>curator-recipes</artifactId>
    <version>${curator.recipes.version}</version>
    </dependency>
    <!--zk服务端-->
    <dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>${zookeeper.version}</version>
    <type>pom</type>
    <exclusions>
    <exclusion>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-log4j12</artifactId>
    </exclusion>
    </exclusions>
    </dependency>
    <dependency>
    <groupId>com.101tec</groupId>
    <artifactId>zkclient</artifactId>
    <version>${zkclient.version}</version>
    </dependency>
    <!--dubbo-->
    <dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>dubbo</artifactId>
    <version>${dubbo.version}</version>
    </dependency>
    <dependency>
    <groupId>com.alibaba.boot</groupId>
    <artifactId>dubbo-spring-boot-starter</artifactId>
    <version>${dubbo.start.version}</version>
    </dependency>
    </dependencies>
    <!-- <scope>主要管理依赖的部署
    * compile,缺省值,适用于所有阶段,会随着项目一起发布。
    * provided,类似compile,期望JDK、容器或使用者会提供这个依赖。如servlet.jar。
    * runtime,只在运行时使用,如JDBC驱动,适用运行和测试阶段。
    * test,只在测试时使用,用于编译和运行测试代码。不会随项目发布。
    * system,类似provided,需要显式提供包含依赖的jar,Maven不会在Repository中查找它。
    -->

    <build>
    <plugins>
    <!--打包跳过测试-->
    <plugin>
    <groupId>org.apache.maven.plugins</groupId>
    <artifactId>maven-surefire-plugin</artifactId>
    <configuration>
    <skip>true</skip>
    </configuration>
    </plugin>
    </plugins>
    </build>

    </project>

    备注:
    每个业务微服务都是生产者,增加一个统一消费的微服务【该服务是需要引用生产者的微服务jar包】,请求直接走消费微服务的api
    假如两个或以上业务微服务既是生产者又是消费者的情况下,相互引用.这种情况是不允许的【禁止模块直接互相引用】
    每个微服务端口不一样,dubbo端口也不一样
  • 相关阅读:
    QSPI
    温度标准
    minigui占用空间的情况
    引导页的展示
    Xcode6.0以后SVN的配置
    【转】iOS多线程编程技术之NSThread、Cocoa NSOperation、GCD
    SDWebImage最新使用
    OC设计模式
    Objective-c的@property 详解
    iOS开发时间戳与时间,时区的转换,汉字与UTF8,16进制的转换
  • 原文地址:https://www.cnblogs.com/austinspark-jessylu/p/15042954.html
Copyright © 2011-2022 走看看