springboot整合dubbo

阿新 • • 發佈：2020-11-03

springboot整合dubbo

springdubbo父工程

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">
  <modelVersion>4.0.0</modelVersion>

  <groupId>com.dtg</groupId>
  <artifactId>springdubbo</artifactId>
  <version>1.0-SNAPSHOT</version>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.0.0.RELEASE</version>
  </parent>
  <modules>
    <module>springdubbo-api</module>
    <module>springdubbo-provider</module>
    <module>springdubbo-consumer</module>
  </modules>
  <packaging>pom</packaging>
</project>

API工程springdubbo-api

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>springdubbo</artifactId>
    <groupId>com.dtg</groupId>
    <version>1.0-SNAPSHOT</version>
  </parent>
  <modelVersion>4.0.0</modelVersion>
  <artifactId>springdubbo-api</artifactId>
</project>

定義介面

ITestFacadeService.java

package com.dtg.springdubbo.service;

public interface ITestFacadeService {
   public String testMethod(String input);
}

服務提供者 springdubbo-provider

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <parent>
     <groupId>com.dtg</groupId>
     <artifactId>springdubbo</artifactId>
     <version>1.0-SNAPSHOT</version>
   </parent>
   <groupId>com.dtg</groupId>
   <artifactId>springdubbo-provider</artifactId>
   <version>0.0.1-SNAPSHOT</version>
   <name>springdubbo-provider</name>
   <description>Demo project for Spring Boot</description>

   <properties>
     <java.version>1.8</java.version>
   </properties>

   <dependencies>
     <!-- springboot -->
     <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-test</artifactId>
       <scope>test</scope>
     </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 -->
     <dependency>
       <groupId>com.alibaba</groupId>
       <artifactId>dubbo</artifactId>
       <version>2.5.3</version>
       <exclusions>
         <exclusion>
           <groupId>org.springframework</groupId>
           <artifactId>spring</artifactId>
         </exclusion>
       </exclusions>
     </dependency>

     <!-- zookeeper -->
     <dependency>
       <groupId>org.apache.zookeeper</groupId>
       <artifactId>zookeeper</artifactId>
       <version>3.4.6</version>
       <exclusions>
         <exclusion>
           <groupId>org.slf4j</groupId>
           <artifactId>slf4j-log4j12</artifactId>
         </exclusion>
         <exclusion>
           <groupId>log4j</groupId>
           <artifactId>log4j</artifactId>
         </exclusion>
       </exclusions>
     </dependency>
     <dependency>
       <groupId>com.github.sgroschupf</groupId>
       <artifactId>zkclient</artifactId>
       <version>0.1</version>
     </dependency>

     <!-- 專案依賴 -->
     <dependency>
       <groupId>com.dtg</groupId>
       <artifactId>springdubbo-api</artifactId>
       <version>1.0-SNAPSHOT</version>
     </dependency>

     <!-- 日誌 -->
     <dependency>
       <groupId>org.slf4j</groupId>
       <artifactId>slf4j-log4j12</artifactId>
     </dependency>
   </dependencies>


   <build>
     <plugins>
       <plugin>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-maven-plugin</artifactId>
       </plugin>
     </plugins>
   </build>

</project>

配置application.properties

server.port=8080
# dubbo
dubbo.application.name=xdloan-test
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.name=dubbo

配置dubbo-provider.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
  http://www.springframework.org/schema/beans/spring-beans.xsd
  http://code.alibabatech.com/schema/dubbo
  http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
  <!-- 提供方應用資訊，用於計算依賴關係 -->
  <dubbo:application name="${dubbo.application.name}"/>
  <!-- 使用zookeeper註冊中心暴露服務地址 -->
  <dubbo:registry id="register" address="${dubbo.registry.address}"/>
  <dubbo:registry id="local" address="zookeeper://127.0.0.1:2181"/>
  <!-- 用dubbo協議在20880埠暴露服務 -->
  <dubbo:protocol name="${dubbo.protocol.name}" port="${dubbo.protocol.port}"/>

  <!-- 宣告需要暴露的服務介面（注意是介面,不是實現類） -->
  <!-- 這裡是具體實現類,id和上面的暴露的服務介面ref要一致,dubbo就是通過這個來註冊對應的服務 -->
  <!-- 同模組的registry使用local，不同模組的使用遠端的register -->
  <dubbo:service registry="register" interface="com.dtg.springdubbo.service.ITestFacadeService" ref="testService"/>

</beans>

啟動類

DemoproviderApplication.java

package com.dtg.demoprovider;

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

@SpringBootApplication
@ImportResource("classpath:dubbo-provider.xml")
public class DemoproviderApplication {

  public static void main(String[] args) {
    SpringApplication.run(DemoproviderApplication.class, args);
   }

}

服務實現類

TestServiceImpl.java

package com.dtg.demoprovider.service;

import com.dtg.springdubbo.service.ITestFacadeService;
import org.springframework.stereotype.Service;

@Service("testService")
public class TestServiceImpl implements ITestFacadeService {
  @Override
  public String testMethod(String s) {
    System.out.println("testmethod:"+s);
    return "hello "+ s;
   }
}

服務消費者 springdubbo-consumer

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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <parent>
    <groupId>com.dtg</groupId>
    <artifactId>springdubbo</artifactId>
    <version>1.0-SNAPSHOT</version>
  </parent>
  <groupId>com.dtg</groupId>
  <artifactId>springdubbo-consumer</artifactId>
  <version>0.0.1-SNAPSHOT</version>
  <name>springdubbo-consumer</name>
  <description>Demo project for Spring Boot</description>

  <properties>
    <java.version>1.8</java.version>
  </properties>

  <dependencies>
    <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>
      <exclusions>
        <exclusion>
          <groupId>org.junit.vintage</groupId>
          <artifactId>junit-vintage-engine</artifactId>
        </exclusion>
      </exclusions>
    </dependency>

    <!-- dubbo -->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.5.3</version>
      <exclusions>
        <exclusion>
          <groupId>org.springframework</groupId>
          <artifactId>spring</artifactId>
        </exclusion>
      </exclusions>
    </dependency>

    <!-- zookeeper -->
    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.6</version>
      <exclusions>
        <exclusion>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
        <exclusion>
          <groupId>log4j</groupId>
          <artifactId>log4j</artifactId>
        </exclusion>
      </exclusions>
    </dependency>
    <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
    </dependency>

    <!-- 專案依賴 -->
    <dependency>
      <groupId>com.dtg</groupId>
      <artifactId>springdubbo-api</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
  </dependencies>

  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>
</project>

配置application.properties

server.port=8080
# dubbo
dubbo.application.name=springdubbo-consumer
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.protocol.name=dubbo

配置dubbo-consumer.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans
  http://www.springframework.org/schema/beans/spring-beans.xsd
  http://code.alibabatech.com/schema/dubbo
  http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
  <!-- 消費方應用名，用於計算依賴關係，不是匹配條件，不要與提供方一樣 -->
  <dubbo:application name="${dubbo.application.name}"/>
  <dubbo:registry id="register" address="${dubbo.registry.address}"/>
  <dubbo:registry id="local" address="zookeeper://127.0.0.1:2181"/>
  <dubbo:protocol name="${dubbo.protocol.name}"/>
  <!-- 生成遠端服務代理，可以和本地bean一樣呼叫 -->
  <!-- 同模組的registry使用local，不同模組的使用遠端的register -->
  <dubbo:reference registry="register" id="testService" interface="com.dtg.springdubbo.service.ITestFacadeService"/>
</beans>

啟動類

package com.dtg.springdubboconsumer;

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

@SpringBootApplication
@ImportResource("classpath:dubbo-customer.xml")
public class SpringdubboConsumerApplication {

  public static void main(String[] args) {
    SpringApplication.run(SpringdubboConsumerApplication.class, args);
   }

}

業務類

package com.dtg.springdubboconsumer.controller;

import com.dtg.springdubbo.service.ITestFacadeService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class TestController {

  @Autowired
  ITestFacadeService testFacadeService;

  @GetMapping("/test/{name}")
  public String test(@PathVariable("name") String name){
    return testFacadeService.testMethod(name);
   }
}

SpringBoot整合Dubbo zookeeper過程解析

這篇文章主要介紹了SpringBoot整合Dubbo zookeeper過程解析,文中通過示例程式碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

springboot 整合dubbo(用zookeeper註冊中心)

1.新建Springboot工程，引入dubbo依賴  <dependency> <groupId>com.alibaba.boot</groupId>

2020最新IDEA SpringBoot整合Dubbo的實現(zookeeper版)

首先，要在電腦上安裝配置好zookeeper哦~ 這是我雲伺服器上的zookeeper狀態接下來，開始整合

springboot整合dubbo啟動遇到空指標異常

遇到的錯誤： Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is java.lang.NullPointerException] with roo

springboot整合dubbo設定全域性唯一ID進行日誌追蹤的示例程式碼

1.新建專案利用idea建立一個父專案，三個子專案，其中一個專案為生產者，一個專案為消費者，一個為介面等公共服務專案，生產者和消費者需要有web依賴，可以作為tomcat容器啟動。

springboot整合dubbo

springboot整合dubbo springdubbo父工程 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-insta