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

    }

}

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