您好,登錄后才能下訂單哦!
本文小編為大家詳細(xì)介紹“SpringBoot怎么整合ActiveMQ實(shí)現(xiàn)秒殺隊(duì)列”,內(nèi)容詳細(xì),步驟清晰,細(xì)節(jié)處理妥當(dāng),希望這篇“SpringBoot怎么整合ActiveMQ實(shí)現(xiàn)秒殺隊(duì)列”文章能幫助大家解決疑惑,下面跟著小編的思路慢慢深入,一起來(lái)學(xué)習(xí)新知識(shí)吧。
前言
在實(shí)際生產(chǎn)環(huán)境中中,通常生產(chǎn)者和消費(fèi)者會(huì)是兩個(gè)獨(dú)立的應(yīng)用,這樣才能通過(guò)消息隊(duì)列實(shí)現(xiàn)了服務(wù)解耦和廣播。因?yàn)榇隧?xiàng)目?jī)H是一個(gè)案例,為了方便期間,生產(chǎn)和消費(fèi)定義在了同一個(gè)項(xiàng)目中。
基礎(chǔ)配置
pom.xml 添加依賴:
<!-- activemq -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
application.properties 基礎(chǔ)配置:
# activemq 基礎(chǔ)配置
#spring.activemq.broker-url=tcp://47.94.232.109:61616
# 生產(chǎn)環(huán)境設(shè)置密碼
#spring.activemq.user=admin
#spring.activemq.password=123456
#spring.activemq.in-memory=true
#spring.activemq.pool.enabled=false
項(xiàng)目集成
定義生產(chǎn)者:
import javax.jms.Destination;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;
@Component
public class ActiveMQSender {
@Autowired
private JmsMessagingTemplate jmsTemplate;
/*
* 發(fā)送消息,destination是發(fā)送到的隊(duì)列,message是待發(fā)送的消息
*/
public void sendChannelMess(Destination destination, final String message){
jmsTemplate.convertAndSend(destination, message);
}
}
定義消費(fèi)者:
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.stereotype.Service;
import com.itstyle.seckill.common.entity.Result;
import com.itstyle.seckill.common.enums.SeckillStatEnum;
import com.itstyle.seckill.common.redis.RedisUtil;
import com.itstyle.seckill.common.webSocket.WebSocketServer;
import com.itstyle.seckill.service.ISeckillService;
@Service
public class ActiveMQConsumer {
@Autowired
private ISeckillService seckillService;
@Autowired
private RedisUtil redisUtil;
// 使用JmsListener配置消費(fèi)者監(jiān)聽(tīng)的隊(duì)列,其中text是接收到的消息
@JmsListener(destination = "seckill.queue")
public void receiveQueue(String message) {
//收到通道的消息之后執(zhí)行秒殺操作(超賣)
String[] array = message.split(";");
Result result = seckillService.startSeckilDBPCC_TWO(Long.parseLong(array[0]), Long.parseLong(array[1]));
if(result.equals(Result.ok(SeckillStatEnum.SUCCESS))){
WebSocketServer.sendInfo(array[0].toString(), "秒殺成功");//推送給前臺(tái)
}else{
WebSocketServer.sendInfo(array[0].toString(), "秒殺失敗");//推送給前臺(tái)
redisUtil.cacheValue(array[0], "ok");//秒殺結(jié)束
}
}
}
測(cè)試案例:
@ApiOperation(value="秒殺五(ActiveMQ分布式隊(duì)列)",nickname="科幫網(wǎng)")
@PostMapping("/startActiveMQQueue")
public Result startActiveMQQueue(long seckillId){
seckillService.deleteSeckill(seckillId);
final long killId = seckillId;
LOGGER.info("開(kāi)始秒殺五");
for(int i=0;i<1000;i++){
final long userId = i;
Runnable task = new Runnable() {
@Override
public void run() {
if(redisUtil.getValue(killId+"")==null){
Destination destination = new ActiveMQQueue("seckill.queue");
//思考如何返回給用戶信息ws
activeMQSender.sendChannelMess(destination,killId+";"+userId);
}else{
//秒殺結(jié)束
}
}
};
executor.execute(task);
}
try {
Thread.sleep(10000);
redisUtil.cacheValue(killId+"", null);
Long seckillCount = seckillService.getSeckillCount(seckillId);
LOGGER.info("一共秒殺出{}件商品",seckillCount);
} catch (InterruptedException e) {
e.printStackTrace();
}
return Result.ok();
}
注意事項(xiàng)
spring-boot-starter-activemq 依賴即可默認(rèn)采用內(nèi)嵌的 ActiveMQ,這個(gè)跟 elasticsearch 是一樣的,測(cè)試的小伙伴可以不用安裝,注釋掉相關(guān)參數(shù),使用默認(rèn)即可。
如果自行安裝 ActiveMQ 記得配置防火墻/安全組,配置web訪問(wèn)密碼以及連接密碼。
在生產(chǎn)環(huán)境下盡量還是采用外部 activemq 服務(wù),提高擴(kuò)展性、穩(wěn)定性、可維護(hù)性。
讀到這里,這篇“SpringBoot怎么整合ActiveMQ實(shí)現(xiàn)秒殺隊(duì)列”文章已經(jīng)介紹完畢,想要掌握這篇文章的知識(shí)點(diǎn)還需要大家自己動(dòng)手實(shí)踐使用過(guò)才能領(lǐng)會(huì),如果想了解更多相關(guān)內(nèi)容的文章,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。