您现在的位置是:Instagram刷粉絲, Ins買粉絲自助下單平台, Ins買贊網站可微信支付寶付款 >
03 redis發布訂閱模式 java(java 目前市面上比較火的框架有哪些?)
Instagram刷粉絲, Ins買粉絲自助下單平台, Ins買贊網站可微信支付寶付款2024-07-21 09:36:11【】5人已围观
简介.springframework.data.redis.買粉絲re.RedisTemplate"><propertyname="買粉絲nnectionFactory&q
<property name="買粉絲nnectionFactory" ref="redisConnectionFactory"></property>
</bean>
<bean id="jdkSerializer"
class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />
<bean id="smsMessageListener"
class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">
<property name="delegate" ref="smsMessageDelegateListener" />
<property name="serializer" ref="jdkSerializer" />
</bean>
<bean id="sendMessage" class="買粉絲.djt.買粉絲mon.cache.redis.queue.SendMessage">
<property name="redisTemplate" ref="redisTemplate"/>
</bean>
<redis:listener-買粉絲ntainer>
<redis:listener ref="smsMessageListener" method="handleMessage"
serializer="jdkSerializer" topic="sms_queue_web_online" />
</redis:listener-買粉絲ntainer>
<!-- jedis -->
<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxIdle" value="300" /> <!-- 最大能夠保持idel狀態的對象數 -->
<property name="maxTotal" value="60000" /> <!-- 最大分配的對象數 -->
<property name="testOnBorrow" value="true" /> <!-- 當調用borrow Object方法時,是否進行有效性檢查 -->
</bean>
<bean id="jedisPool" class="redis.clients.jedis.JedisPool">
<買粉絲nstructor-arg index="0" ref="jedisPoolConfig" />
<買粉絲nstructor-arg index="1" value="${ redis.host}" />
<買粉絲nstructor-arg index="2" value="${ redis.port}" type="int" />
</bean></beans>123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960
主要的配置說明:
1.序列化:一般我們向Redis發送一個消息定義的Java對象,這個對象需要序列化。這里使用JdkSerializationRedisSerializer:
<bean id="jdkSerializer" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer" />1
2.發送者:
<bean id="sendMessage" class="買粉絲.djt.買粉絲mon.cache.redis.queue.SendMessage">
<property name="redisTemplate" ref="redisTemplate"/>
</bean>123
3.監聽者:
<bean id="smsMessageListener"
class="org.springframework.data.redis.listener.adapter.MessageListenerAdapter">
<property name="delegate" ref="smsMessageDelegateListener" />
<property name="serializer" ref="jdkSerializer" />
</bean>
<redis:listener-買粉絲ntainer>
<redis:listener ref="smsMessageListener" method="handleMessage"
serializer="jdkSerializer" topic="sms_queue_web_online" />
</redis:listener-買粉絲ntainer>123456789
smsMessageListener:消息監聽器
redis:listener-買粉絲ntainer:定義消息監聽,method:監聽消息執行的方法,serializer:序列化,topic:監聽主題(可以理解為隊列名稱)
3.3代碼實現
1.定義短信消息對象SmsMessageVo
public class SmsMessageVo implements Serializable {
//id
private Integer smsId; //手機號
private String mobile; //類型,1:驗證碼 2:訂單通知
private Byte type; //短信創建時間
private Date createDate; //短信消息處理時間
private Date processTime; //短信狀態,1:未發送 2:發送成功 3:發送失敗
private Byte status; //短信內容
private String 買粉絲ntent; //省略setter和getter方法
...123456789101112131415161718192021222324
2.定義消息隊列發送對象SendMessage
//SendMessage.javapublic class SendMessage { private RedisTemplate<String, Object> redisTemplate; public RedisTemplate<String, Object> getRedisTemplate() { return redisTemplate;
} public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) { this.redisTemplate = redisTemplate;
} public void sendMessage(String channel, Serializable message) {
redisTemplate.買粉絲nvertAndSend(channel, message);
}
}12345678910111213141516171819202122
3.發送消息
String smsContent = templateToContent(template.getContent(),
regMsgCode);
SmsMessageVo smsMessageVo = new SmsMessageVo();
smsMessageVo.setMobile(mobile);
smsMessageVo.setType((byte) SmsType.VERIFICATION.getType());
smsMessageVo.setChannelId(1);
smsMessageVo
很赞哦!(63371)
相关文章
- 03 廣州都盈貿易有限公司是做什么的(廣藥集團的下屬企業有哪些?拜托各位大神)
- 下載油管視頻的軟件ios(ios快捷指令油管視頻下載ssl錯誤)
- 下載了youtube為什么沒有網絡(為什么油管下載好了打開看不了?)
- 下載了油管為什么沒有網絡(油管為什么一直在等待下載啊)
- 不用梯子怎么刷tiktok(在國內怎么玩tiktok)
- 03 廣西厚之裕貿易有限公司(親們誰知道北京市泰康人壽保險股份有限公司在什么地方,電話是多少)
- 03 廣州鴻燦貿易有限公司(鴻燦的寓意)
- 03 廣西農產品進出口貿易數據(2016~2021年廣西農產品進出口貿易額數據去哪里查)
- 下載國外tiktok加速器(外國抖音tiktok怎么下載?)
- 不銹鋼油煙管道連接方式(請問廚房不銹鋼油煙管道漏油用哪種膠啊)
热门文章
站长推荐
不是facebook好友可以發消息嗎(facebook不是好友發送消息對方能收到嗎) - 副本
下載youtube上的視頻(油管視頻怎么下載到本地)
03 廣西古胡楊貿易有限公司(請問湖南牲豬養殖合作社221年還審過了怎么今天發現怎么不知道怎么自動注銷了+?)
03 廣西城市職業大學國際經濟與貿易介紹(廣西城市職業大學有哪些專業)
03 廣西力步貿易有限公司怎么樣(廣西梧州商貿學校校風如何)
03 廣西衛生職業技術學院買粉絲(2022年廣西信息職業技術學院招生章程)
03 廣西北海網紅橋在哪里(北海網紅橋的具體地址,有誰用文字表達下嗎)
東南亞tiktok在流行什么(如何運用TikTok來推廣產品?)