Dubbo と Zookeeper を利用した XML 設定による RPC システム構築

1. プロジェクト構成（Maven マルチモジュール）

本構成では、Maven のマルチモジュールプロジェクトを採用し、API、Provider、Consumer の 3 つのモジュールに分割します。これにより、依存関係の明確化とビルドの効率化を図ります。

2. 親 POM 設定

ルートプロジェクトの POM ファイルでは、共通の依存ライブラリとプロパティを定義します。Dubbo、Zookeeper、Spring Framework などの主要ライブラリを含めます。

<?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.example.rpc</groupId>
    <artifactId>dubbo-zk-integration</artifactId>
    <packaging>pom</packaging>
    <version>1.0.0</version>
    <modules>
        <module>api</module>
        <module>provider</module>
        <module>consumer</module>
    </modules>

    <properties>
        <dubbo.version>2.5.3</dubbo.version>
        <spring.version>4.3.6.RELEASE</spring.version>
        <java.version>1.7</java.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <!-- Dubbo 依存 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>${dubbo.version}</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.3.3</version>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <dependency>
            <groupId>com.netflix.curator</groupId>
            <artifactId>curator-framework</artifactId>
            <version>1.1.10</version>
        </dependency>

        <!-- Spring Framework -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
    </dependencies>
</project>

3. API モジュール

3.1 POM 設定

API モジュールはインターフェース定義のみを含むため、依存関係は最小限に抑えます。

<?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>dubbo-zk-integration</artifactId>
        <groupId>com.example.rpc</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>api</artifactId>
</project>

3.2 サービスインターフェース

共有されるサービス契約を定義します。

package com.example.rpc.service;

public interface MessageService {
    String transmit(String input);
}

4. Provider モジュール

4.1 POM 設定

API モジュールへの依存を追加します。

<?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>dubbo-zk-integration</artifactId>
        <groupId>com.example.rpc</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>provider</artifactId>
    <dependencies>
        <dependency>
            <groupId>com.example.rpc</groupId>
            <artifactId>api</artifactId>
            <version>1.0.0</version>
        </dependency>
    </dependencies>
</project>

4.2 ログ設定 (log4j.properties)

log4j.rootLogger=info, stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.out
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=[%d{HH:mm:ss}] %5p %c{1}: %m%n

4.3 Dubbo 提供者設定 (spring-provider-context.xml)

Zookeeper をレジストリとして使用し、サービスを公開します。

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

    <bean id="messageServiceImpl" class="com.example.rpc.service.MessageServiceImpl"/>
    
    <dubbo:application name="service-provider"/>
    <dubbo:registry address="zookeeper://127.0.0.1:2181" client="curator"/>
    <dubbo:protocol name="dubbo" port="20880"/>
    <dubbo:service interface="com.example.rpc.service.MessageService" 
                   ref="messageServiceImpl" 
                   timeout="6000"/>
</beans>

4.4 サービス実装

package com.example.rpc.service;

public class MessageServiceImpl implements MessageService {
    @Override
    public String transmit(String input) {
        return "Received: " + input;
    }
}

4.5 起動クラス

package com.example.rpc;

import org.springframework.context.support.ClassPathXmlApplicationContext;
import java.io.IOException;

public class ProviderStarter {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext appContext = new ClassPathXmlApplicationContext("spring-provider-context.xml");
        appContext.start();
        System.out.println("Provider service is running...");
        System.in.read();
    }
}

5. Consumer モジュール

5.1 POM 設定

Provider と同様に API への依存が必要です。

<?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>dubbo-zk-integration</artifactId>
        <groupId>com.example.rpc</groupId>
        <version>1.0.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>consumer</artifactId>
    <dependencies>
        <dependency>
            <groupId>com.example.rpc</groupId>
            <artifactId>api</artifactId>
            <version>1.0.0</version>
        </dependency>
    </dependencies>
</project>

5.2 Dubbo 消費者設定 (spring-consumer-context.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"
       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">

    <dubbo:application name="service-consumer"/>
    <dubbo:registry protocol="zookeeper" address="zookeeper://127.0.0.1:2181"/>
    <dubbo:reference id="messageService" interface="com.example.rpc.service.MessageService"/>
</beans>

5.3 起動クラス

package com.example.rpc;

import com.example.rpc.service.MessageService;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class ConsumerStarter {
    public static void main(String[] args) {
        ClassPathXmlApplicationContext appContext = new ClassPathXmlApplicationContext("spring-consumer-context.xml");
        appContext.start();
        MessageService service = (MessageService) appContext.getBean("messageService");
        String result = service.transmit("Hello Dubbo");
        System.out.println("Response: " + result);
    }
}

タグ: Dubbo ZooKeeper spring-xml Maven distributed-system

9月19日 03:33 投稿

ホットタグ

©2026 異端開発室