淺析JavaWeb項目架構(gòu)之Redis分布式日志隊列
摘要：
架構(gòu)、分布式、日志隊列，標題自己都看著唬人，其實就是一個日志收集的功能，只不過中間加了一個Redis做消息隊列罷了。 為什么需要消息隊列？ 當系統(tǒng)中出現(xiàn)“生產(chǎn)“和“消費“的速度或穩(wěn)定性等因素不一致的時候，就需要消息隊列，作為抽象層，彌合雙方的差異。
架構(gòu)、分布式、日志隊列，標題自己都看著唬人，其實就是一個日志收集的功能，只不過中間加了一個Redis做消息隊列罷了。
為什么需要消息隊列？
當系統(tǒng)中出現(xiàn)“生產(chǎn)“和“消費“的速度或穩(wěn)定性等因素不一致的時候，就需要消息隊列，作為抽象層，彌合雙方的差異。
比如我們系統(tǒng)中常見的郵件、短信發(fā)送，把這些不需要及時響應的功能寫入隊列，異步處理請求，減少響應時間。
如何實現(xiàn)？
成熟的JMS消息隊列中間件產(chǎn)品市面上有很多，但是基于目前項目的架構(gòu)以及部署情況，我們采用Redis做消息隊列。
為什么用Redis？
Redis中l(wèi)ist數(shù)據(jù)結(jié)構(gòu)，具有“雙端隊列”的特性，同時redis具有持久數(shù)據(jù)的能力，因此redis實現(xiàn)分布式隊列是非常安全可靠的。
它類似于JMS中的“Queue”，只不過功能和可靠性(事務性)并沒有JMS嚴格。Redis本身的高性能和"便捷的"分布式設計(replicas,sharding),可以為實現(xiàn)"分布式隊列"提供了良好的基礎。
提供者端
項目采用第三方redis插件spring-data-redis，不清楚如何使用的請自行谷歌或者百度。
redis.properties：
#redis 配置中心 redis.host=192.168.1.180 redis.port=6379 redis.password=123456 redis.maxIdle=100 redis.maxActive=300 redis.maxWait=1000 redis.testOnBorrow=true redis.timeout=100000
redis配置：
<!-- redis 配置 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig" />
<bean id="jedisConnectionFactory"
class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
<property name="hostName" value="${redis.host}" />
<property name="port" value="${redis.port}" />
<property name="password" value="${redis.password}" />
<property name="timeout" value="${redis.timeout}" />
<property name="poolConfig" ref="jedisPoolConfig" />
<property name="usePool" value="true" />
</bean>
<bean id="redisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
<property name="connectionFactory" ref="jedisConnectionFactory" />
</bean>
切面日志配置(偽代碼)：
/**
* 系統(tǒng)日志，切面處理類
* 創(chuàng)建者 小柒2012
* 創(chuàng)建時間 2018年1月15日
*/
@Component
@Scope
@Aspect
public class SysLogAspect {
@Autowired
private RedisTemplate<String, String> redisTemplate;
//注解是基于swagger的API，也可以自行定義
@Pointcut("@annotation(io.swagger.annotations.ApiOperation)")
public void logPointCut() {
}
@Around("logPointCut()")
public Object around(ProceedingJoinPoint point) throws Throwable {
Object result = point.proceed();
//把日志消息寫入itstyle_log頻道
redisTemplate.convertAndSend("itstyle_log","日志數(shù)據(jù)，自行處理");
return result;
}
}
消費者端
Redis配置：
<!-- redis 配置 -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig" />
<bean id="jedisConnectionFactory"
class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
<property name="hostName" value="${redis.host}" />
<property name="port" value="${redis.port}" />
<property name="password" value="${redis.password}" />
<property name="timeout" value="${redis.timeout}" />
<property name="poolConfig" ref="jedisPoolConfig" />
<property name="usePool" value="true" />
</bean>
<bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate"
p:connection-factory-ref="jedisConnectionFactory">
<property name="keySerializer">
<bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />
</property>
<property name="hashKeySerializer">
<bean class="org.springframework.data.redis.serializer.StringRedisSerializer" />
</property>
</bean>
<!-- 監(jiān)聽實現(xiàn)類 -->
<bean id="listener" class="com.itstyle.market.common.listener.MessageDelegateListenerImpl"/>
<bean id="stringRedisSerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer" />
<redis:listener-container connection-factory="jedisConnectionFactory">
<!-- topic代表監(jiān)聽的頻道，是一個正規(guī)匹配 其實就是你要訂閱的頻道-->
<redis:listener ref="listener" serializer="stringRedisSerializer" method="handleLog" topic="itstyle_log"/>
</redis:listener-container>
監(jiān)聽接口：
public interface MessageDelegateListener {
public void handleLog(Serializable message);
}
監(jiān)聽實現(xiàn)：
public class MessageDelegateListenerImpl implements MessageDelegateListener {
@Override
public void handleLog(Serializable message) {
if(message == null){
System.out.println("null");
}else {
//處理日志數(shù)據(jù)
}
}
}
Q&A
【問題一】為什么使用Redis？
上面其實已經(jīng)有做說明，盡管市面上有許多很穩(wěn)定的產(chǎn)品，比如可能大家會想到的Kafka、RabbitMQ以及RocketMQ。但是由于項目本身使用了Redis做分布式緩存，基于省事可行的原則就選定了Redis。
【問題二】日志數(shù)據(jù)如何存儲？
原則上是不建議存儲到關系數(shù)據(jù)庫的，比如MySql，畢竟產(chǎn)生的日志數(shù)量是巨大的，建議存儲到Elasticsearch等非關系型數(shù)據(jù)庫。
【問題三】切面日志收集是如何實現(xiàn)的？
切面日志需要引入spring-aspects相關Jar包，并且配置使Spring采用CGLIB代理 。
開源項目源碼(參考)：https://gitee.com/52itstyle/spring-boot-mail
總結(jié)
以上所述是小編給大家介紹的JavaWeb項目架構(gòu)之Redis分布式日志隊列，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持！
相關文章
Java基本數(shù)據(jù)類型(動力節(jié)點java學院整理)
Java數(shù)據(jù)類型（type）可以分為兩大類：基本類型（primitive types）和引用類型（reference types）。下面是動力節(jié)點給大家整理java基本數(shù)據(jù)類型相關知識，感興趣的朋友一起學習吧2017-03-03
這篇文章主要介紹了解析Java的可變參數(shù)列表及其使用時的注意點,注意可變參數(shù)必須位于最后一項,需要的朋友可以參考下2016-03-03
這篇文章主要為大家詳細介紹了java實現(xiàn)對服務器的自動巡檢郵件通知，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-05-05
這篇文章主要為大家詳細介紹了java網(wǎng)上圖書商城，支付模塊,具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-12-12
這篇文章主要介紹了JavaWeb如何實現(xiàn)限制單個賬號多處登錄問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-08-08
本篇文章主要介紹了spring mvc 和ajax異步交互完整實例代碼，簡單的AJAX+SpringMVC的異步交互小例子，有興趣的可以了解一下。2017-02-02
這篇文章主要介紹了應用Java泛型和反射導出CSV文件的方法,通過一個自定義函數(shù)結(jié)合泛型與反射的應用實現(xiàn)導出CSV文件的功能,具有一定的參考借鑒價值,需要的朋友可以參考下2014-12-12
在Java Web的開發(fā)過程中，如果希望調(diào)用Java對象轉(zhuǎn)化成JSON對象等操作，我們需要引入相關jar包，下面小編給大家?guī)砹薺ava web中對json的使用，一起看看吧2018-08-08
今天給大家?guī)淼氖顷P于Java的相關知識,文章圍繞著Java中JSON數(shù)據(jù)的生成與解析展開,文中有非常詳細的介紹及代碼示例,需要的朋友可以參考下2021-06-06
Java用POI解析excel并獲取所有單元格數(shù)據(jù)的實例
下面小編就為大家?guī)硪黄狫ava用POI解析excel并獲取所有單元格數(shù)據(jù)的實例。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-10-10