用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");

    }

}

 媽的太多了，累死我的！懶得寫下去了，就這樣吧。