dubbo之dubbo协议使用

普通接口及实现类

public interface DemoService
{
    String sayHello(String msg);
}

public class DemoServiceImpl implements DemoService
{

    public String sayHello(String msg)
    {
        return "hello " + msg;
    }
}

服务提供者配置

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

    
    

    
    

    
    

    
    

    
    

服务消费者配置

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

    
    

    
    

    
    

运行测试

public class Provider
{
    public static void main(String[] args) throws Exception
    {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-dubbo-provider.xml");
        context.start();

        System.in.read(); // 按任意键退出
    }
}

public class Consumer
{
    public static void main(String[] args) throws Exception
    {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-dubbo-consumer.xml");
        context.start();

        DemoService demoService = (DemoService)context.getBean("demoService"); // 获取远程服务代理
        String hello = demoService.sayHello("world"); // 执行远程方法

        System.err.println( hello ); // 显示调用结果
    }
}

直连模式

服务提供者,不用将服务注册到注册中心,并在dubbo:service配置中增加registry="N/A";

同时,服务消费者也不需要通过注册中心发现服务,并在dubbo:reference配置中增加url="dubbo://localhost:20880"直连地址.

相反,则通过注册中心来获取连接地址.