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

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

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

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

通過使用list的lpop及l(fā)push命令進(jìn)行隊列的寫入和消費，可以輕松實現(xiàn)消息隊列；由于它是獨立于游戲服務(wù)器的，所以多個游戲服務(wù)器可以通過它來交換數(shù)據(jù)、發(fā)送事件，通過使用sorted set，甚至可以構(gòu)建有優(yōu)先級的隊列系統(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)建隊列系統(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

云服務(wù)器 GPU云服務(wù)器 redis 隊列 redis隊列 redis消息隊列免費redis 消息隊列

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

轉(zhuǎn)載請注明本文地址：http://m.hztianpu.com/yun/126762.html

發(fā)表評論

登陸后可評論

0條評論

ernest.wang

男|高級講師

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

TA的文章

DeepSeek R1系列模型一鍵部署教程，支持云端免費體驗！

閱讀 1583·2025-02-07 13:29
特朗普勝任，將對跨境電商賣家產(chǎn)生哪些影響？

閱讀 1008·2024-11-07 18:25
幻獸帕魯常見問題匯總

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

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

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

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

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

閱讀 2395·2023-06-02 13:36

成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲中文字幕日韩无码

資訊專欄INFORMATION COLUMN

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

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