SpringBoot集成Dubbo--provider

刺骨的言语ヽ痛彻心扉 2022-05-14 02:42 210阅读 0赞

目录结构：

![70][]

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>springboot</groupId>
        <artifactId>springboot-dubbo-server</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>springboot-dubbo 服务端:: 整合 Dubbo/ZooKeeper 详解 SOA 案例</name>
    
        
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.5.1.RELEASE</version>
        </parent>
    
        <properties>
            <dubbo-spring-boot>1.0.0</dubbo-spring-boot>
        </properties>
    
        <dependencies>
    
            
            <dependency>
                <groupId>io.dubbo.springboot</groupId>
                <artifactId>spring-boot-starter-dubbo</artifactId>
                <version>${dubbo-spring-boot}</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-test</artifactId>
                <scope>test</scope>
            </dependency>
    
            
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
            </dependency>
        </dependencies>
    </project>

application.properties：

## Dubbo 服务提供者配置
    spring.dubbo.application.name=provider
    spring.dubbo.registry.address=zookeeper://127.0.0.1:2181
    spring.dubbo.protocol.name=dubbo
    spring.dubbo.protocol.port=20882
    spring.dubbo.scan=org.spring.springboot.dubbo

City :

package org.spring.springboot.domain;
    
    import java.io.Serializable;
    
    /**
     * 城市实体类
     *
     */
    public class City implements Serializable {
    
        private static final long serialVersionUID = -1L;
    
        /**
         * 城市编号
         */
        private Long id;
    
        /**
         * 省份编号
         */
        private Long provinceId;
    
        /**
         * 城市名称
         */
        private String cityName;
    
        /**
         * 描述
         */
        private String description;
    
        public City() {
        }
    
        public City(Long id, Long provinceId, String cityName, String description) {
            this.id = id;
            this.provinceId = provinceId;
            this.cityName = cityName;
            this.description = description;
        }
    
        public Long getId() {
            return id;
        }
    
        public void setId(Long id) {
            this.id = id;
        }
    
        public Long getProvinceId() {
            return provinceId;
        }
    
        public void setProvinceId(Long provinceId) {
            this.provinceId = provinceId;
        }
    
        public String getCityName() {
            return cityName;
        }
    
        public void setCityName(String cityName) {
            this.cityName = cityName;
        }
    
        public String getDescription() {
            return description;
        }
    
        public void setDescription(String description) {
            this.description = description;
        }
    }

CityDubboService:

package org.spring.springboot.dubbo;
    
    import org.spring.springboot.domain.City;
    
    /**
     * 城市业务 Dubbo 服务层
     *
     * Created by bysocket on 28/02/2017.
     */
    public interface CityDubboService {
    
        /**
         * 根据城市名称，查询城市信息
         * @param cityName
         */
        City findCityByName(String cityName);
    }

CityDubboServiceImpl:

package org.spring.springboot.dubbo.impl;
    
    import com.alibaba.dubbo.config.annotation.Service;
    import org.spring.springboot.domain.City;
    import org.spring.springboot.dubbo.CityDubboService;
    import org.springframework.beans.factory.annotation.Autowired;
    
    /**
     * 城市业务 Dubbo 服务层实现层
     *
     */
    // 注册为 Dubbo 服务
    @Service(version = "1.0.0")
    public class CityDubboServiceImpl implements CityDubboService {
    
        public City findCityByName(String cityName) {
            return new City(1L,2L,"忠县","是我的故乡");
        }
    }

ServerApplication启动类：

package org.spring.springboot;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    
    /**
     * Spring Boot 应用启动类
     *
     * Created by bysocket on 16/4/26.
     */
    // Spring Boot 应用的标识
    @SpringBootApplication
    public class ServerApplication {
    
        public static void main(String[] args) {
            // 程序启动入口
            // 启动嵌入式的 Tomcat 并初始化 Spring 环境及其各 Spring 组件
            SpringApplication.run(ServerApplication.class,args);
        }
    }

直接启动：

![70 1][]

服务发布成功！！！

[70]: /images/20220514/a2593d97b5e14f7db2a0d4cd22a7ad13.png
[70 1]: /images/20220514/d66dd68a588148a89dbfad7bfe39ee9c.png