![](https://img.laitimes.com/img/__Qf2AjLwojIjJCLyojI0JCLiAzNfRHLGZkRGZkRfJ3bs92YsYTMfVmepNHL5dmeNNTTE90MNpHW3BjMMBjVtJWd0ckW65UbM5WOHJWa5kHT20ESjBjUIF2X0hXZ0xCMx81dvRWYoNHLrdEZwZ1Rh5WNXp1bwNjW1ZUba9VZwlHdssmch1mclRXY39CXldWYtlWPzNXZj9mcw1ycz9WL49zZuBnL4cDN5ITN1YTMwMDMxgTMwIzLc52YucWbp5GZzNmLn9Gbi1yZtl2Lc9CX6MHc0RHaiojIsJye.png)
如图所示:由于系统的后台运营模块需要引入dubbo接口的调用。且之前对于dubbo接口都是在现有基础上直接加接口,没有太多关注其生产者和消费者配置。故初次配置也遇到了一些问题。即注入失败
1.首先引入dubbo的工程要引入dubbo相关jar包,一开始我就只引入了dubbojar包,没有引入zk相关jar包,导致项目启动时,报zk的error。
<!-- dubbo -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.10</version>
<exclusions>
<exclusion>
<!-- 避免与rop引用spring冲突 -->
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
<exclusion>
<groupId>org.jboss.netty</groupId>
<artifactId>netty</artifactId>
</exclusion>
</exclusions>
</dependency>
<!-- zkclient -->
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.4</version>
</dependency>
<!-- zookeeper -->
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.6</version>
<exclusions>
<exclusion>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
</exclusion>
</exclusions>
</dependency>
2.确保引入jar包没有问题后,进行生产者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://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:application name="consumer-of-ops-app" /> <-- 应用名称
<!-- 使用multicast广播注册中心暴露发现服务地址 -->
<dubbo:registry protocol="zookeeper" address="${dubbo.address}" /> ---address通常配置在全局变量中为提供服务的地址,在本地时通常为 127.0.0.1:2181
<!-- 生成远程服务代理,可以和本地bean一样使用demoService -->
<dubbo:protocol name="dubbo" threads="100" server="netty" serialization="hessian2" host="${dubbo.protocol.host}" port="33896" />
<dubbo:service inter ref="distributionService" group="ops-interface-group" version="0.0.1" retries="0" timeout="5000"/> <!-- 对外的提供接口
<import resource="classpath*:dubbo/dubbo-provider.xml" /> 在spring-context配置中加入此配置 与spring相整合
在pom中引入相应配置,即在项目启动时加载
<resource>
<directory>src/main/resources</directory>
<includes>
<include>application.properties</include>
<include>dubbo/dubbo-provider.xml</include>
<include>redis.properties</include>
</includes>
<!--也可以用排除标签 -->
<!--<excludes></excludes> -->
<!--开启过滤 -->
<filtering>true</filtering>
</resource>
同时在本地调试时,要启动本地的zk服务,即下载zk,然后将其client.cmd和server.cmd打开即可
上图为提供的接口
对于消费者dubbo-consumer:
<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:application name="ops-manager" />
<!-- 使用zookeeper注册中心暴露服务地址 -->
<dubbo:registry id="carzone_ops_zk" protocol="zookeeper" address="${dubbo.address}" />
<!--客户信息接口-->
<dubbo:reference id="opsCustomerService" inter
registry="carzone_ops_zk" group="ops-interface-group" check="false" version="0.0.1"
retries="0" timeout="5000"/>
</beans>
同时dubbo-consumer.xml也要相应的加入到pom和spring-context配置中。 此时可以直接在代码中注入opsCustomerService这个bean
并调用相应的方法