當前位置：首頁 > 前端技术 > javascript >内容正文

javascript

ssm（Spring、Springmvc、Mybatis）实战之淘淘商城-第七天(非原创)

發(fā)布時間：2024/4/15 javascript 29 豆豆

生活随笔收集整理的這篇文章主要介紹了 ssm（Spring、Springmvc、Mybatis）实战之淘淘商城-第七天(非原创) 小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

文章大綱

一、課程介紹
二、Redis基礎(chǔ)實戰(zhàn)
三、Redis之高可用、集群、云平臺搭建實戰(zhàn)
四、淘淘商城Jedis整合spring
五、項目源碼與資料下載
六、參考文章

一、課程介紹

一共14天課程
（1）第一天：電商行業(yè)的背景。淘淘商城的介紹。搭建項目工程。Svn的使用。
（2）第二天：框架的整合。后臺管理商品列表的實現(xiàn)。分頁插件。
（3）第三天：后臺管理。商品添加。商品類目的選擇、圖片上傳、富文本編輯器的使用。
（4）第四天：商品規(guī)格的實現(xiàn)。
（5）第五天：商城前臺系統(tǒng)的搭建。首頁商品分類的展示。Jsonp。
（6）第六天：cms系統(tǒng)的實現(xiàn)。前臺大廣告位的展示。
（7）第七天：cms系統(tǒng)添加緩存。Redis。緩存同步。
（8）第八天：搜索功能的實現(xiàn)。使用solr實現(xiàn)搜索。
（9）第九天：商品詳情頁面的展示。
（10）第十天：單點登錄系統(tǒng)。Session共享。
（11）第十一天：購物車訂單系統(tǒng)的實現(xiàn)。
（12）第十二天：nginx。反向代理工具。
（13）第十三天：redis集群的搭建、solr集群的搭建。系統(tǒng)的部署。
（14）項目總結(jié)。

二、Redis基礎(chǔ)實戰(zhàn)

Redis的基礎(chǔ)包括以下內(nèi)容，可參考文章https://www.cnblogs.com/WUXIAOCHANG/p/10832330.html進行學(xué)習(xí)
（1）安裝并設(shè)置開機自動啟動
（2）Redis文件結(jié)構(gòu)
（3）Redis啟動方式
（4）Redis持久化
（5）Redis配置文件詳解
（7）Redis圖形化工具
（8）Java之Jedis連接Redis單機

三、Redis之高可用、集群、云平臺搭建實戰(zhàn)

https://www.cnblogs.com/WUXIAOCHANG/p/10851334.html

四、淘淘商城Jedis整合spring

1. 添加Reids之后項目架構(gòu)

2. Redis在淘淘商城解決方案

在taotao-rest工程中發(fā)布一個服務(wù)。當后臺管理系統(tǒng)修改內(nèi)容后，調(diào)用此服務(wù)，同步緩存。

3. Jedis整合spring

3.1 resources文件夾中添加配置文件
在resources文件夾中創(chuàng)建applicationContext-redis.xml配置文件

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd">  <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">  <property name="maxTotal" value="30" />  <property name="maxIdle" value="10" />  <property name="numTestsPerEvictionRun" value="1024" />  <property name="timeBetweenEvictionRunsMillis" value="30000" />  <property name="minEvictableIdleTimeMillis" value="1800000" />  <property name="softMinEvictableIdleTimeMillis" value="10000" />  <property name="maxWaitMillis" value="1500" />  <property name="testOnBorrow" value="true" />  <property name="testWhileIdle" value="true" />  <property name="blockWhenExhausted" value="false" /> </bean>  <bean id="jedisPool" class="redis.clients.jedis.JedisPool"> <constructor-arg name="host" value="192.168.3.153"/> <constructor-arg name="port" value="6379"/> <constructor-arg name="poolConfig" ref="jedisPoolConfig"/> </bean>     <bean id="jedisClient" class="com.taotao.rest.dao.impl.JedisClientPool"/>   </beans>

溫馨提示：
（1）jedisPoolConfig是連接池的配置信息，無論是單機還是集群都適用
（2）jedisClient為單機版的配置信息
（3）jedisCluster是集群版的配置信息

3.2 單機版整合測試
com.taotao.rest.dao包中創(chuàng)建連接池JedisClientPool.java

/*** redis單機版客戶端*/ public class JedisClientPool implements JedisClient{ @Autowired private JedisPool jedisPool; @Override public String get(String key) { Jedis jedis = jedisPool.getResource(); String result = jedis.get(key); jedis.close(); return result; } @Override public String set(String key, String value) { Jedis jedis = jedisPool.getResource(); String string = jedis.set(key, value); jedis.close(); return string; } @Override public long incr(String key) { Jedis jedis = jedisPool.getResource(); Long result = jedis.incr(key); jedis.close(); return result; } @Override public Long hset(String hkey, String key, String value) { Jedis jedis = jedisPool.getResource(); Long hset = jedis.hset(hkey, key, value); jedis.close(); return hset; } @Override public String hget(String hkey, String key) { Jedis jedis = jedisPool.getResource(); String result = jedis.hget(hkey, key); jedis.close(); return result; } @Override public Long del(String key) { Jedis jedis = jedisPool.getResource(); Long result = jedis.del(key); jedis.close(); return result; } @Override public Long hdel(String hkey, String key) { Jedis jedis = jedisPool.getResource(); Long result = jedis.hdel(hkey, key); jedis.close(); return result; } @Override public Long expire(String key, int second) { Jedis jedis = jedisPool.getResource(); Long result = jedis.expire(key, second); return result; } }

com.taotao.rest.dao包中創(chuàng)建測試類JedisTest.java

public class JedisTest { // 單機版測試Jedis，不使用連接池 public void testJedis() { // 創(chuàng)建Jedis對象 Jedis jedis = new Jedis("127.0.0.1", 6379); // 設(shè)置對象 jedis.set("key1", "jedis test"); String string = jedis.get("key1"); System.out.println(string); // 關(guān)閉jedis jedis.close(); } // 單機版測試Jedis，這是使用連接池的方式來獲取redis的資源 public void testJedispool() { JedisPool pool = new JedisPool("127.0.0.1", 6379); Jedis resource = pool.getResource(); String string = resource.get("key1"); System.out.println(string); // 不要忘記關(guān)閉連接池了 pool.close(); resource.close(); }

創(chuàng)建后項目結(jié)構(gòu)如下

3.3 集群版整合測試
com.taotao.rest.dao包中創(chuàng)建集群版客戶端JedisClientCluster.java

/*** redis集群版客戶端*/ public class JedisClientCluster implements JedisClient { @Autowired private JedisCluster jedisCluster; @Override public String get(String key) { String string = jedisCluster.get(key); return string; } @Override public String set(String key, String value) { String string = jedisCluster.set(key, value); return string; } @Override public long incr(String key) { Long result = jedisCluster.incr(key); return result; } @Override public Long hset(String hkey, String key, String value) { Long result = jedisCluster.hset(hkey, key, value); return result; } @Override public String hget(String hkey, String key) { String string = jedisCluster.hget(hkey, key); return string; } @Override public Long del(String key) { Long result = jedisCluster.del(key); return result; } @Override public Long hdel(String hkey, String key) { Long result = jedisCluster.hdel(hkey, key); return result; } @Override public Long expire(String key, int second) { Long result = jedisCluster.expire(key, second); return result; } }

com.taotao.rest.dao包中使用測試類JedisTest.java

// 集群版，測試redis集群環(huán)境public void testJiQun(){ HashSet<HostAndPort> nodes=new HashSet<HostAndPort>(); //這里的ip和后面的端口是，在linux系統(tǒng)的ip和配置的不同的redis的端口 nodes.add(new HostAndPort("127.0.0.1",6379)); nodes.add(new HostAndPort("127.0.0.1",6380)); nodes.add(new HostAndPort("127.0.0.1",6381)); nodes.add(new HostAndPort("127.0.0.1",6382)); nodes.add(new HostAndPort("127.0.0.1",6383)); nodes.add(new HostAndPort("127.0.0.1",6384)); JedisCluster cluster=new JedisCluster(nodes); String string=cluster.get("key4"); System.out.println(string); cluster.close(); }

4. 把緩存添加到業(yè)務(wù)邏輯

4.1 resources文件夾中添加配置
resources文件夾中新增resource.properties配置文件

#redis中內(nèi)容緩存的key REDIS_CONTENT_KEY=REDIS_CONTENT #redis中商品信息緩存的key REDIS_TAOTAO_ITEM_KEY=TAOTAO_ITEM #過期時間60*60*24 REDIS_TAOTAO_ITME_EXPIRE=86400

4.2 創(chuàng)建緩存使用業(yè)務(wù)邏輯類
com.taotao.rest.service包下創(chuàng)建ContentServiceImpl.java進行緩存使用

package com.taotao.rest.service.impl;import java.util.List;import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import com.taotao.common.pojo.TaotaoResult; import com.taotao.common.utils.ExceptionUtil; import com.taotao.common.utils.JsonUtils; import com.taotao.mapper.TbContentMapper; import com.taotao.pojo.TbContent; import com.taotao.pojo.TbContentExample; import com.taotao.pojo.TbContentExample.Criteria; import com.taotao.rest.dao.JedisClient; import com.taotao.rest.service.ContentService; /** * 內(nèi)容管理服務(wù) */ @Service public class ContentServiceImpl implements ContentService { @Autowired private TbContentMapper contentMapper; @Autowired private JedisClient jedisClient; @Value("${REDIS_CONTENT_KEY}") private String REDIS_CONTENT_KEY; @Override public TaotaoResult getContentList(long categoryId) { //添加取緩存的邏輯 //緩存不能影響正常邏輯 try { String result = jedisClient.hget(REDIS_CONTENT_KEY, categoryId+""); //判斷結(jié)果是否為空 if (!StringUtils.isBlank(result)) { List<TbContent> list = JsonUtils.jsonToList(result, TbContent.class); return TaotaoResult.ok(list); } } catch (Exception e) { e.printStackTrace(); } //緩存邏輯結(jié)束 List<TbContent> list = null; try { TbContentExample example = new TbContentExample(); Criteria criteria = example.createCriteria(); // 設(shè)置查詢條件 criteria.andCategoryIdEqualTo(categoryId); // 執(zhí)行查詢 list = contentMapper.selectByExample(example); } catch (Exception e) { e.printStackTrace(); return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e)); } //把內(nèi)容添加到緩存中 try { jedisClient.hset(REDIS_CONTENT_KEY, categoryId + "", JsonUtils.objectToJson(list)); } catch (Exception e) { // TODO: handle exception } //end return TaotaoResult.ok(list); } }

5. 同步緩存服務(wù)

??當數(shù)據(jù)庫中的內(nèi)容信息發(fā)生改變后，例如首頁大廣告為的廣告內(nèi)容發(fā)生變化后，如何實現(xiàn)redis中的數(shù)據(jù)同步更新呢？可以在taotao-rest工程中發(fā)布一個服務(wù)，就是專門同步數(shù)據(jù)用的，其實只需要把緩存中的數(shù)據(jù)清空即可。當管理后臺更新了內(nèi)容信息后，需要調(diào)用此服務(wù)。
??此服務(wù)不需要mapper內(nèi)容。只需要JedisCluster對象。

5.1 創(chuàng)建緩存同步服務(wù)邏輯類
com.taotao.rest.service包中創(chuàng)建RedisSyncServiceImpl.java

@Service public class RedisSyncServiceImpl implements RedisSyncService { @Autowired private JedisClient jedisClient; @Value("${REDIS_CONTENT_KEY}") private String REDIS_CONTENT_KEY; @Override public TaotaoResult syncContent(String key) { jedisClient.hdel(REDIS_CONTENT_KEY, key); return TaotaoResult.ok(); } }

在com.taotao.rest.controller包中創(chuàng)建緩存同步的服務(wù)類RedisSyncController.java

@Controller @RequestMapping("/sync") public class RedisSyncController { @Autowired private RedisSyncService redisSyncService; @RequestMapping("/content/{categoryId}") @ResponseBody public TaotaoResult syncContent(@PathVariable String categoryId) { try { redisSyncService.syncContent(categoryId); } catch (Exception e) { e.printStackTrace(); return TaotaoResult.build(500, ExceptionUtil.getStackTrace(e)); } return TaotaoResult.ok(); } }

五、項目源碼與資料下載

鏈接：https://pan.baidu.com/s/1XsTBNB8RCT-c2SaFdOTyqA
提取碼：t05n

六、參考文章

http://yun.itheima.com/course?hm

轉(zhuǎn)載于:https://www.cnblogs.com/WUXIAOCHANG/p/10851733.html

總結(jié)

以上是生活随笔為你收集整理的ssm（Spring、Springmvc、Mybatis）实战之淘淘商城-第七天(非原创)的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。