Dubbo配置http協(xié)議全過程

更新時(shí)間：2025年10月21日 08:40:47 作者：要爭氣

文章介紹了在服務(wù)提供者和服務(wù)消費(fèi)者中,分別通過添加依賴包和配置文件,實(shí)現(xiàn)基于HTTP協(xié)議的服務(wù)接口注冊及調(diào)用,無需修改消費(fèi)者啟動類,服務(wù)調(diào)用方式與Dubbo協(xié)議類似

一服務(wù)提供者

在服務(wù)提供者中，需要添加注釋為http協(xié)議支持的依賴jar包，修改啟動類的啟動方式，添加provider.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>tech-dubbo</artifactId>
        <groupId>com.tech</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>tech-service</artifactId>

    <name>tech-service</name>

    <properties>
        <spring-boot.version>2.3.0.RELEASE</spring-boot.version>
        <dubbo.version>2.7.8</dubbo.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>com.tech</groupId>
            <artifactId>tech-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>

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

        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>

        <!--zookeeper-->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.6.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.0.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.0.1</version>
        </dependency>

        <!--http協(xié)議支持-->
        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>javax.servlet-api</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.tomcat.embed</groupId>
            <artifactId>tomcat-embed-core</artifactId>
        </dependency>
        <dependency>
            <groupId>org.eclipse.jetty</groupId>
            <artifactId>jetty-server</artifactId>
        </dependency>
        <dependency>
            <groupId>org.eclipse.jetty</groupId>
            <artifactId>jetty-servlet</artifactId>
        </dependency>
        <dependency>
            <groupId>com.github.briandilley.jsonrpc4j</groupId>
            <artifactId>jsonrpc4j</artifactId>
            <version>1.2.0</version>
        </dependency>

    </dependencies>

    <dependencyManagement>
        <dependencies>
            <!-- Spring Boot -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <!-- Apache Dubbo  -->
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-dependencies-bom</artifactId>
                <version>${dubbo.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo</artifactId>
                <version>${dubbo.version}</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework</groupId>
                        <artifactId>spring</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>javax.servlet</groupId>
                        <artifactId>servlet-api</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>log4j</groupId>
                        <artifactId>log4j</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
        </dependencies>
    </dependencyManagement>
</project>

啟動類修改服務(wù)啟動方式

package com.tech;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.WebApplicationType;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.ImportResource;

/**
 * @author lw
 * @since 2021/10/11
 */
@ImportResource("provider.xml")
@EnableAutoConfiguration
public class ServiceApp {
    public static void main(String[] args) {
//        SpringApplication.run(ServiceApp.class);
        new SpringApplicationBuilder(ServiceApp.class).web(WebApplicationType.NONE).run();
    }
}

provider.xml

userService fileService配置為http協(xié)議

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    <dubbo:registry address="zookeeper://192.168.50.133:2183?backup=192.168.50.132:2182,192.168.50.131:2181" timeout="30000"/>
    <dubbo:protocol name="http" port="8666" server="jetty"/>
    <bean id="userService" class="com.tech.impl.UserServiceImpl"/>
    <bean id="fileService" class="com.tech.impl.FileServiceImpl"/>
    <dubbo:service interface="com.tech.UserService" ref="userService" cluster="failsafe" protocol="http"/>
    <dubbo:service interface="com.tech.FileService" ref="fileService"  protocol="http"/>
</beans>

服務(wù)接口

package com.tech.impl;

import com.tech.UserService;
import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.TimeUnit;

@Slf4j
public class UserServiceImpl implements UserService {

    public String hello()  {
        log.info("服務(wù)調(diào)用");
        try {
            TimeUnit.SECONDS.sleep(5L);
            log.info("調(diào)用結(jié)束");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "hello word";
    }
}

package com.tech.impl;

import com.tech.FileService;

/**
 * @author lw
 * @since 2021/10/13
 */
public class FileServiceImpl implements FileService {
    @Override
    public void upload(String msg) {
        System.out.println("文件上傳成功 "+msg);
    }
}

二服務(wù)消費(fèi)者

服務(wù)消費(fèi)者，需要添加依賴包jsonrpc4j，counsermer.xml與采用dubbo協(xié)議配置方式一樣，不用修改

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

    <artifactId>tech-web</artifactId>

    <name>tech-web</name>

    <properties>
        <spring-boot.version>2.3.0.RELEASE</spring-boot.version>
        <dubbo.version>2.7.8</dubbo.version>
        <zookeeper.version>2.12.0</zookeeper.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>com.tech</groupId>
            <artifactId>tech-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </dependency>

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

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

        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.8</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo</artifactId>
        </dependency>

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.6.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>4.0.1</version>
        </dependency>
        <dependency>
            <groupId>org.apache.curator</groupId>
            <artifactId>curator-recipes</artifactId>
            <version>4.0.1</version>
        </dependency>

        <!--http協(xié)議支持-->
        <dependency>
            <groupId>com.github.briandilley.jsonrpc4j</groupId>
            <artifactId>jsonrpc4j</artifactId>
            <version>1.2.0</version>
        </dependency>



    </dependencies>

    <dependencyManagement>
        <dependencies>
            <!-- Spring Boot -->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>${spring-boot.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <!-- Apache Dubbo  -->
            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo-dependencies-bom</artifactId>
                <version>${dubbo.version}</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <dependency>
                <groupId>org.apache.dubbo</groupId>
                <artifactId>dubbo</artifactId>
                <version>${dubbo.version}</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework</groupId>
                        <artifactId>spring</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>javax.servlet</groupId>
                        <artifactId>servlet-api</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>log4j</groupId>
                        <artifactId>log4j</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
        </dependencies>
    </dependencyManagement>
</project>

consumer.xml

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
       http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
    <dubbo:registry address="zookeeper://192.168.50.133:2183?backup=192.168.50.132:2182,192.168.50.131:2181"  timeout="30000"/>
    <dubbo:reference id="userService" check="false" interface="com.tech.UserService" retries="4" timeout="6000"/>
    <dubbo:reference id="fileService" check="false" interface="com.tech.FileService"  retries="4"/>
</beans>

啟動類

package com.tech;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@ImportResource("consumer.xml")
public class WebApp {
    public static void main(String[] args) {
        SpringApplication.run(WebApp.class);
    }
}

服務(wù)調(diào)用類

package com.tech.controller;

import com.tech.FileService;
import com.tech.UserService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author lw
 * @since 2021/10/11
 */
@RestController
public class UserController {

    //dubbo.registry.address=N/A 需要通過url配置服務(wù)地址
//    @DubboReference(version = "1.0.0", url = "dubbo://127.0.0.1:12345")

    //check 默認(rèn)為true,啟動依賴檢查，如果依賴的UserService不存在（注冊中心中沒有該服務(wù)實(shí)例信息）則啟動失敗
//    @DubboReference(version = "1.0.0",check = false)

    //timeout 服務(wù)調(diào)用時(shí)的超時(shí)時(shí)間，達(dá)到該時(shí)間服務(wù)消費(fèi)者報(bào)超時(shí)異常
    //cluster配置集群容錯策略
//    failover （默認(rèn)容錯策略） 失敗重試，默認(rèn)重試2次
//    failfast 快速失敗，不進(jìn)行重試
//    forking 并行調(diào)用多個(gè)服務(wù)器，只要有一個(gè)成功就返回
//    @DubboReference(version = "1.0.0",timeout = 3000,retries = 1,cluster = "failover")
//    private UserService userService;
//
//    @DubboReference(version = "1.0.0")
//    private FileService fileService;

    @Autowired
    private UserService userService;
    @Autowired
    private FileService fileService;

    @GetMapping("hello")
    public String hello() {
        return userService.hello();
    }

    @GetMapping("upload")
    public String upload(){
        fileService.upload("hello word");
        return "hello word";
    }
}