1.官网上分别下载zookeeper, kafka . 注意选择二进制文件下载.

2. 先启动zookeeper

1. 在解压后的conf文件中复制一份zoo_sample.cfg 重新命名为 zoo.cfg ,因为zookeeper启动默认加载zoo.cfg的配置文件.
2. 配置zookeeper的环境变量, zookeeper_home
3. 修改配置文件dataDir=D:\Java\Tool\zookeeper-3.4.6\tmp ,然后双击运行 zkServer.cmd 文件. 然后双击运行 zkServer.cmd 文件. (需要java环境)

3.再启动kafka

1. 修改server.properties配置文件. log.dirs=D:\Java\Tool\kafka_2.11-0.10.0.1\kafka-log

# The id of the broker. This must be set to a unique integer for each broker.
broker.id=0
#     listeners = PLAINTEXT://your.host.name:9092
listeners=PLAINTEXT://127.0.0.1:9092
# root directory for all kafka znodes.
zookeeper.connect=localhost:2181

2. 命令窗口进入安装根目录, 执行命令 ,回车

.\bin\windows\kafka-server-start.bat .\config\server.properties 

3. zookeeper, kafka窗口一直保持开的的状态.

4. 使用注解配置

4.1 配置文件添加注解配置

dubbo配置中添加:

	<!-- 使用注解方式暴露接口 -->     
    <dubbo:annotation package="com.dubbo.provide" />  ```

sping配置中添加:

    <!-- 加入spring注解扫描 -->  
    <context:component-scan base-package="com.dubbo"/>  

4.2 provide 的serviceImpl使用:

	@Component    //引入spring的注解
	@Service  	//引入dubbo注解

4.3 customer的使用:

	@Reference  //引入dubbo的注解
    IUserService userService;//调用Dubbo暴露的接口  

4.4 设置重连次数, 否则可能会造成重复执行

<!-- 服务启动关闭对该服务提供者的接口是否正常的监测，也就是BarService是否可以正常调用不影响本应用的启动，当为true的时候如果该接口挂了，本应用就起不起来了-->
<dubbo:reference interface="com.foo.BarService" check="false" />

<!-- 关闭所有服务的启动时检查 -->
<dubbo:consumer check="false" />

<!-- 配置重试次数， 默认retries="2"-->
<dubbo:provider delay="-1"  timeout="60000" retries="0"></dubbo:provider>

4.5. 点对点调用添加url属性, 指定要访问的ip

<!-- 订单接口 -->
	<dubbo:reference id="orderInterfaceService" interface="com.emotte.dubbo.order.OrderInterfaceService" retries="0" timeout="60000" url="dubbo://10.10.54.22:20886"/>