Создание проекта dubbo на основе springboot

Dubbo

Как один из наиболее часто используемых распределенных фреймворков, dubbo, я считаю необходимым создать простой фреймворк самостоятельно.

окончательная структура проекта

Самый внешний уровень — это модуль maven с именем dubbo_demo, который содержит модули производителя и потребителя на основе Springboot.

Создать мавен проект

Используйте идею, чтобы создать новый проект maven и заполнить основную информацию.

Сохраните только файл 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.lamarsan</groupId>
    <artifactId>dubbo_demo</artifactId>
    <version>1.0-SNAPSHOT</version>

    <!--子模块声明-->
    <modules>
        <module>
            provider
        </module>
        <module>
            consumer
        </module>
    </modules>

    <properties>
        <java.version>1.8</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <dubbo.version>2.8.5-SNAPSHOT</dubbo.version>
        <curator-framework.version>1.3.3</curator-framework.version>
        <zookeeper.version>3.4.8</zookeeper.version>
        <zkclient.version>0.1</zkclient.version>
        <mybatis-starter.version>1.3.2</mybatis-starter.version>
    </properties>
    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>0.2.0</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>2.0.1.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>${mybatis-starter.version}</version>
            </dependency>
            <!-- zookeeper start -->
            <dependency>
                <groupId>com.netflix.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>${curator-framework.version}</version>
            </dependency>

            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>${zookeeper.version}</version>
                <exclusions>
                    <exclusion>
                        <groupId>commons-logging</groupId>
                        <artifactId>commons-logging</artifactId>
                    </exclusion>
                    <exclusion>
                        <artifactId>log4j-over-slf4j</artifactId>
                        <groupId>org.slf4j</groupId>
                    </exclusion>
                    <exclusion>
                        <artifactId>slf4j-log4j12</artifactId>
                        <groupId>org.slf4j</groupId>
                    </exclusion>
                    <exclusion>
                        <artifactId>log4j</artifactId>
                        <groupId>log4j</groupId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>com.github.sgroschupf</groupId>
                <artifactId>zkclient</artifactId>
                <version>${zkclient.version}</version>
            </dependency>
            <!-- zookeeper end -->

            <dependency>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-resources-plugin</artifactId>
                <version>2.5</version>
            </dependency>
            <dependency>
                <groupId>commons-lang</groupId>
                <artifactId>commons-lang</artifactId>
                <version>2.6</version>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <build>
        <resources>
            <resource>
                <directory>${basedir}/src/main/resources</directory>
                <filtering>true</filtering>
                <includes>
                    <include>**/application*.yml</include>
                    <include>**/*.properties</include>
                    <include>**/*.xml</include>
                </includes>
            </resource>
            <resource>
                <directory>${basedir}/src/main/resources</directory>
                <includes>
                    <include>**/application*.yml</include>
                    <include>**/*.properties</include>
                    <include>**/*.xml</include>
                </includes>
            </resource>
        </resources>
    </build>
</project>

Создайте подмодуль следующим образом:

Щелкните правой кнопкой мыши имя проекта, создайте новый модуль и создайте проект Springboot.

provider

Структура проекта выглядит следующим образом, включая dao, подключенный к базе данных, модель класса сущностей и сервисную службу:

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>
    <!--父模块声明-->
    <parent>
        <groupId>com.lamarsan</groupId>
        <artifactId>dubbo_demo</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <groupId>com.lamarsan</groupId>
    <artifactId>provider</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>provider</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</artifactId>
            <version>2.0.1.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <version>2.0.1.RELEASE</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
        </dependency>
        <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.16</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <version>2.0.1.RELEASE</version>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.18</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>commons-lang</groupId>
            <artifactId>commons-lang</artifactId>
            <version>2.6</version>
        </dependency>
    </dependencies>

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

</project>

service

Dubbo предоставляет метод объявления службы @Service, хотя он такой же, как метод объявления службы Springboot, но они относятся к разным пакетам. Имя пакета dubbo — com.alibaba.dubbo.config.annotation.Service, не вводите в заблуждение.

конфигурация свойства

#当前服务/应用的名字
dubbo.application.id=provider
dubbo.application.name=provider
dubbo.application.qos-enable=false
dubbo.scan.basePackages=com.lamarsan.provider.service.impl
#通信规则（通信协议和接口）
dubbo.protocol.id=dubbo
dubbo.protocol.name=dubbo
dubbo.protocol.port=12346
#注册中心的协议和地址
dubbo.registry.protocol=zookeeper
dubbo.registry.address=xxxxx:2181
user.service.version=1.0.0
spring.datasource.url=jdbc:mysql://localhost:3306/debate?serverTimezone=GMT%2B8&&useCursorFetch=true&&characterEncoding=utf8
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

mybatis.mapper-locations = classpath*:mapper/*.xml

элемент запуска

package com.lamarsan.provider;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ComponentScan;

@SpringBootApplication
@EnableDubbo
@ComponentScan(basePackages = {"com.lamarsan.provider"})   //dubbo扫描的包
@MapperScan("com.lamarsan.provider.dao")
public class ProviderApplication {

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

}

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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>com.lamarsan</groupId>
        <artifactId>dubbo_demo</artifactId>
        <version>1.0-SNAPSHOT</version>
    </parent>

    <groupId>com.lamarsan</groupId>
    <artifactId>consumer</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>consumer</name>
    <description>Demo project for Spring Boot</description>

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

    <dependencies>
        <dependency>
            <groupId>com.lamarsan</groupId>
            <artifactId>provider</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <version>2.0.1.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <version>2.0.1.RELEASE</version>
            <scope>test</scope>
        </dependency>
        <!--引入web依赖-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
            <version>2.0.1.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <version>2.0.1.RELEASE</version>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.18</version>
            <scope>provided</scope>
        </dependency>
    </dependencies>

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

</project>

controller

dubbo предоставляет аннотацию @Reference, которая может заменить аннотацию @Autowired и используется для представления удаленных микросервисов. com.alibaba.dubbo.config.annotation.Reference

конфигурация свойства

# ApplicationConfig Bean
dubbo.application.id = consumer
dubbo.application.name = consumer
dubbo.application.qos-enable = false
dubbo.consumer.timeout=60000
dubbo.consumer.retries=0

server.port = 8098
# zookeeper
## ProtocolConfig Bean
dubbo.protocol.id = dubbo
dubbo.protocol.name = dubbo
dubbo.registry.protocol = zookeeper
dubbo.registry.address = xxxxx:2181

элемент запуска

package com.lamarsan.consumer;

import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ComponentScan;

@SpringBootApplication
@EnableDubbo
@ComponentScan(basePackages = {"com.lamarsan.consumer"})
public class ConsumerApplication {

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

результат вызова

Сначала запустите модуль провайдера, затем запустите модуль потребителя, чтобы прочитать информацию о пользователе из базы данных:

Выше описан весь процесс строительства. Ниже приведены ответы на некоторые вопросы, возникшие в процессе строительства.

Ступая на яму

1) Источник данных не настроен автоматически

Failed to auto-configure a DataSource: 'spring.datasource.url' is not specified and no embedded datasource could be auto-configured.
Источник данных приглашения настроен неправильно.

Решение 1

добавить в потребительский запускexclude = {DataSourceAutoConfiguration.class}, как показано на рисунке:

Решение 2

Просто удалите зависимости между mybatis и базой данных в pom.xml потребительского модуля. Поскольку я не обратил внимание на эту деталь в начале, она была скопирована и вставлена ​​прямо из pom.xml производителя, поэтому об этой ошибке было сообщено.

2) Сервисная сторона запускается корректно, но метод в сервисе не вызывается

No provider available from registry 127.0.0.1:2181 for service com.focussend.email.service.EdmTaskS
Указывает, что услуга недоступна. Поскольку информация о версии была добавлена ​​в @service(version="") ранее, но сторона потребителя не определила ее, возникла проблема несогласованности версий, поэтому ее нельзя было запустить корректно.

Решение 1

Удалите содержимое в скобках @service.

Решение 2

Определите информацию о версии в dubbo.xml на стороне потребителя.

3) Исключение привязки базы данных

org.apache.ibatis.binding.BindingException: Invalid bound statement (not found)
Ошибки, которые появляются в Интернете, - это то же сообщение о том, что имя mapper.xml и класс интерфейса слоя dao несовместимы и проблема пространства имен, а также есть проблемы, что файл .xml не генерируется, но они не применимы к их собственной ситуации. В итоге оказалось, что проблема в объявлении элемента конфигурации.

решение

В файле .properties добавьте:mybatis.mapper-locations = classpath*:mapper/*.xmlОдна строка для сканирования карты.

Суммировать

Я использовал фреймворк даббо, который другие строили раньше, но сам построил набор и обнаружил, что ямы действительно не обычные.Я часто наступаю на некоторые ямы, которые другие считают само собой разумеющимися и имеют правильную конфигурацию.Не смотрите в есть только три исключения, от начала до строительства. На сборку ушло почти четыре часа, лихорадочно выискивая проблемы. Но эти ямки имеют смысл, и они действительно заставляют меня, человека с плохой памятью, глубоко их помнить.

Наконец, дайте адрес gihub этого проекта:GitHub.com/Ramarensan/Ду…

Категории