[

    {

        "srcB": "http://image.taotao.com/images/2015/03/03/2015030304360302109345.jpg",

        "height": 240,

        "alt": "",

        "width": 670,

        "src": "http://image.taotao.com/images/2015/03/03/2015030304360302109345.jpg",

        "widthB": 550,

        "href": "http://sale.jd.com/act/e0FMkuDhJz35CNt.html?cpdad=1DLSUE",

        "heightB": 240

}

]

/**

 * 首页大广告位轮播图数据展示POJO

 */

public class Ad1Node {

    private String srcB; //pic2

    private String height;

    private String alt;  //subtitle中获取

    private String width;

    private String src;  //pic

    private String widthB;

    private String href; //url

    private String heightB;

    set/get。。。。。。

}

　　/**

     * 根据cid查询内容列表

     */

    public List<TbContent> getContentListByCatId(long cid);

　　@Override

    public List<TbContent> getContentListByCatId(long cid) {

        TbContentExample example = new TbContentExample();

        Criteria criteria = example.createCriteria();

        criteria.andCategoryIdEqualTo(cid);

        //执行查询

        List<TbContent> list = contentMapper.selectByExample(example);

        return list;

    }

　　<!-- 引用dubbo服务 -->

    <dubbo:application name="taotao-portal-web" />

    <dubbo:registry protocol="zookeeper" address="192.168.25.129:2181" />

    <dubbo:reference interface="com.taotao.content.service.ContentService" id="contentService" timeout="300000" />

@Controller

public class PageController {

    //注入服务

    @Autowired

    private ContentService contentService;

    @Value("${AD1_CATEGORY_ID}")

    private Long categoryId;

    @Value("${AD1_HEIGHT_B}")

    private String AD1_HEIGHT_B;

    @Value("${AD1_HEIGHT}")

    private String AD1_HEIGHT;

    @Value("${AD1_WIDTH}")

    private String AD1_WIDTH;

    @Value("${AD1_WIDTH_B}")

    private String AD1_WIDTH_B;

    /**

     * 展示首页

     * @return

     */

    @RequestMapping("/index")

    public String showIndex(Model model){

        //根据内容分类的id查询内容列表

        List<TbContent> contentList = contentService.getContentListByCatId(categoryId);

        //转成自定义的pojo：Ad1Node

        List<Ad1Node> nodes = new ArrayList<Ad1Node>();

        for(TbContent content : contentList){

            Ad1Node node = new Ad1Node();

            node.setAlt(content.getSubTitle());

            node.setHeight(AD1_HEIGHT);

            node.setHeightB(AD1_HEIGHT_B);

            node.setHref(content.getUrl());

            node.setSrc(content.getPic());

            node.setSrcB(content.getPic2());

            node.setWidth(AD1_WIDTH);

            node.setWidthB(AD1_WIDTH_B);

            nodes.add(node);

        }

        //传递数据给jsp

        model.addAttribute("ad1", JsonUtils.objectToJson(nodes));

        return "index"; //响应jsp

    }

}

<!-- 加载属性文件 -->

<context:property-placeholder location="classpath:resource/*.properties" />

　　　　　　　<!-- Redis客户端 -->

            <dependency>

                <groupId>redis.clients</groupId>

                <artifactId>jedis</artifactId>

                <version>${jedis.version}</version>

            </dependency>

　　/**

     * 测试单机版

     */

    @Test

    public void testJedis(){

        //1.创建Jedis对象 需要指定连接的地址和端口

        Jedis jedis = new Jedis("192.168.25.131",6379);

        //2.直接操作Jedis set

        jedis.set("key123", "value123");

        System.out.println(jedis.get("key123"));

        //3.关闭Jedis

        jedis.close();

    }
输出：value123

　　/**

     * 使用连接池连接单机版

     */

    @Test

    public void testJedisPool(){

        // 第一步：创建一个JedisPool对象。需要指定服务端的ip及端口。

        JedisPool jedisPool = new JedisPool("192.168.25.131", 6379);

        // 第二步：从JedisPool中获得Jedis对象。

        Jedis jedis = jedisPool.getResource();

        // 第三步：使用Jedis操作redis服务器。

        jedis.set("jedis", "test");

        String result = jedis.get("jedis");

        System.out.println(result);

        // 第四步：操作完毕后关闭jedis对象，连接池回收资源。

        jedis.close();

        // 第五步：关闭JedisPool对象。

        jedisPool.close();

    }
输出：test

/**

     * 连接集群版

     */

    @Test

    public void testJedisCluster() throws Exception {

        //1.创建JedisCluster对象

        //需要一个Set<HostAndPort>参数。Redis节点的列表。

        Set<HostAndPort> nodes = new HashSet<>();

        nodes.add(new HostAndPort("192.168.25.131", 7001));

        nodes.add(new HostAndPort("192.168.25.131", 7002));

        nodes.add(new HostAndPort("192.168.25.131", 7003));

        nodes.add(new HostAndPort("192.168.25.131", 7004));

        nodes.add(new HostAndPort("192.168.25.131", 7005));

        nodes.add(new HostAndPort("192.168.25.131", 7006));

        JedisCluster jedisCluster = new JedisCluster(nodes);

        //2.直接根据JedisCluster对象操作redis集群

        jedisCluster.set("hello", "100");

        //3.打印结果

        System.out.println(jedisCluster.get("hello"));

        //4.系统关闭前，关闭JedisCluster对象

        jedisCluster.close();

    }
输出：100

public interface JedisClient {

    String set(String key, String value);

    String get(String key);

    Boolean exists(String key);

    Long expire(String key, int seconds);

    Long ttl(String key);

    Long incr(String key);

    Long hset(String key, String field, String value);

    String hget(String key, String field);

    Long hdel(String key, String... field);

}

public class JedisClientPool implements JedisClient {

    @Autowired

    private JedisPool jedisPool;

    @Override

    public String set(String key, String value) {

        Jedis jedis = jedisPool.getResource();

        String result = jedis.set(key, value);

        jedis.close();

        return result;

    }

    @Override

    public String get(String key) {

        Jedis jedis = jedisPool.getResource();

        String result = jedis.get(key);

        jedis.close();

        return result;

    }

    @Override

    public Boolean exists(String key) {

        Jedis jedis = jedisPool.getResource();

        Boolean result = jedis.exists(key);

        jedis.close();

        return result;

    }

    @Override

    public Long expire(String key, int seconds) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.expire(key, seconds);

        jedis.close();

        return result;

    }

    @Override

    public Long ttl(String key) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.ttl(key);

        jedis.close();

        return result;

    }

    @Override

    public Long incr(String key) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.incr(key);

        jedis.close();

        return result;

    }

    @Override

    public Long hset(String key, String field, String value) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.hset(key, field, value);

        jedis.close();

        return result;

    }

    @Override

    public String hget(String key, String field) {

        Jedis jedis = jedisPool.getResource();

        String result = jedis.hget(key, field);

        jedis.close();

        return result;

    }

    @Override

    public Long hdel(String key, String... field) {

        Jedis jedis = jedisPool.getResource();

        Long result = jedis.hdel(key, field);

        jedis.close();

        return result;

    }

}

<!-- 配置单机版的连接 -->

    <bean id="jedisPool" class="redis.clients.jedis.JedisPool">

        <constructor-arg name="host" value="192.168.25.131"></constructor-arg>

        <constructor-arg name="port" value="6379"></constructor-arg>

    </bean>

    <bean id="jedisClientPool" class="com.taotao.jedis.JedisClientPool"/>

</beans>

public class JedisClientCluster implements JedisClient {

    @Autowired

    private JedisCluster jedisCluster;

    @Override

    public String set(String key, String value) {

        return jedisCluster.set(key, value);

    }

    @Override

    public String get(String key) {

        return jedisCluster.get(key);

    }

    @Override

    public Boolean exists(String key) {

        return jedisCluster.exists(key);

    }

    @Override

    public Long expire(String key, int seconds) {

        return jedisCluster.expire(key, seconds);

    }

    @Override

    public Long ttl(String key) {

        return jedisCluster.ttl(key);

    }

    @Override

    public Long incr(String key) {

        return jedisCluster.incr(key);

    }

    @Override

    public Long hset(String key, String field, String value) {

        return jedisCluster.hset(key, field, value);

    }

    @Override

    public String hget(String key, String field) {

        return jedisCluster.hget(key, field);

    }

    @Override

    public Long hdel(String key, String... field) {

        return jedisCluster.hdel(key, field);

    }

}

　　<!-- 集群版的配置 -->

    <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster">

        <constructor-arg>

            <set>

                <bean class="redis.clients.jedis.HostAndPort">

                    <constructor-arg name="host" value="192.168.25.131"></constructor-arg>

                    <constructor-arg name="port" value="7001"></constructor-arg>

                </bean>

                <bean class="redis.clients.jedis.HostAndPort">

                    <constructor-arg name="host" value="192.168.25.131"></constructor-arg>

                    <constructor-arg name="port" value="7002"></constructor-arg>

                </bean>

                <bean class="redis.clients.jedis.HostAndPort">

                    <constructor-arg name="host" value="192.168.25.131"></constructor-arg>

                    <constructor-arg name="port" value="7003"></constructor-arg>

                </bean>

                <bean class="redis.clients.jedis.HostAndPort">

                    <constructor-arg name="host" value="192.168.25.131"></constructor-arg>

                    <constructor-arg name="port" value="7004"></constructor-arg>

                </bean>

                <bean class="redis.clients.jedis.HostAndPort">

                    <constructor-arg name="host" value="192.168.25.131"></constructor-arg>

                    <constructor-arg name="port" value="7005"></constructor-arg>

                </bean>

                <bean class="redis.clients.jedis.HostAndPort">

                    <constructor-arg name="host" value="192.168.25.131"></constructor-arg>

                    <constructor-arg name="port" value="7006"></constructor-arg>

                </bean>

            </set>

        </constructor-arg>

    </bean>

    <bean id="jedisClientCluster" class="com.taotao.jedis.JedisClientCluster"/>

　　@Test

    public void testdanji(){

        //1.初始化spring容器

        ApplicationContext context = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-redis.xml");

        //2.获取实现类实例

        JedisClient bean = context.getBean(JedisClient.class);

        //3.调用方法操作

        bean.set("jedisclientkey11", "jedisclientkey");

        System.out.println(bean.get("jedisclientkey11"));

    }

//注入jedisClient

    @Autowired

    private JedisClient jedisClient;

    @Value("${CONTENT_KEY}")

    private String CONTENT_KEY;

    //////////根据cid查询内容列表

    @Override

    public List<TbContent> getContentListByCatId(long cid) {

        //查询缓存。判断是否redis中有数据，如果有，直接从redis中获取数据返回

        try{

            String jsonstr = jedisClient.hget(CONTENT_KEY, cid+"");//从redis数据库中获取内容分类下的所有内容

            if(StringUtils.isNoneBlank(jsonstr)){//不为空

                //System.out.println("这里有缓存了！！！");

                return JsonUtils.jsonToList(jsonstr, TbContent.class);

            }

        }catch(Exception e){

            e.printStackTrace();

        }

//创建example

        TbContentExample example = new TbContentExample();

        //设置查询条件

        Criteria criteria = example.createCriteria();

        criteria.andCategoryIdEqualTo(cid);

        //执行查询

        List<TbContent> list = contentMapper.selectByExample(example);

        //将数据写入到redis数据库:

        try{

            //System.out.println("没有缓存！");

            jedisClient.hset(CONTENT_KEY, cid+"", JsonUtils.objectToJson(list));

        }catch(Exception e){

            e.printStackTrace();

        }

//返回

        return list;

    }

<context:property-placeholder location="classpath:properties/*.properties" />

    ///////////添加内容

    @Override

    public TaotaoResult addContent(TbContent content) {

        //补全属性

        content.setCreated(new Date());

        content.setUpdated(new Date());

        //插入数据

        contentMapper.insert(content);

        //当添加内容的时候，需要清空此内容所属的分类下的所有的缓存

        try{

            jedisClient.hdel(CONTENT_KEY, content.getCategoryId()+"");

            System.out.println("当插入时清空缓存！");

        }catch(Exception e){

            e.printStackTrace();

        }

        //返回结果

        return TaotaoResult.ok();

    }