Dubbo在Spring和SpringBoot中的使用详解

  com.alibaba
  dubbo
  2.5.3.6
  
    
      log4j
      log4j
    
    
      commons-logging
      commons-logging
    
    
      org.springframework
      spring
    
    
      com.alibaba
      fastjson
    
  


  com.github.sgroschupf
  zkclient
  0.1

<&＃63;xml version="1.0" encoding="UTF-8"&＃63;>

 
 
 
 
 
 
 
 
 
 
 

<&＃63;xml version="1.0" encoding="UTF-8"&＃63;>

 
 
 
 
 
 
 

  org.springframework.boot
  spring-boot-starter-web
  1.2.5.RELEASE


  org.springframework.boot
  spring-boot-starter
  1.2.5.RELEASE


  com.alibaba
  dubbo
  2.5.3.6
  
    
      log4j
      log4j
    
    
      commons-logging
      commons-logging
    
    
      org.springframework
      spring
    
    
      com.alibaba
      fastjson
    
  


  com.github.sgroschupf
  zkclient
  0.1

public class DubboBaseConfig {
  @Bean
  public RegistryConfig registry() {
    RegistryConfig registryCOnfig= new RegistryConfig();
    registryConfig.setAddress("127.0.0.1:2181");
    registryConfig.setProtocol("zookeeper");
    return registryConfig;
  }
  @Bean
  public ApplicationConfig application() {
    ApplicationConfig applicatiOnConfig= new ApplicationConfig();
    applicationConfig.setName("testApp");
    return applicationConfig;
  }
  @Bean
  public MonitorConfig monitorConfig() {
    MonitorConfig mc = new MonitorConfig();
    mc.setProtocol("registry");
    return mc;
  }
  @Bean
  public ReferenceConfig referenceConfig() {
    ReferenceConfig rc = new ReferenceConfig();
    rc.setMonitor(monitorConfig());
    return rc;
  }
  @Bean
  public ProtocolConfig protocol() {
    ProtocolConfig protocolCOnfig= new ProtocolConfig();
    protocolConfig.setPort(20880);
    return protocolConfig;
  }
  @Bean
  public ProviderConfig provider() {
    ProviderConfig providerCOnfig= new ProviderConfig();
    providerConfig.setMonitor(monitorConfig());
    return providerConfig;
  }
}

@Configuration
public class ExportServiceConfig extends DubboBaseConfig {
  @Bean
  public ServiceBean personServiceExport(Person person) {
    ServiceBean serviceBean = new ServiceBean();
    serviceBean.setProxy("javassist");
    serviceBean.setVersion("myversion");
    serviceBean.setInterface(Person.class.getName());
    serviceBean.setRef(person);
    serviceBean.setTimeout(5000);
    serviceBean.setRetries(3);
    return serviceBean;
  }
}

@Configuration
public class ReferenceConfig extends DubboBaseConfig {
  @Bean
  public ReferenceBean person() {
    ReferenceBean ref = new ReferenceBean<>();
    ref.setVersion("myversion");
    ref.setInterface(Person.class);
    ref.setTimeout(5000);
    ref.setRetries(3);
    ref.setCheck(false);
    return ref;
  }
}