Dubbo和Zookeeper

<!-- dubbo相关 -->
<dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>dubbo</artifactId>
  <version>2.6.6</version>
</dependency>
<dependency>
  <groupId>io.netty</groupId>
  <artifactId>netty-all</artifactId>
  <version>4.1.32.Final</version>
</dependency>
<dependency>
  <groupId>org.apache.curator</groupId>
  <artifactId>curator-framework</artifactId>
  <version>4.0.0</version>
  <exclusions>
    <exclusion>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
    </exclusion>
  </exclusions>
</dependency>
<dependency>
  <groupId>org.apache.zookeeper</groupId>
  <artifactId>zookeeper</artifactId>
  <version>3.4.7</version>
</dependency>
<dependency>
  <groupId>com.github.sgroschupf</groupId>
  <artifactId>zkclient</artifactId>
  <version>0.1</version>
</dependency>

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xmlns="http://java.sun.com/xml/ns/javaee"
         xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
         version="2.5">
  <!-- 监听器监听其他的spring配置文件 -->
  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath:applicationContext-*.xml</param-value>
  </context-param>
  <listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>
</web-app>

/**
 * 服务提供者的service层接口
 * @author Mr.song
 * @date 2019/05/12 21:42
 */
public interface HelloDubboService {
    String helloDubbo(String name);
}

/**
 * 服务提供者者（service层）
 * @author Mr.song
 * @date 2019/05/12 21:33
 */
@Service
public class HelloDubboServiceImpl implements HelloDubboService {
    public String helloDubbo(String name){
        return "Hello" + name;
    }
}

<?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://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">
    <!--指定dubbo的服务名称，不能重复-->
    <dubbo:application name="dubbodemo_provider"></dubbo:application>
    <!--指定注册到zookeeper的地址 ip为zookeeper所在服务器的地址 -->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
    <!--指定当前服务使用的 协议和端口 端口默认是：20880 -->
    <dubbo:protocol name="dubbo" port="20888"></dubbo:protocol>
    <!--指定提供服务类所在的包,有@Service注解的类会被发布为服务-->
    <dubbo:annotation package="cn.dintalk.service"></dubbo:annotation>
</beans>

/**
 * @author Mr.song
 * @date 2019/05/13 14:27
 */
public class HelloDubboProvider {
    public static void main(String[] args) throws IOException {
        ClassPathXmlApplicationContext context =
                new ClassPathXmlApplicationContext("classpath*:applicationContext-*.xml");
        context.start();
        System.in.read(); // 按任意键退出
    }

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xmlns="http://java.sun.com/xml/ns/javaee"
         xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
         version="2.5">
  <servlet>
    <servlet-name>springmvc</servlet-name>
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <!-- 指定加载的配置文件 ，通过参数contextConfigLocation加载-->
    <init-param>
      <param-name>contextConfigLocation</param-name>
      <param-value>classpath:applicationContext-web.xml</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>springmvc</servlet-name>
    <url-pattern>*.do</url-pattern>
  </servlet-mapping>
</web-app>

/**
 * 服务消费者的service层接口: 和提供者一模一样
 * @author Mr.song
 * @date 2019/05/12 21:43
 */
public interface HelloDubboService {
    String helloDubbo(String name);
}

/**
 * 服务消费者（web层）
 * @author Mr.song
 * @date 2019/05/12 21:35
 */
@Controller
public class HelloDubboController {
    @Reference
    private HelloDubboService helloDubboService;
    @RequestMapping("/hello")
    public @ResponseBody String hello(String name){
        return helloDubboService.helloDubbo(name);
    }
}

<?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://code.alibabatech.com/schema/dubbo"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
       http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc.xsd
        http://code.alibabatech.com/schema/dubbo 
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context.xsd">
    <!--创建容器时要扫描的包-->
    <context:component-scan base-package="cn.dintalk.web"></context:component-scan>
    <!--开启springmvc对注解的支持-->
    <mvc:annotation-driven></mvc:annotation-driven>
    
    <!--指定注册到dubbo中的服务名称，它不能重复-->
    <dubbo:application name="dubbodemo_consumer"></dubbo:application>
    <!--指定zookeeper的地址:连接服务中心 ip 为zookeeper所在服务器ip-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"></dubbo:registry>
    <!--指定dubbo的注解包扫描-->
    <dubbo:annotation package="cn.dintalk.web"></dubbo:annotation>
    <!--做合理化检查的看看注册中心中有没有提供者信息(开发阶段默认false)
       check的取值：true：表示做检查  false：表示不检查
    -->
    <dubbo:consumer check="false"></dubbo:consumer>
</beans>

//提供者配置负载均衡
@Service(interfaceClass=HelloDubboService.class,loadbalance="random")
//消费者配置负载均衡
@Reference(check=false,loadbalance="random")