我所理解的DUBBO
相对于传统web开发框架，dubbo更加适合于并行系统开发，分布式，模块化。将server和client都注册到zookeeper注册中心上，然后由最外层客户端发起请求到相应client上，client再调用server。所谓模块化，举例说明，将一个电商系统分隔成用户，商品，进销存等模块，不同的服务模块，client同样也可以这样区分，这样分布完成之后，我们还可以建立多个相同的client端，用nginx来进行相应的集群服务。这也就是我所理解的nginx+dubbo的集群分布式系统
一副自己理解的请求图
安装zookeeper
zookeeper下载地址:http://www.apache.org/dyn/closer.cgi/zookeeper/
启动之前将/home/conf下的zoo_sample.cfg 改名为 zoo.cfg
zoo.cfg解析:
tickTime：这个时间是作为Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。
•dataDir：顾名思义就是 Zookeeper保存数据的目录，默认情况下，Zookeeper 将写数据的日志文件也保存在这个目录里。
•dataLogDir：顾名思义就是Zookeeper 保存日志文件的目录
•clientPort：这个端口就是客户端连接Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户端的访问请求
相关服务
- 启动ZK服务: sh bin/zkServer.sh start
- 查看ZK服务状态: sh bin/zkServer.sh status
- 停止ZK服务: sh bin/zkServer.sh stop
- 重启ZK服务: sh bin/zkServer.sh restart
server code
public interface DubboInter {
public String saveUsers();
public void hgetUsers();
}
public class DubboInterImpl implements DubboInter{
@Override
public String saveUsers() {
System.out.println("save user");
return "test";
}
@Override
public void hgetUsers() {
System.out.println("dubbo getUsers");
}
}
public class Provider {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "spring-mvc.xml" });
context.start();
System.in.read(); // 为保证服务一直开着，利用输入流的阻塞来模拟
}
}
<?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
">
<!--具体的实现bean-->
<bean id="dubboService" class="com.dubbo.imp.DubboInterImpl"></bean>
<!-- 提供方应用信息，用于计算依赖关系 -->
<dubbo:application name="xs_provider" />
<!-- 使用zookeeper注册中心暴露服务地址 即zookeeper的所在服务器ip地址和端口号 -->
<dubbo:registry address="zookeeper://ip:port" />
<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20880" />
<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.dubbo.inter.DubboInter"
ref="dubboService" /></beans>
client code
public interface DubboInter {
public String saveUsers();
public void hgetUsers();
}
public class Customer {
public static void main(String[] args) throws IOException {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "spring-mvc.xml" });
context.start();
DubboInter dubboInter = (DubboInter) context.getBean("dubboService");
String aa = dubboInter.saveUsers();
System.out.println(aa);
System.in.read();
}
}
<?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
">
<!-- 消费方应用名，用于计算依赖关系，不是匹配条件，不要与提供方一样 -->
<dubbo:application name="hjy_consumer" />
<!-- 使用zookeeper注册中心暴露服务地址 -->
<dubbo:registry address="zookeeper://ip:port" />
<!-- 生成远程服务代理，可以像使用本地bean一样使用demoService -->
<dubbo:reference id="dubboService"
interface="com.dubbo.inter.DubboInter" /></beans>
简单说明
服务端编写服务接口和实现类，并且将实现类暴露出去，将zookeeper启动，然后运行服务端，将服务按照配置文件的配置注册到zookeeper上面，客户端为接口声明类，配置文件以及调用代码，客户端同样从zookeeper上调用相应的服务。整个流程就是这样了。