用dubbo+zookeeper+spring搭建一个简单的http接口程序

dubbo是一个分布式服务框架，是阿里巴巴开发的一个解决RPC远程调用优化的核心框架，包含负载均衡算法，能提升分布式系统的性能。

zookeeper是hadoop的一个子项目，主要用来解决分布式系统的数据一致性、状态同步、服务集群管理、配置同步等一系列的问题。本文使用zookeeper做为dubbo的服务注册中心。

技术细节方面：

dubbo：http://www.dubbo.io

zookeeper：http://www.ibm.com/developerworks/cn/opensource/os-cn-zookeeper/index.html

 

本demo的需求是，有两个功能模块（demo而已嘛）：商品、订单。这两个模块分辨要有不一样的服务提供者，而且要有不一样的注册中心。而后使用一个client来提供http接口，供外部访问。

本demo专一于dubbo+zookeeper的配置，因此一些数据库链接池配置、数据源配置什么的会省略掉。

须要的jar包（若是不访问数据库，mysql那个能够不用，其它一个都不能少，少了就会报错）：

首先咱们开发商品的服务提供者，在eclipse下新建一个web_server_goods的java project：

而后咱们写一个接口OrderQueryService，代码以下：

package com.web.server.service;

import java.util.Map;

public interface OrderQueryService {

    public Map<String, Object> queryList(Map<String, Object> params);

}

该接口有一个queryList方法，用于查询订单列表

而后咱们再开发一个实现类OrderQueryServiceImpl，这个类实现了OrderQueryService，代码以下：

package com.web.server.service.impl;

import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;

import com.web.server.service.OrderQueryService;
import com.web.server.util.ServiceUtil;

public class OrderQueryServiceImpl implements OrderQueryService {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Override
    public Map<String, Object> queryList(Map<String, Object> params) {
        String sql = "select * from t_order";
        List<Map<String, Object>> list = jdbcTemplate.queryForList(sql);
        return ServiceUtil.getServiceResult(list, "success");
    }
}

 

而后咱们再创建一个web_server_goods的java project

写一个接口GoodsQueryService，代码以下：

package com.web.server.service;

import java.util.Map;

public interface GoodsQueryService {

    public Map<String, Object> queryGoodsList(Map<String, Object> params);

}

该接口有一个queryGoodsList方法，用于查询商品列表

而后再写一个实现类GoodsQueryServiceImpl，实现了GoodsQueryService，代码以下：

package com.web.server.service.impl;

import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;

import com.web.server.service.GoodsQueryService;
import com.web.server.util.ServiceUtil;

public class GoodsQueryServiceImpl implements GoodsQueryService {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Override
    public Map<String, Object> queryGoodsList(Map<String, Object> params, int currentPage, int pageSize) {

        StringBuilder sql = new StringBuilder();
        sql.append("select * from t_goods where 1=1 ");
        List<Map<String, Object>> list = jdbcTemplate.queryForList(sql.toString());
        return ServiceUtil.getServiceResult(list, "success");

    }

}

 妈的太多了，累死我的！懒得写下去了，就这样吧。