Dubbo快速启动

素颜马尾好姑娘i 2022-02-24 01:10 194阅读 0赞

> Dubbo 安装

Dubbo的安装实例可以参考阿里的Dubbo文档

### 快速启动 ###

> 服务提供者

*  定义服务接口

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

*  服务提供方实现接口

import com.alibaba.dubbo.demo.DemoService;
     
        public class DemoServiceImpl implements DemoService {
            public String sayHello(String name) {
                return "Hello " + name;
            }
        }

*  用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://dubbo.apache.org/schema/dubbo"
            xsi:schemaLocation="http://www.springframework.org/schema/beans        
            http://www.springframework.org/schema/beans/spring-beans-4.3.xsd        
            http://dubbo.apache.org/schema/dubbo        
            http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
         
            
            <dubbo:application name="hello-world-app"  />
         
            
            <dubbo:registry address="multicast://224.5.6.7:1234" />
         
            
            <dubbo:protocol name="dubbo" port="20880" />
         
            
            <dubbo:service interface="com.alibaba.dubbo.demo.DemoService" ref="demoService" />
         
            
            <bean id="demoService" class="com.alibaba.dubbo.demo.provider.DemoServiceImpl" />
        </beans>

*  加载Spring配置

import org.springframework.context.support.ClassPathXmlApplicationContext;
         
        public class Provider {
            public static void main(String[] args) throws Exception {
                ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"http://10.20.160.198/wiki/display/dubbo/provider.xml"});
                context.start();
                System.in.read(); // 按任意键退出
            }
        }

> 服务消费者

*  通过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://dubbo.apache.org/schema/dubbo"
            xsi:schemaLocation="http://www.springframework.org/schema/beans        
            http://www.springframework.org/schema/beans/spring-beans-4.3.xsd        
            http://dubbo.apache.org/schema/dubbo        
            http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
         
            
            <dubbo:application name="consumer-of-helloworld-app"  />
         
            
            <dubbo:registry address="multicast://224.5.6.7:1234" />
         
            
            <dubbo:reference id="demoService" interface="com.alibaba.dubbo.demo.DemoService" />
        </beans>

*  加载Spring配置，并调用远程服务

import org.springframework.context.support.ClassPathXmlApplicationContext;
        import com.alibaba.dubbo.demo.DemoService;
         
        public class Consumer {
            public static void main(String[] args) throws Exception {
                ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"http://10.20.160.198/wiki/display/dubbo/consumer.xml"});
                context.start();
                DemoService demoService = (DemoService)context.getBean("demoService"); // 获取远程服务代理
                String hello = demoService.sayHello("world"); // 执行远程方法
                System.out.println( hello ); // 显示调用结果
            }
        }