dubbo、zookeeper和spring整合

一  zookeeper下载和操作

    1 下载zookeeper

       下载地址 https://mirrors.tuna.tsinghua.edu.cn/apache/zookeeper/ 

        将下载的源码包上传到linux机器上(我的在/usr/local/zookeeper/目录下),并解压

        解压的根目录的conf文件夹下有一个zoo_sample.cfg

        使用命令:cp zoo_sample.cfg  zoo.cfg  复制一份 在启动的时候会加载配置文件

    2 操作zookeeper

${zookeeper path}/bin/zkServer.sh start            进入bin目录  执行服务脚本   默认监听2181端口
${zookeeper path}/bin/zkServer.sh stop

二  项目搭建

       

  1  创建maven工程   下面创建4个模块

    api: 里面写服务接口

    service: 写api里面接口的实现类

    provider: 服务提供者  暴露服务  接收消费者的请求之后  调用实现类返回数据

    customer: 服务消费者  调用provider暴露的服务

    这里面provider和customer要发送接收请求,所以使用工程

    api和service里面只有一些类,使用工程就行了

  2  在api里面写一个接口

public interface TestRPC {
    public Map<String,String> test();
}

  3  在service里 写实现类

     首先 在service的pom文件加入api模块的依赖

public class TestRPCimpl implements TestRPC {
    public Map<String, String> test(){
        System.out.println("hello world");
        Map<String, String> map = new HashMap<String, String>();
        map.put("hello", "dubbo");
        map.put("hello", "zookeeper");
        return map;
    }
}

  4  provider服务提供者

    4.1 pom文件加入这些依赖后   再加入service模块的依赖

<properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <org.springframework.version>4.3.12.RELEASE</org.springframework.version>
    <jackson.version>2.9.3</jackson.version>
</properties>

<dependencies>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>javax.servlet-api</artifactId>
			<version>3.1.0</version>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context</artifactId>
			<version>${org.springframework.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context-support</artifactId>
			<version>${org.springframework.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-web</artifactId>
			<version>${org.springframework.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-webmvc</artifactId>
			<version>${org.springframework.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-jdbc</artifactId>
			<version>${org.springframework.version}</version>
		</dependency>

		<dependency>
			<groupId>com.fasterxml.jackson.core</groupId>
			<artifactId>jackson-core</artifactId>
			<version>${jackson.version}</version>
		</dependency>

		<dependency>
			<groupId>com.fasterxml.jackson.core</groupId>
			<artifactId>jackson-databind</artifactId>
			<version>${jackson.version}</version>
		</dependency>
		<dependency>
			<groupId>com.fasterxml.jackson.core</groupId>
			<artifactId>jackson-annotations</artifactId>
			<version>${jackson.version}</version>
		</dependency>

		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>dubbo</artifactId>
			<version>2.5.3</version>
			<exclusions>
				<exclusion>
					<artifactId>spring</artifactId>
					<groupId>org.springframework</groupId>
				</exclusion>
			</exclusions>
		</dependency>
		<dependency>
			<groupId>org.apache.zookeeper</groupId>
			<artifactId>zookeeper</artifactId>
			<version>3.4.8</version>
			<exclusions>
				<exclusion>
					<groupId>log4j</groupId>
					<artifactId>log4j</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
		<dependency>
			<groupId>log4j</groupId>
			<artifactId>log4j</artifactId>
			<version>1.2.16</version>
		</dependency>
		<dependency>
			<groupId>com.github.sgroschupf</groupId>
			<artifactId>zkclient</artifactId>
			<version>0.1</version>
		</dependency>
</dependencies>

    4.2  spring配置文件applicationContext.xml(这里面 配置dubbo 暴露服务) 

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

	<!-- 用于配置当前应用信息，不管该应用是提供者还是消费者 -->
	<dubbo:application name="test_provider" />

	<!-- 使用zookeeper注册中心暴露服务地址  ip为第一步启动zookeeper的linux机器ip  默认端口2181 -->
	<dubbo:registry address="zookeeper://192.168.0.202:2181" />

	<!-- 协议配置，用于配置提供服务的协议信息 -->
	<dubbo:protocol name="dubbo" port="20880"/>

	<!-- 声明需要暴露的服务接口 -->
	<dubbo:service interface="org.dubbo_zk.api.TestRPC" ref="testRpc" />

	<!-- 具体的实现bean -->
	<bean id="testRpc" class="org.dubbo_zk.service.TestRPCimpl" />
</beans>

 4.3 spring-mvc.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:context="http://www.springframework.org/schema/context"
	xmlns:task="http://www.springframework.org/schema/task" xmlns:mvc="http://www.springframework.org/schema/mvc"
	xmlns:tx="http://www.springframework.org/schema/tx"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
	http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
	 http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd
	  http://www.springframework.org/schema/mvc
	  http://www.springframework.org/schema/mvc/spring-mvc.xsd
	  http://www.springframework.org/schema/tx
      http://www.springframework.org/schema/tx/spring-tx.xsd"
	default-lazy-init="false">

	<mvc:annotation-driven>
		<!-- 消息转换器 -->
		<mvc:message-converters register-defaults="true">
			<bean class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter">
				<property name="supportedMediaTypes" value="text/html;charset=UTF-8" />
			</bean>
		</mvc:message-converters>
	</mvc:annotation-driven>
	<!-- 静态资源 -->
	<mvc:resources mapping="/resources/**" location="/resources/" />

	<!-- 启动SpringMVC的注解功能，完成请求和注解POJO的映射 -->
	<bean
		class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">
		<property name="messageConverters">
			<list>
				<bean
					class="org.springframework.http.converter.json.MappingJackson2HttpMessageConverter">
					<property name="supportedMediaTypes">
						<list>
							<value>text/plain;charset=UTF-8</value>
						</list>
					</property>
				</bean>
			</list>
		</property>
	</bean>
</beans>

 4.4  web.xml文件

<!DOCTYPE web-app PUBLIC
 "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
 "http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app>
	<display-name>dubbo_zk-provider</display-name>
	<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>

	<servlet>
		<servlet-name>dubbo_provider_Servlet</servlet-name>
		<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
		<init-param>
			<param-name>contextConfigLocation</param-name>
			<param-value>classpath*:spring-mvc.xml</param-value>
		</init-param>
		<load-on-startup>1</load-on-startup>
	</servlet>
	<servlet-mapping>
		<servlet-name>dubbo_provider_Servlet</servlet-name>
		<url-pattern>/</url-pattern>
	</servlet-mapping>

</web-app>

5  customer消费者

   5.1  pom文件

    加入4.1中的依赖后  加入api模块的依赖

    5.2  applicationContex.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:p="http://www.springframework.org/schema/p"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
    http://code.alibabatech.com/schema/dubbo
    http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
    <!-- 提供方应用信息，用于计算依赖关系 -->
    <dubbo:application name="test_consumer" />

    <!-- 使用zookeeper注册中心暴露服务地址  ip为第一步启动zookeeper的linux机器ip  默认端口2181 -->
    <dubbo:registry address="zookeeper://192.168.0.202:2181" />

    <!-- 声明需要暴露的服务接口 -->
    <dubbo:reference interface="org.dubbo_zk.api.TestRPC" id="testRpc" check="false" />
</beans>

    5.3  spring-mvc.xml文件

    和4.3的一样

    5.4  web.xml文件

    和4.4的一样

    5.5  写controller类  远程调用服务

@Controller
public class TestRPCustomer {
	@Resource
	private TestRPC testRPC;
	@RequestMapping("/test")
	public @ResponseBody Map<String,String> test(){
		Map<String,String> map = testRPC.test();
		Set<String> set = map.keySet();
		for(String s:set) {
			System.out.println(s+":"+map.get(s));
		}
		return testRPC.test();
	}
}

这个时候整个项目搭建完成了  

可以下载看一下代码  https://github.com/hello-piper/piper

可以放到tomcat中  请求一下了

6  dubbo的监控页面

   项目启动之后,我们可以打开dubbo的监控页面看一下 消费者和提供者的状态

    这个把我坑的好惨   网上有人提供了一个dubbo-admin-2.6.0.war的包  说放到tomcat中就可以了

    我下载了他们的war包后却怎么也访问不到页面 

    后来想了一下   官网都下载不到这个war包  这些人怎么找到的呢    带着这个疑问找度娘

    这有一个小哥说了怎么自己生成一个war包  https://www.cnblogs.com/xhkj/p/7407092.html 

    把官网上的github地址的项目下载下来    在dos窗口 进入目录的dubbo-admin目录  使用maven打包工具 

    之后会生成一个war包  讲这个包放到tomcat中就行了