dubbo直连

dubbo的直连方式即消费方不通过zookeeper注册中心去调用注册的服务，而是直接绕过zookeeper环节直接调用服务

2017-05-21_154952.png

直接上代码

【服务方provider】
接口：dubbo.direct.provider.DirectService.java

public interface DirectService {

    public String direct() throws Exception;
}

接口实现：dubbo.direct.provider.impl.DirecyServiceImpl.java

public class DirectServiceImpl implements DirectService{

    @Override
    public String direct() throws Exception {
        
        return "执行 DirectService exe";
    }

}

服务发布类：dubbo.direct.test.provider.java

public class Provider {

    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"direct-provider.xml"});
        context.start();
        System.in.read();//为保证服务一直开着，利用输入流阻塞来模拟，开发中，这些应该打jar包在服务器上运行
    }
}

XML配置：direct-provider.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">
 
    <!-- 具体实现bean  扫描代替 -->
    <bean id="directService" class="dubbo.direct.provider.impl.DirectServiceImpl" />
   
    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="direct-provider"  />
 
    <!-- 注意：dubbo直连不需要zookeeper做注册中心,但是还得配置否则报错 ,register="false"(只订阅，不注册) sbuscribe=false(只注册，不订阅)  -->
    <dubbo:registry address="zookeeper://192.168.22.128:2181" register="false" />
    
    <!-- 用dubbo协议在20880端口暴露服务 -->
    <dubbo:protocol name="dubbo" port="20882" />
    
    <!-- 声明需要暴露的服务接口，写操作可以设置retries=0避免重复调用SOA服务  注解代替--> 
    <dubbo:service interface="dubbo.direct.provider.DirectService" ref="directService" />
 
</beans>

启动服务

2017-05-21_162349.png

这里可以设置订阅与注册（只订阅不注册、只注册不订阅）

【消费方consumer】
接口：dubbo.direct.provider.DirectService.java

public interface DirectService {

    public String direct() throws Exception;
}

测试调用类：dubbo.direct.test.Consumer.java

public class Consumer {

    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"direct-consumer.xml"});
        context.start();
        
        DirectService directService = (DirectService) context.getBean("directService");
        
        System.out.println(directService.direct());
    }
}

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="direct-consumer"  />
 
    <!-- 使用zookeeper注册中心暴露发现服务地址 -->
    <dubbo:registry address="zookeeper://192.168.22.128:2181" />
 
    <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
    <dubbo:reference id="directService" url="dubbo://localhost:20882" interface="dubbo.direct.provider.DirectService" />
 
</beans>

调用

2017-05-21_162913.png 2017-05-21_162944.png