(四)Dubbo 2.7 整合Spring(xml形式)

(四)Dubbo 2.7 整合Spring(xml形式),第1张

(四)Dubbo 2.7 整合Spring(xml形式) Dubbo整合Spring(xml形式)

Dubbo 在 spring xml 形式的配置要比SpringBoot 注解形式的配置 可读性要更友好。

springboot项目也推荐使用 xml 形式配置 dubbo

因为Dubbo 是可以具体到方法级别的,使用xml配置起来更直观。(官方也推荐)

本文就来使用 Dubbo 2.7 整合 Spring。

项目结构如下:

父类项目依赖 pom.xml :

	
        2.7.13
        4.3.16.RELEASE
    
    
        
            
                org.springframework
                spring-framework-bom
                ${spring.version}
                pom
                import
            
            
                org.apache.dubbo
                dubbo-bom
                ${dubbo.version}
                pom
                import
            

            
                org.apache.dubbo
                dubbo-dependencies-zookeeper
                ${dubbo.version}
                pom
            

        
    
1、创建api

创建dubbo-samples-xml-api项目,定义一个接口:

OrderService.java

public interface OrderService {
   List getOrderInfo(long orderId);
}

Order.java:

@Data
@NoArgsConstructor
@AllArgsConstructor
public class Order implements Serializable {

    private static final long serialVersionUID = -3757842094691885448L;
    Long orderId;
    String orderName;

}
2、创建provider

dubbo-provider.xml:







OrderServiceImpl.java ,实现接口:

@Service("orderServiceImpl")
@Slf4j
public class OrderServiceImpl implements OrderService {

    @Override
    public List getOrderInfo(long orderId) {
        
        List list = new ArrayList<>();
        Order order1 = new Order();
        order1.setOrderId(199L);
        order1.setOrderName("MacBook Pro 13");

        Order order2 = new Order();
        order2.setOrderId(200L);
        order2.setOrderName("RTX 2060");

        list.add(order1);
        list.add(order2);

        return list;
    }
}

启动类Provider:

public class Provider {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"spring/dubbo-provider.xml"});
        context.start();
        System.out.println("provider service start ......");
        new CountDownLatch(1).await();
    }
}
3、创建consumer

dubbo-consumer.xml:






实现类 OrderServiceImpl:

@Service("orderServiceImpl")
@Slf4j
public class OrderServiceImpl implements OrderService {

    @Override
    public List getOrderInfo(long orderId) {
        log.info("OrderServiceImpl方法");
        log.info("request from consumer: {}", RpcContext.getContext().getRemoteAddress());
        log.info("protocol: {}",RpcContext.getContext().getProtocol());
        log.info("response from provider: {}",RpcContext.getContext().getLocalAddress());
        List list = new ArrayList<>();
        Order order1 = new Order();
        order1.setOrderId(199L);
        order1.setOrderName("MacBook Pro 13");

        Order order2 = new Order();
        order2.setOrderId(200L);
        order2.setOrderName("RTX 2060");

        list.add(order1);
        list.add(order2);

        return list;
    }
}

启动类Consumer:

public class Consumer {
    public static void main(String[] args) throws Exception {
        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"spring/dubbo-consumer.xml"});
        context.start();
        System.out.println("consumer start.....");
//        dubbo
        OrderService orderService1 = context.getBean("orderServiceImpl", OrderService.class);
        while (true) {
            System.in.read();
            RpcContext rpcContext = RpcContext.getContext();
            System.out.println("SUCCESS: got order list " + orderService1.getOrderInfo(1L));
        }
    }
}
4、测试

启动 provider,打开dubbo-admin(需要自行搭建,请参考:),可以看到provider已经注册进来了:

启动consumer,按下enter键。

consumer日志:

SUCCESS: got order list [Order(orderId=199, orderName=MacBook Pro 13), Order(orderId=200, orderName=RTX 2060)]

privider日志:

2021-12-23 11:42.35 [DubboServerHandler-172.16.44.48:20883-thread-2] -- [ INFO] - impl.OrderServiceImpl: OrderServiceImpl方法
2021-12-23 11:42.35 [DubboServerHandler-172.16.44.48:20883-thread-2] -- [ INFO] - impl.OrderServiceImpl: request from consumer: /172.16.44.48:47287
2021-12-23 11:42.35 [DubboServerHandler-172.16.44.48:20883-thread-2] -- [ INFO] - impl.OrderServiceImpl: protocol: null
2021-12-23 11:42.35 [DubboServerHandler-172.16.44.48:20883-thread-2] -- [ INFO] - impl.OrderServiceImpl: response from provider: 172.16.44.48:20883
5、总结

Dubbo是支持多种协议的,以上我演示的是 dubbo(默认)协议。除了该协议,dubbo也支持其他协议,专栏其他文章我做了dubbo、hessian、rest协议的演示:

相对SpringBoot的yml、properties配置,xml的配置更清晰明了,个人也推荐使用xml的方式配置。

项目的地址已经上传到github:https://github.com/DogerRain/dubbo-samples-test


  • Java资源分享:
    Java学习路线思维导图+Java学习视频+简历模板+Java电子书

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5684701.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-17
下一篇 2022-12-17

发表评论

登录后才能评论

评论列表(0条)

保存