Dubbo、Spring、Zookeeper、集成基础案例(多版本兼容发布)

迈不过友情╰ 2024-02-18 23:43 129阅读 0赞

**摘要**：最近抽时间系统的学习了Dubbo的一些内容，趁有时间，整理下，顺便记录下，以防以后回顾。前面我们学校了Dubbo的参数回调，本次我们学习下Dubbo的多版本兼容发布、当一个接口实现、，出现不兼容升级时，可以用版本号过渡，版本号不同的服务相互间不引用。可以按照以下的步骤进行版本迁移：

**1>**.在低压力时间段，先升级一半提供者为新版本

**2>**.再将所有消费者升级为新版本

**3>**.然后将剩下的一半提供者升级为新版本

**一：运行环境**

1>:JDK 1.8

2>:IDEA 2018.1

3>:Zookeeper 3.x

4>:Maven 3.2

5>:Dubbo 2.8.4

**二：项目结构**

![70][]

三：服务提供者、pom.xml和上一篇一样，这里就不再贴出来了

VersionService.java

package com.micai.dubbo.provider;
    
    /**
     * @Auther: zhaoxinguo
     * @Date: 2018/9/13 17:44
     * @Description:
     */
    public interface VersionService {
    
        String sayHello(String name);
    }

VersionServiceImpl.java

package com.micai.dubbo.provider;
    
    import com.alibaba.dubbo.config.annotation.Service;
    
    /**
     * @Auther: zhaoxinguo
     * @Date: 2018/9/13 17:44
     * @Description:
     */
    @Service(version = "1.0.0")
    public class VersionServiceImpl implements VersionService {
    
        @Override
        public String sayHello(String name) {
            return "hello, " + name;
        }
    }

VersionServiceImpl2.java

package com.micai.dubbo.provider;
    
    import com.alibaba.dubbo.config.annotation.Service;
    
    /**
     * @Auther: zhaoxinguo
     * @Date: 2018/9/13 17:45
     * @Description:
     */
    @Service(version = "2.0.0")
    public class VersionServiceImpl2 implements VersionService {
    
        @Override
        public String sayHello(String name) {
            return "hello2, " + name;
        }
    }

Provider.java

package com.micai.dubbo;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import java.io.IOException;
    
    /**
     * @Auther: zhaoxinguo
     * @Date: 2018/9/10 14:13
     * @Description:
     */
    public class Provider {
    
        public static void main(String [] args) {
            ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
            classPathXmlApplicationContext.start();
            try {
                System.in.read();//按任意键退出
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

Provider2.java

package com.micai.dubbo;
    
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import java.io.IOException;
    
    /**
     * @Auther: zhaoxinguo
     * @Date: 2018/9/10 14:13
     * @Description:
     */
    public class Provider2 {
    
        public static void main(String [] args) {
            ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("applicationContext2.xml");
            classPathXmlApplicationContext.start();
            try {
                System.in.read();//按任意键退出
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

applicationContext.xml

applicationContext2.xml

四：服务消费者、pom.xml和上一篇一样，这里就不再贴出来了

VersionAction.java

package com.micai.dubbo.consumer;
    
    import com.alibaba.dubbo.config.annotation.Reference;
    import com.micai.dubbo.provider.VersionService;
    import org.springframework.stereotype.Component;
    
    /**
     * @Auther: zhaoxinguo
     * @Date: 2018/9/13 17:54
     * @Description:
     */
    @Component
    public class VersionAction {
    
        @Reference(version = "1.0.0")
        private VersionService versionService;
    
        @Reference(version = "2.0.0")
        private VersionService versionService2;
    
        public String sayHello() {
            String result = versionService.sayHello("world");
            return result;
        }
    
        public String sayHello2() {
            String result = versionService2.sayHello("world");
            return result;
        }
    
    }

Consumer.java

package com.micai.dubbo;
    
    import com.micai.dubbo.consumer.VersionAction;
    import com.micai.dubbo.provider.VersionService;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import java.io.IOException;
    
    /**
     * @Auther: zhaoxinguo
     * @Date: 2018/9/11 14:36
     * @Description:
     */
    public class Consumer {
    
        public static void main(String [] args) {
            try {
                ClassPathXmlApplicationContext classPathXmlApplicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
                classPathXmlApplicationContext.start();
                VersionAction versionAction = (VersionAction) classPathXmlApplicationContext.getBean("versionAction");
                String result = versionAction.sayHello();
                System.out.println("版本1调用返回结果：" + result);
                Thread.sleep(2000);
                String result2 = versionAction.sayHello2();
                System.out.println("版本2调用返回结果：" + result2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

applicationContext.xml

五：运行结果

![70 1][]

六：下载源码请加群下载

![70 2][] QQ交流群

[70]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/20943023bed14f33b66f03bdec2ab959.png
[70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/fdd7818ce82642bcb2a02e746e1cb95f.png
[70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/43e39da522fd4b13a754ce1083323b7b.png