專欄：高并發(fā)---分布式項目?

億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目搭建 一 （商家端與用戶端功能介紹、項目技術架構(gòu)、數(shù)據(jù)庫表結(jié)構(gòu)等設計）	億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目搭建 一 （商家端與用戶端功能介紹、項目技術架構(gòu)、數(shù)據(jù)庫表結(jié)構(gòu)等設計）_童小純的博客-CSDN博客
億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 二（Zookeeper、Docker、Dubbo-Admin等搭建工作	億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 二（Zookeeper、Docker、Dubbo-Admin等搭建工作_童小純的博客-CSDN博客
億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 三（通用模塊、商品服務模塊、后臺API模塊、IDEA忽略文件顯示等開發(fā)工作	億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 三（通用模塊、商品服務模塊、后臺API模塊、IDEA忽略文件顯示等開發(fā)工作_童小純的博客-CSDN博客
億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 四（Dashboard服務、設置統(tǒng)一返回格式與異常處理、Postman測試接口 ）	億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 四（Dashboard服務、設置統(tǒng)一返回格式與異常處理、Postman測試接口 ）_童小純的博客-CSDN博客
億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 五 (用戶服務模塊、管理員模塊功能 增、刪、改、查 、分頁，前端工程)	億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 五 (用戶服務模塊、管理員模塊功能 增、刪、改、查 、分頁，前端工程)_童小純的博客-CSDN博客
億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 六（編寫角色管理、用戶權限(Spring Security認證授權)、管理員管理等模塊）	億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 六（編寫角色管理、用戶權限(Spring Security認證授權)、管理員管理等模塊）_童小純的博客-CSDN博客
億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 七（品牌模塊、商品類型模塊等開發(fā)）	億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 七（品牌模塊、商品類型模塊等開發(fā)）_童小純的博客-CSDN博客
億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 八（安裝FastDFS、安裝Nginx、文件服務模塊、文件上傳功能、商品功能與秒殺商品等功能）	億級高并發(fā)電商項目-- 實戰(zhàn)篇 --萬達商城項目 八（安裝FastDFS、安裝Nginx、文件服務模塊、文件上傳功能、商品功能與秒殺商品等功能）_童小純的博客-CSDN博客

👏作者簡介：大家好，我是小童，Java開發(fā)工程師，CSDN博客博主，Java領域新星創(chuàng)作者
📕系列專欄：前端、Java、Java中間件大全、微信小程序、微信支付、若依框架、Spring全家桶
📧如果文章知識點有錯誤的地方，請指正！和大家一起學習，一起進步👀
🔥如果感覺博主的文章還不錯的話，請👍三連支持👍一下博主哦
🍂博主正在努力完成2023計劃中：以夢為馬，揚帆起航，2023追夢人

編寫廣告服務接口

接下來我們編寫廣告相關的CRUD方法，首先在通用模塊編寫廣告服務接口：

// 廣告服務
public interface CategoryService {// 增加廣告void add(Category category);// 修改廣告void update(Category category);// 修改廣告狀態(tài)void updateStatus(Long id, Integer status);// 刪除廣告void delete(Long[] ids);// 根據(jù)Id查詢廣告Category findById(Long id);// 分頁查詢廣告Page<Category> search(int page, int size);// 查詢?nèi)繂⒂脧V告List<Category> findAll();
}

?創(chuàng)建廣告服務模塊

1、創(chuàng)建名為 shopping_category_service 的SpringBoot工程，添加相關依賴。

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><!-- MyBatisPlus --><dependency><groupId>com.baomidou</groupId><artifactId>mybatis-plus-boot-starter</artifactId><version>3.5.0</version></dependency><!-- mysql驅(qū)動 --><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><dependency><groupId>com.itbaizhan</groupId><artifactId>shopping_common</artifactId><version>0.0.1-SNAPSHOT</version></dependency><!-- dubbo --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency><!-- 操作zookeeper --><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.2.0</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency>
</dependencies>

?2、設置該工程的父工程為 shopping 。

<parent><groupId>com.ittxc</groupId><artifactId>shopping</artifactId><version>1.0-SNAPSHOT</version>
</parent>

3、給 shopping 工程設置子模塊

<!-- 子模塊 -->
<modules><!-- 廣告服務 --><module>shopping_category_service</module>
</modules>

4、編寫配置文件 application.yml

# 端口號
server:port: 9004
# 日志格式
logging:pattern:console: '%d{HH:mm:ss.SSS} %clr(%-5level) --- [%-15thread] %cyan(%-50logger{50}):%msg%n'
# 配置Mybatis-plus
mybatis-plus:global-config:db-config:# 表名前綴table-prefix: bz_# 主鍵生成策略為自增id-type: autoconfiguration:# 關閉列名自動駝峰命名映射規(guī)則map-underscore-to-camel-case: falselog-impl: org.apache.ibatis.logging.stdout.StdOutImp
l # 開啟sql日志
spring:# 數(shù)據(jù)源datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql:///baizhanshopping?serverTimezone=UTCusername: rootpassword01: 123456
dubbo:application:name: shopping_category_service # 項目名registry:address: zookeeper://192.168.100.131 #注冊中心地址port: 2181 # 注冊中心端口號timeout: 10000 # 注冊到zk上超市時間,msprotocol:name: dubbo # dubbo使用的協(xié)議port: -1 # 自動分配端口scan:base-packages: com.ittxc.shopping_category_service.service # 包掃描

5、啟動類掃描Mapper包

@SpringBootApplication
@MapperScan("com.itbaizhan.shopping_category_service.mapper")
public class ShoppingCategoryServiceApplication {public static void main(String[] args){SpringApplication.run(ShoppingCategoryServiceApplication.class, args);}
}

編寫廣告服務實現(xiàn)類

1、創(chuàng)建廣告Mapper接口

public interface CategoryMapper extends BaseMapper<Category> { }

2、創(chuàng)建廣告服務實現(xiàn)類

@DubboService
public class CategoryServiceImpl implements CategoryService {@Autowiredprivate CategoryMapper categoryMapper;@Overridepublic void add(Category category) {categoryMapper.insert(category);}@Overridepublic void update(Category category){categoryMapper.updateById(category);}@Overridepublic void updateStatus(Long id, Integer status) {Category category = categoryMapper.selectById(id);category.setStatus(status);categoryMapper.updateById(category);}@Overridepublic Category findById(Long id) {return categoryMapper.selectById(id);}@Overridepublic void delete(Long[] ids) {categoryMapper.deleteBatchIds(Arrays.asList(ids));}@Overridepublic Page<Category> search(int page, int size) {return categoryMapper.selectPage(new Page(page,size),null);}@Overridepublic List<Category> findAll() {// 從數(shù)據(jù)庫查詢所有啟用的廣告QueryWrapper<Category> queryWrapper = new QueryWrapper();queryWrapper.eq("status",1);List<Category> categories = categoryMapper.selectList(queryWrapper);return categories;}
}

編寫廣告管理控制器

1、在管理員Api模塊編寫廣告管理控制器

/**
* 廣告
*/
@RestController
@RequestMapping("/category")
public class CategoryController {@DubboReferenceprivate CategoryService categoryService;/*** 分頁查詢廣告** @param page 頁碼* @param size 每頁條數(shù)* @return 查詢結(jié)果*/@GetMapping("/search")public BaseResult<Page<Category>> search(int page, int size) {Page<Category> page1 = categoryService.search(page, size);return BaseResult.ok(page1);}/*** 增加廣告** @param category 廣告對象* @return 操作結(jié)果*/@PostMapping("/add")public BaseResult add(@RequestBody Category category) {categoryService.add(category);return BaseResult.ok();}/*** 修改廣告** @param category 廣告對象* @return 操作結(jié)果*/@PutMapping("/update")public BaseResult update(@RequestBody Category category) {categoryService.update(category);return BaseResult.ok();}/*** 修改廣告狀態(tài)** @param id     廣告id* @param status 廣告狀態(tài) 0:未啟用 1:啟用* @return 操作結(jié)果*/@PutMapping("/updateStatus")public BaseResult updateStatus(Long id, Integer status) {categoryService.updateStatus(id,status);return BaseResult.ok();}/*** 根據(jù)Id查詢廣告** @param id 廣告id* @return 查詢結(jié)果*/@GetMapping("/findById")public BaseResult<Category> findById(Long id) {Category category = categoryService.findById(id);return BaseResult.ok(category);}/*** 刪除廣告** @param ids 廣告id集合* @return 操作結(jié)果*/@DeleteMapping("/delete")public BaseResult delete(Long[] ids) {categoryService.delete(ids);return BaseResult.ok();}
}

創(chuàng)建廣告用戶Api模塊

前臺用戶在訪問首頁的時候是可以查看廣告的，但前臺項目無法使 用后臺項目的接口，因為后臺項目接口需要管理員登錄才能使用， 且前臺項目訪問量大，我們需要專門編寫一個api模塊方便前臺用戶訪問。

1、創(chuàng)建名為 shopping_category_customer_api 的SpringBoot工程，添加相關依賴。

<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- dubbo --><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency><!-- 操作zookeeper --><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>4.2.0</version></dependency><dependency><groupId>com.ittxc</groupId><artifactId>shopping_common</artifactId><version>0.0.1-SNAPSHOT</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency>
</dependencies>

2、設置該工程的父工程為 shopping 。

<parent><groupId>com.ittxc</groupId><artifactId>shopping</artifactId><version>1.0-SNAPSHOT</version>
</parent>

3、給 shopping 工程設置子模塊

<!-- 子模塊 -->
<modules><!-- 網(wǎng)站用戶操作廣告暴露的api --><module>shopping_category_customer_api</module>
</modules>

4、編寫配置文件 application.yml

# 端口號
server:port: 8002
# 日志格式
logging:pattern:console: '%d{HH:mm:ss.SSS} %clr(%-5level) --- [%-15thread] %cyan(%-50logger{50}):%msg%n'
dubbo:application:name: shopping_category_customer_api #項目名registry:address: zookeeper://192.168.100.131 #注冊中心地址port: 2181       # 注冊中心的端口timeout: 10000 # 注冊到zk上超時時間，msprotocol:name: dubbo # dubbo使用的協(xié)議port: -1 # dubbo自動分配端口

5、啟動類忽略數(shù)據(jù)源自動配置

@SpringBootApplication(exclude= {DataSourceAutoConfiguration.class})
public class ShoppingCategoryCustomerApiApplication {public static void main(String[] args)
{SpringApplication.run(ShoppingCategoryCustomerApiApplication.class, args);}
}

6、編寫前臺用戶廣告控制器

/**
* 廣告
*/
@RestController
@RequestMapping("/user/category")
public class CategoryController {@DubboReferenceprivate CategoryService categoryService;/*** 查詢?nèi)繂⒂脧V告** @return 查詢結(jié)果*/@GetMapping("/all")public BaseResult<List<Category>> findAll() {List<Category> categories = categoryService.findAll();return BaseResult.ok(categories);}
}

7、啟動前端客戶端項目，測試前臺查詢廣告接口

使用緩存優(yōu)化用戶查詢廣告

在用戶訪問網(wǎng)站首頁時，需要查詢網(wǎng)站的所有啟用廣告。而電商網(wǎng) 站用戶訪問量大，大量用戶每次訪問首頁都從數(shù)據(jù)庫查詢廣告非常 浪費資源，我們可以使用Redis緩存技術優(yōu)化用戶對于廣告的查詢。 思路如下：

?安裝Redis

1、安裝GCC

yum install -y gcc

2、使用rz上傳Redis壓縮文件

3、解壓并安裝Redis

# 解壓Redis
tar -zxvf redis-6.2.6.tar.gz -C /usr/local
# 進入Redis解壓目錄
cd /usr/local/redis-6.2.6/src/
# 編譯Redis
make
# 安裝Redis
make install

4、啟動Redis

# 啟動Redis,關閉保護狀態(tài)
./redis-server --protected-mode no

優(yōu)化廣告服務實現(xiàn)類

1、在廣告服務模塊添加redis起步依賴

<!-- redis -->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-dataredis</artifactId>
</dependency>

2、在yml文件中配置redis連接

spring:# 數(shù)據(jù)源datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql:///baizhanshopping?serverTimezone=UTCusername: rootpassword01: 123456# redisredis:host: 192.168.100.131port: 6379timeout: 30000jedis:pool:max-idle: 8max-wait: -1max-active: 8min-idle: 0

3、修改廣告服務實現(xiàn)類

@DubboService
public class CategoryServiceImpl
implements CategoryService {@Autowiredprivate CategoryMapper categoryMapper;// 對象名必須叫redisTemplate，否則由于容器中有多個RedisTemplate對象造成無法注入@Autowiredprivate RedisTemplate redisTemplate;@Overridepublic void add(Category category) {categoryMapper.insert(category);refreshRedisCategory();}@Overridepublic void update(Category category){categoryMapper.updateById(category);refreshRedisCategory();}
@Overridepublic void updateStatus(Long id,Integer status) {Category category = categoryMapper.selectById(id);category.setStatus(status);categoryMapper.updateById(category);refreshRedisCategory();}@Overridepublic void delete(Long[] ids) {categoryMapper.deleteBatchIds(Arrays.asList(ids));}@Overridepublic Category findById(Long id) {return categoryMapper.selectById(id);}@Overridepublic Page<Category> search(int page,int size) {return categoryMapper.selectPage(new Page(page,size),null);}@Overridepublic List<Category> findAll() {// 1.從redis中查詢啟用的廣告// 1.1 獲取操作redis中l(wèi)ist數(shù)據(jù)的對象ListOperations<String,Category> listOperations = redisTemplate.opsForList();// 1.2 從redis中獲取所有啟用的廣告List<Category> categoryList = listOperations.range("categories", 0, -1);if (categoryList != null && categoryList.size() > 0){// 2.如果查到結(jié)果，直接返回System.out.println("從redis中查詢廣告");return categoryList;}else{// 3.如果redis中沒有數(shù)據(jù)，則從數(shù)據(jù)庫查詢廣告，并同步到redis中System.out.println("從mysql中查詢廣告");// 從數(shù)據(jù)庫查詢廣告QueryWrapper<Category> queryWrapper = new QueryWrapper();queryWrapper.eq("status",1);List<Category> categories = categoryMapper.selectList(queryWrapper);// 同步到redis中l(wèi)istOperations.leftPushAll("categories",categories);return categories;}}/*** 更新redis中的廣告數(shù)據(jù)*/public void refreshRedisCategory(){// 從數(shù)據(jù)庫查詢廣告QueryWrapper<Category> queryWrapper = new QueryWrapper();queryWrapper.eq("status",1);List<Category> categories = categoryMapper.selectList(queryWrapper);// 刪除redis中的原有廣告數(shù)據(jù)redisTemplate.delete("categories");// 將新的廣告數(shù)據(jù)同步到redis中ListOperations<String,Category> listOperations = redisTemplate.opsForList();listOperations.leftPushAll("categories",categories);}
}