Dubbo常用功能04--使用url指定服務

1、apolication.yml的配置：

server:
  port: 8001
dubbo:
  application:
    name: site-service-boot-provider
  registry:
    address: zookeeper://ubu:2181
  scan:
    base-packages: com.yas.serviceprovider
#  #指定某一種協議
#  protocol:
#    name: dubbo
#    port: 20882

#  protocol:
#    name: rest
#    port: 8787

  #指定多種協議
  protocols:
    pro1:
      id: dubbo1
      name: dubbo
      port: 20881
      host: 0.0.0.0
    pro2:
      id: dubbo2
      name: dubbo
      port: 20882
      host: 0.0.0.0

 

2、服務提供者代碼：

package com.yas.serviceprovider.impl;

import com.yas.api.SiteService;
import org.apache.dubbo.common.URL;
import org.apache.dubbo.config.annotation.Service;
import org.apache.dubbo.rpc.RpcContext;

@Service(version = "url")
public class URLSiteServiceImpl implements SiteService {

    @Override
    public String getName(String name) {
        URL url = RpcContext.getContext().getUrl();
        return "url:" + name+",使用的協議是:"+url.getProtocol()+",端口是:"+url.getPort();
    }
}

 

注意第8行，沒有指定protocol參數，則表示配置文件中配置的20881和20882端口的服務都會啟動。

 

3、服務消費者的代碼：

package com.yas.serviceconsumer.controller;

import com.yas.api.SiteService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class ProtocolSiteController {

//    @Reference(version = "default",protocol = "")
//    SiteService siteService1;
//
//    @RequestMapping("/pro1")
//    public String getName1(@RequestParam("name") String name){
//        return siteService1.getName(name);
//    }
//
//    @Reference(version = "async",protocol = "")
//    SiteService SiteService2;
//
//    @RequestMapping("/pro2")
//    public String getName2(@RequestParam("name") String name){
//        return SiteService2.getName(name);
//    }

    @Reference(version = "url",url = "dubbo://127.0.0.1:20882/com.yas.api.SiteService:url")
    SiteService SiteService3;

    @RequestMapping("/url")
    public String getName3(@RequestParam("name") String name) {
        return SiteService3.getName(name);
    }
}

 

4、測試：

使用postman請求地址：http://localhost:8000/url?name=zhangsan

得到響應：url:zhangsan,使用的協議是:dubbo,端口是:20882