脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Dubbo配置http协议

Dubbo配置http协议全过程

 更新时间：2025年10月21日 08:40:47   作者：要争气  
文章介绍了在服务提供者和服务消费者中,分别通过添加依赖包和配置文件,实现基于HTTP协议的服务接口注册及调用,无需修改消费者启动类,服务调用方式与Dubbo协议类似

一 服务提供者

在服务提供者中，需要添加 注释为http协议支持 的依赖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协议支持-->
        <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>

启动类修改服务启动方式

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协议

<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>

服务接口

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("服务调用");
        try {
            TimeUnit.SECONDS.sleep(5L);
            log.info("调用结束");
        } 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);
    }
}

二 服务消费者

服务消费者，需要添加依赖包jsonrpc4j，counsermer.xml与采用dubbo协议配置方式一样，不用修改

<?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协议支持-->
        <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);
    }
}

服务调用类

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配置服务地址
//    @DubboReference(version = "1.0.0", url = "dubbo://127.0.0.1:12345")

    //check 默认为true,启动依赖检查，如果依赖的UserService不存在（注册中心中没有该服务实例信息）则启动失败
//    @DubboReference(version = "1.0.0",check = false)

    //timeout 服务调用时的超时时间，达到该时间服务消费者报超时异常
    //cluster配置集群容错策略
//    failover （默认容错策略） 失败重试，默认重试2次
//    failfast 快速失败，不进行重试
//    forking 并行调用多个服务器，只要有一个成功就返回
//    @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";
    }
}

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • Java Clone(类的复制)实例代码

    Java Clone(类的复制)实例代码

    Java Clone(类的复制)实例代码，需要的朋友可以参考一下
    2013-03-03
  • SpringBoot中间件ORM框架实现案例详解(Mybatis)

    SpringBoot中间件ORM框架实现案例详解(Mybatis)

    这篇文章主要介绍了SpringBoot中间件ORM框架实现案例详解(Mybatis),本篇文章提炼出mybatis最经典、最精简、最核心的代码设计，来实现一个mini-mybatis,从而熟悉并掌握ORM框架的涉及实现，需要的朋友可以参考下
    2023-07-07
  • Java的SPI机制以及基于SPI编程示例详解

    Java的SPI机制以及基于SPI编程示例详解

    这篇文章主要为大家介绍了Java的SPI机制以及基于SPI编程示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-08-08
  • Java 超详细讲解对象的构造及初始化

    Java 超详细讲解对象的构造及初始化

    面向对象乃是Java语言的核心，是程序设计的思想。Java语言的面向对象技术包括了面向对象和面向过程的基本概念，面向对象的特征，Java语言的类，对象，修饰符，抽象类等一系列的知识点
    2022-03-03
  • Java下载安装和环境变量配置图文教程

    Java下载安装和环境变量配置图文教程

    这篇文章主要为大家详细介绍了Java下载安装和环境变量配置图文教程，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
    2018-10-10
  • System.identityHashCode和hashCode的区别及说明

    System.identityHashCode和hashCode的区别及说明

    String调用hashCode()和System.identityHashCode()返回值不同是因为String重写了hashCode()方法,而System.identityHashCode()返回对象的内存地址哈希值；Test调用两个方法返回值相同是因为Test没有重写hashCode()方法,因此两者调用底层的JVM_IHashCode方法返回相同值
    2024-11-11
  • Ubuntu手动安装JDK 17完整教程(.tar.gz 方式)

    Ubuntu手动安装JDK 17完整教程(.tar.gz 方式)

    JDK是Java开发的核心组件之一,它包含了Java编译器和Java运行时环境,以及其他开发工具和库,这篇文章主要介绍了Ubuntu手动安装JDK 17(.tar.gz 方式)的相关资料,需要的朋友可以参考下
    2026-02-02
  • Spring Boot中使用activiti的方法教程（一）

    Spring Boot中使用activiti的方法教程（一）

    最近一直研究springboot，下面这篇文章主要给大家介绍了关于Spring Boot中使用activiti的相关资料，文中通过示例代码介绍的非常详细，需要的朋友可以参考借鉴，下面随着小编来一起学习学习吧
    2018-08-08
  • java实现切割wav音频文件的方法详解【附外部jar包下载】

    java实现切割wav音频文件的方法详解【附外部jar包下载】

    这篇文章主要介绍了java实现切割wav音频文件的方法,结合实例形式详细分析了java切割wav音频文件的相关原理、操作技巧与注意事项,并附带外部jar包供读者下载,需要的朋友可以参考下
    2019-05-05
  • Spring如何利用三级缓存解密解决循环依赖难题

    Spring如何利用三级缓存解密解决循环依赖难题

    在Spring框架的日常开发中,循环依赖问题如同一个幽灵,时不时困扰着开发者,本文将深入剖析Spring如何通过三级缓存机制破解这一难题,希望对大家有所帮助
    2025-07-07

最新评论