一個系統原來是使用dubbo的，現在想把微服務架構轉為Spring Cloud。但是這個系統已經在使用中了，希望一步步的把dubbo服務一個個的轉為Spring Cloud，轉換一個使用一個，轉換的過程中盡量少影響原系統。

比如現在要轉換dubbo服務D1成Spring Cloud服務C1，D1又需要調用dubbo服務D2。怎么辦呢？如果同時轉換D1，D2的話，D2可能又會調用D3，這樣可能引用一大堆服務。這種做法肯定不可取。一種更好的解決方案是：提供一個Spring Cloud的代理服務，這個代理服務同時是一個Spring Cloud服務和dubbo客戶端，其作用就是將對Spring Cloud服務的調用轉為對dubbo服務的調用。這樣Spring Cloud服務C1需要調用的Spring Cloud服務C2就先以代理的方式實現。等服務C1測試完成后，再停掉代理中的C2，將D2轉換為真正的Spring Cloud服務C2。這樣逐步把所有的dubbo服務都轉換成Spring Cloud服務。這種方案的優點是原系統不用做任何修改，避免了修改帶來的風險。

這個方案的關鍵就是代理服務的實現。

假設有兩個dubbo服務，分別為Hello1Service和Hello2Service如下：

public interface Hello1Service {String hello(String name); } public interface Hello2Service {String hello(String name); }

創建一個MAVEN項目。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>com.example</groupId><artifactId>CloudDubboProxy</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>CloudDubboProxy</name><description>Cloud Dubbo Proxy</description><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.1.RELEASE</version><relativePath/> <!-- lookup parent from repository --></parent><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><spring-cloud.version>Finchley.RC1</spring-cloud.version></properties><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jetty</artifactId></dependency--><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.8.4</version></dependency><!-- dependency><groupId>org.javassist</groupId><artifactId>javassist</artifactId><version>3.15.0-GA</version></dependency--><dependency><groupId>org.apache.mina</groupId><artifactId>mina-core</artifactId><version>1.1.7</version></dependency><dependency><groupId>org.glassfish.grizzly</groupId><artifactId>grizzly-core</artifactId><version>2.1.4</version></dependency><dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.5.5</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.1.39</version></dependency><dependency><groupId>org.apache.bsf</groupId><artifactId>bsf-api</artifactId><version>3.1</version></dependency><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.6</version></dependency><dependency><groupId>com.github.sgroschupf</groupId><artifactId>zkclient</artifactId><version>0.1</version></dependency><!-- dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>2.5.0</version></dependency--><dependency><groupId>com.googlecode.xmemcached</groupId><artifactId>xmemcached</artifactId><version>1.3.6</version></dependency><dependency><groupId>de.ruedigermoeller</groupId><artifactId>fst</artifactId><version>1.55</version></dependency></dependencies><dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency><!-- dependency><groupId>com.alibaba</groupId><artifactId>dubbo-parent</artifactId><version>2.8.4</version><type>pom</type><scope>import</scope></dependency--> </dependencies></dependencyManagement><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build><repositories><repository><id>spring-milestones</id><name>Spring Milestones</name><url>https://repo.spring.io/milestone</url><snapshots><enabled>false</enabled></snapshots></repository><repository><id>alimaven</id><name>aliyun maven</name><url>http://maven.aliyun.com/nexus/content/groups/public/</url><snapshots><enabled>false</enabled></snapshots></repository><repository> <id> central</id> <name> Maven Repository Switchboard</name> <layout> default</layout> <url> http://repo1.maven.org/maven2</url> <snapshots> <enabled> false</enabled> </snapshots> </repository> </repositories></project>

dubbo的Spring配置文件：

<?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-2.5.xsdhttp://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"><dubbo:application name="demo-consumer" owner="programmer" organization="dubbox"/><dubbo:registry address="zookeeper://127.0.0.1:2181"/><!--uncomment this if you want to test dubbo's monitor--><!--<dubbo:monitor protocol="registry"/>--><dubbo:reference id="hello1Service" interface="com.alibaba.dubbo.demo.hello.Hello1Service"/><dubbo:reference id="hello2Service" interface="com.alibaba.dubbo.demo.hello.Hello2Service"/> </beans>

Spring Cloud的配置文件：

#debug: true eureka:client:serviceUrl:defaultZone: http://localhost:8761/eureka/ server:port: 9999 spring:application:name: service-aapplication:name: service-b

注意：Spring Cloud 1.x中只支持一個服務，Spring Cloud 2.x中可以定義多個服務。

代理的啟動類：

@SpringBootApplication @EnableEurekaClient @RestController public class CloudDubboProxyApplication {private static Hello1Service hello1Service;private static Hello2Service hello2Service;public static void main(String[] args) {ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("classpath:application-context.xml");context.start();hello1Service = context.getBean(Hello1Service.class);hello2Service = context.getBean(Hello2Service.class);SpringApplication.run(CloudDubboProxyApplication.class, args);}@RequestMapping("/a")public String ma(@RequestParam String name) {String s = hello1Service.hello("world");return "From Cloud service A: "+name+"<br>"+s;}@RequestMapping("/b")public String mb(@RequestParam String name) {String s = hello2Service.hello("world");return "From Cloud service B: "+name+"<br>"+s;} }

寫個測試類：

@SpringBootApplication @EnableDiscoveryClient @RestController public class DemoRibbonApplication {public static void main(String[] args) {SpringApplication.run(DemoRibbonApplication.class, args);}@Bean@LoadBalancedRestTemplate restTemplate() {return new RestTemplate();}@AutowiredRestTemplate restTemplate;@RequestMapping(value = "/a")public String ha(@RequestParam String name){return restTemplate.getForObject("http://SERVICE-A/a?name="+name,String.class);} @RequestMapping(value = "/b")public String hb(@RequestParam String name){return restTemplate.getForObject("http://SERVICE-B/b?name="+name,String.class);} }

可以驗證確實實現了Spring Cloud調用dubbo功能。

總結

以上是生活随笔為你收集整理的dubbo转Spring Cloud的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。