zoukankan      html  css  js  c++  java
  • Dubbo 消费者

    1. pom

          <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.6.2</version>
            </dependency>
    
            <dependency>
                <groupId>org.apache.curator</groupId>
                <artifactId>curator-framework</artifactId>
                <version>2.12.0</version>
            </dependency>    

    2. 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://dubbo.apache.org/schema/dubbo"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
    http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd
    http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd">


    <dubbo:application name="order-consumer"></dubbo:application>

    <!--注册中心-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>

    <!--声明要调用的远程服务接口,生成远程服务代理 retries="3"重试次数-->
       <dubbo:reference interface="com.aynu.service.UserService" id="userService" retries="3" version="*">

    </dubbo:reference>
      
      <dubbo:consumer check="false" timeout="5000"></dubbo:consumer>

    <!--生成包扫描-->
    <context:component-scan base-package="com.aynu.service"/>

    <!--连接监控中心,去注册中心找-->
    <dubbo:monitor protocol="registry"></dubbo:monitor>

    <!--直接连接监控中心-->
    <!--<dubbo:monitor address="127.0.0.1:7070"></dubbo:monitor>-->


    </beans>

    3. 启动类

    package com.aynu;
    
    import com.aynu.service.OrderService;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import java.io.IOException;
    
    public class Application {
    
        @SuppressWarnings("resource")
        public static void main(String[] args) throws IOException {
            ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("consumer.xml");
    
            OrderService orderService = applicationContext.getBean(OrderService.class);
    
            orderService.initOrder("1");
            System.out.println("调用完成....");
            System.in.read();
        }
    }
  • 相关阅读:
    Validation failed for one or more entities
    sql 存储过程
    SQL Server分页3种方案比拼
    case when 用法
    C#如何计算代码执行时间
    透过 Jet.OLEDB 读取 Excel里面的数据
    DataBinding?资料系结?资料绑定?
    ASP.NET的OutputCache
    我想写程序#3 之 「简单地设计自己的数据表(Table)」
    我想写程序#1 之 「先确立志向」
  • 原文地址:https://www.cnblogs.com/mm163/p/10633860.html
Copyright © 2011-2022 走看看