構(gòu)建隊(duì)列系統(tǒng) 云內(nèi)存 UMem Redis

ernest.wang 發(fā)布于2022-07-12 17:04 / 2579人閱讀

摘要：構(gòu)建隊(duì)列系統(tǒng)構(gòu)建隊(duì)列系統(tǒng)構(gòu)建隊(duì)列系統(tǒng)通過(guò)使用的及命令進(jìn)行隊(duì)列的寫(xiě)入和消費(fèi)，可以輕松實(shí)現(xiàn)消息隊(duì)列由于它是獨(dú)立于游戲服務(wù)器的，所以多個(gè)游戲服務(wù)器可以通過(guò)它來(lái)交換數(shù)據(jù)發(fā)送事件，通過(guò)使用，甚至可以構(gòu)建有優(yōu)先級(jí)的隊(duì)列系統(tǒng)。構(gòu)建隊(duì)列系統(tǒng)輸出

構(gòu)建隊(duì)列系統(tǒng)

通過(guò)使用list的lpop及l(fā)push命令進(jìn)行隊(duì)列的寫(xiě)入和消費(fèi)，可以輕松實(shí)現(xiàn)消息隊(duì)列；由于它是獨(dú)立于游戲服務(wù)器的，所以多個(gè)游戲服務(wù)器可以通過(guò)它來(lái)交換數(shù)據(jù)、發(fā)送事件，通過(guò)使用sorted set，甚至可以構(gòu)建有優(yōu)先級(jí)的隊(duì)列系統(tǒng)。

import redis.clients.jedis.Jedis;
class ProducerThread extends Thread {
    private Jedis jedis;
    private int port;
    private String host,key;
    ProducerThread(String host, int port, String key) {
        super(host);
        this.key = key;
        this.port = port;
        jedis = new Jedis(host, port);
    }
    protected void finalize( ){
        jedis.close();
    }
    public void run() {
        //System.out.println("ProducerThread is running...");
        for(int i = 0; i < 10; i++) {
            jedis.lpush(key, "job"+ Integer.toString(i));
            System.out.println("ProducerThread push job"+ Integer.toString(i));
        }
    }
}
class ConsumerThread extends Thread {
    private Jedis jedis;
    private int port;
    private String host,key;
    ConsumerThread(String host, int port, String key) {
        super(host);
        this.key = key;
        this.port = port;
        jedis = new Jedis(host, port);
    }
    protected void finalize( ) {
        jedis.close();
    }
    public void run() {
        //構(gòu)建隊(duì)列系統(tǒng)
        //System.out.println("ConsumerThread is running...");
        for(int i = 0; i < 10; i++) {
            System.out.println("ConsumerThread pop "+ jedis.lpop(key));
        }
    }
}
public class QueueSystem {
    public static void main(String[] args) {
        String host = "127.0.0.1";
        int port = 10011;
        String key = "jobs";
        ProducerThread pT = new ProducerThread(host,port,key);
        ConsumerThread cT = new ConsumerThread(host,port,key);
        pT.start();
        cT.start();
    }
}

輸出:

ConsumerThread pop null
ProducerThread push job0
ConsumerThread pop job0
ProducerThread push job1
ConsumerThread pop job1
ProducerThread push job2
ConsumerThread pop job2
ProducerThread push job3
ConsumerThread pop job3
ProducerThread push job4
ConsumerThread pop job4
ProducerThread push job5
ConsumerThread pop job5
ProducerThread push job6
ConsumerThread pop job6
ProducerThread push job7
ConsumerThread pop job7
ProducerThread push job8
ConsumerThread pop job8
ProducerThread push job9

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/126762.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

ernest.wang

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

特朗普勝任，將對(duì)跨境電商賣(mài)家產(chǎn)生哪些影響？

閱讀 455·2024-11-07 18:25
幻獸帕魯常見(jiàn)問(wèn)題匯總

閱讀 130770·2024-02-01 10:43
在Linux和Windows上部署帕魯?shù)膮^(qū)別？

閱讀 946·2024-01-31 14:58
怎么重啟幻獸帕魯云服務(wù)器？

閱讀 908·2024-01-31 14:54
幻獸帕魯自建服務(wù)器存檔備份及回檔 - windows篇

閱讀 83008·2024-01-29 17:11
小白必讀教程，幻獸帕魯服務(wù)器手動(dòng)部署教程 - Windows篇

閱讀 3267·2024-01-25 14:55
A800GPU租用-A800顯卡

閱讀 2063·2023-06-02 13:36
5G短信和普通短信的區(qū)別

閱讀 3171·2023-05-23 10:26

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專(zhuān)欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

構(gòu)建隊(duì)列系統(tǒng) 云內(nèi)存 UMem Redis