美文网首页
Springboot+Dubbo+ Zookeeper分布式服务

Springboot+Dubbo+ Zookeeper分布式服务

作者: 闽越布衣 | 来源:发表于2019-07-23 17:22 被阅读0次

示例

  • 项目构建
        新建一个Maven工程,该工程为父工程,只要包含两个模块,一个是服务提供方模块dubbo-provider,另一个是服务消费方dubbo-consumer。父工程主要引入相关依赖,其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>com.hyn.dubbo</groupId>
    <artifactId>dubbo-demo</artifactId>
    <packaging>pom</packaging>
    <version>1.0-SNAPSHOT</version>
    <modules>
        <module>dubbo-provider</module>d
        <module>dubbo-consumer</module>
    </modules>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.4.RELEASE</version>
    </parent>
    <dependencies>
        <dependency>
            <groupId>com.alibaba.spring.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.0.0</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <!-- zookeeper client依赖 -->
        <dependency>
            <groupId>com.101tec</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.10</version>
        </dependency>
    </dependencies>
</project>
  • 服务提供方
    在服务提供主要包括两部分,一个是暴露服务,一个是服务实现。
    暴露服务:即我们平常开发中所使用的的接口,这里我们创建一个 ProviderService 的接口,主要包括一个返回字符串方法sayHello。
package com.hyn.dubbo.provider.service;

public interface ProviderService {
    String sayHello(String name);
}

    服务实现:服务实现,与我们平常的服务一样,对接口进行实现,比较特别的是,我们这里需要使用到Dubbo 的 @Service 注解

package com.hyn.dubbo.provider.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.hyn.dubbo.provider.service.ProviderService;
import org.springframework.stereotype.Component;
/**
* interfaceClass 指定当前要暴露的服务
**/
@Service(interfaceClass = ProviderService.class)
@Component
public class ProviderServiceImpl implements ProviderService {
    @Override
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

工程启动服务ProviderApplication

package com.hyn.dubbo.provider;

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

import java.io.IOException;

@SpringBootApplication
@EnableDubboConfiguration
public class ProviderApplication{
    public static void main(String[] args) throws IOException {
        SpringApplication.run(ProviderApplication.class, args);
    }
}

pom.xml

<?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">
    <parent>
        <artifactId>dubbo-demo</artifactId>
        <groupId>com.hyn.dubbo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>dubbo-provider</artifactId>

</project>

applicatioon.properties

server.port=8080 --工程启动端口
spring.dubbo.application.name=provider --服务名称
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181 --注册中心地址
spring.dubbo.protocol.name=dubbo --协议名称(dubbo 协议)
spring.dubbo.protocol.port=20880 --协议端口

总体架构


总体架构
  • 服务消费方
    服务调用
package com.hyn.dubbo.consumer.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.hyn.dubbo.provider.service.ProviderService;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ConsumerController {

     //用dubbo的@Reference注解去连接提供者提供服务
    @Reference
    private ProviderService providerService;

    @RequestMapping("/hello/{name}")
    public String sayHello(@PathVariable String name) {
        return providerService.sayHello(name);
    }
}

工程启动服务ConsumerApplication

package com.hyn.dubbo.consumer;

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

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

pom.xml

<?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">
    <parent>
        <artifactId>dubbo-demo</artifactId>
        <groupId>com.hyn.dubbo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>consumer</artifactId>
    <dependencies>
        <dependency>
            <groupId>com.hyn.dubbo</groupId>
            <artifactId>dubbo-provider</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>
    </dependencies>
</project>

application.properties

server.port=8081 --工程启动端口
server.context-path=/
spring.dubbo.application.name=consumer --服务名称
spring.dubbo.registry.address=zookeeper://127.0.0.1:2181 --注册中心地址
spring.dubbo.protocol.name=dubbo --协议名称(dubbo 协议)
spring.dubbo.protocol.port=20880 --协议端口
spring.dubbo.consumer.check=false --启动时检查 
spring.dubbo.reference.loadbalance=roundrobin --负载均衡(轮询机制)

总体结构


总体结构
  • 结果


    服务提供者
    服务消费者
    调用结果

相关文章

  • Springboot+Dubbo+ Zookeeper分布式服务

    示例 项目构建新建一个Maven工程,该工程为父工程,只要包含两个模块,一个是服务提供方模块dubbo-provi...

  • ZooKeeper简介

    ZooKeeper简介 ZooKeeper:分布式应用的协调服务 ZooKeeper是一个分布式的开源协调服务,用...

  • ZooKeeper 简介

    ZooKeeper: 分布式应用的分布式协调服务 ZooKeeper 是一个用于分布式应用的分布式、开源的协调服务...

  • zookeeper

    ZooKeeper:分布式应用程序的分布式协调服务 ZooKeeper是面向分布式应用程序的分布式开源协调服务。它...

  • 二、ZooKeeper 概述

    ZooKeeper: 分布式应用的分布式协调服务 ZooKeeper是一个分布式应用下的分布式、开源的协调服务。分...

  • ZooKeeper简介

    原文链接 ZooKeeper:分布式应用的分布式协调服务 ZooKeeper是分布式应用的开源协调服务。它公开了一...

  • Zookeeper简介与架构

    一、Zookeeper是什么 Zookeeper是一个分布式协调服务,可用于服务发现,分布式锁,分布式领导选举,配...

  • Zookeeper 原理

    Zookeeper 原理 Zookeeper 概念 Zookeeper 是一个分布式协调服务,可以用于服务发现,分...

  • ZooKeeper概述

    原文地址ZooKeeper Overview ZooKeeper ZooKeeper: 分布式应用中的协调服务设计...

  • Zookeeper应用

    Zookeeper 1. Zookeeper概念简介: Zookeeper是一个分布式协调服务;就是为用户的分布式...

网友评论

      本文标题:Springboot+Dubbo+ Zookeeper分布式服务

      本文链接:https://www.haomeiwen.com/subject/atqjyqtx.html