码迷,mamicode.com
首页 > 编程语言 > 详细

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

时间:2016-03-13 23:52:26      阅读:247      评论:0      收藏:0      [点我收藏+]

标签:

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

    }

}

 

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

标签:

原文地址:http://www.cnblogs.com/itbole/p/5274120.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!