Kaedah Redis dan contoh aplikasi untuk melaksanakan baris gilir tak segerak

Redis ialah pangkalan data storan nilai kunci berasaskan memori berprestasi tinggi Ia bukan sahaja menyokong penyimpanan pasangan nilai kunci, tetapi juga menyokong beberapa struktur data yang kompleks, seperti Senarai, Set, Set Isih dan Hash. Struktur data Senarai sangat sesuai sebagai struktur data untuk baris gilir tak segerak kerana ia menyokong memasukkan dan memadam elemen pada kedua-dua hujungnya. Artikel ini akan memperkenalkan cara menggunakan Redis untuk melaksanakan baris gilir tak segerak dan memberikan contoh aplikasi.

1. Bagaimana Redis melaksanakan baris gilir tak segerak

Walaupun Senarai dalam Redis menyokong memasukkan dan memadam elemen pada kedua-dua hujungnya, kerana pelaksanaan khasnya, ia tidak dapat menjamin bahawa semua operasi adalah Ia adalah O(1 ) kerumitan. Sebagai contoh, jika terdapat banyak elemen dalam Senarai, maka apabila memadamkan elemen, anda perlu melintasi keseluruhan Senarai untuk mencari, dan kerumitan masa akan menjadi O(N). Oleh itu, apabila melaksanakan baris gilir tak segerak, anda perlu memberi perhatian kepada perkara berikut:

1. Gunakan arahan LPUSH dan BRPOP

Apabila melaksanakan baris gilir tak segerak, kita harus cuba elakkan menggunakan arahan LPOP dan RPUSH, sebaliknya gunakan arahan LPUSH dan BRPOP. Oleh kerana arahan LPOP dan RPUSH memasukkan dan memadam elemen pada kedua-dua hujung Senarai, apabila terdapat banyak elemen dalam Senarai, setiap operasi perlu merentasi keseluruhan Senarai, yang secara relatifnya tidak cekap manakala arahan LPUSH dan BRPOP menggunakan penyekatan Redis ciri dilaksanakan. Apabila Senarai kosong, arahan BRPOP menunggu sehingga terdapat elemen dalam Senarai, dan kemudian mengembalikan elemen yang muncul. Ini mengelakkan merentasi keseluruhan Senarai dan meningkatkan kecekapan.

2. Tetapkan tamat masa yang sesuai

Apabila menggunakan arahan BRPOP, anda perlu menetapkan tamat masa yang sesuai untuk menghalang program daripada menyekat sepanjang masa. Secara umumnya, anda boleh menetapkan tamat masa yang agak singkat, seperti 1 saat, supaya program dapat mengesan dengan cepat sama ada elemen baharu ditambahkan. Pada masa yang sama, perlu juga ambil perhatian bahawa menetapkan tempoh tamat masa terlalu singkat boleh menyebabkan arahan BRPOP dilaksanakan dengan kerap dan meningkatkan beban pada pelayan Redis.

3. Gunakan berbilang Senarai

Untuk meningkatkan prestasi serentak, anda boleh menggunakan berbilang Senarai, setiap Senarai bertanggungjawab untuk menyimpan sebahagian daripada tugas. Tugasan yang berbeza boleh diletakkan dalam Senarai yang berbeza untuk meningkatkan kesan perkongsian data. Pada masa yang sama, setiap Senarai juga boleh mempunyai urutan pengguna bebas, yang boleh dilaksanakan secara selari apabila menggunakan tugas, dengan itu meningkatkan prestasi serentak keseluruhan sistem.

2. Contoh aplikasi baris gilir asynchronous Redis

Di bawah kami memberikan contoh aplikasi menggunakan baris gilir tak segerak Redis: digunakan untuk menghantar kod pengesahan SMS. Dalam aplikasi ini, kami boleh membahagikan kod pengesahan SMS untuk dihantar kepada berbilang senarai mengikut nombor telefon mudah alih, dan kemudian memulakan urutan pengguna untuk setiap Senarai untuk menghantar mesej SMS. Proses pelaksanaan khusus adalah seperti berikut:

1. Buat sambungan Redis

Gunakan bahasa Java untuk menyambung ke pelayan Redis Kodnya adalah seperti berikut:

Jedis jedis = new Jedis("localhost", 6379);

2. Tambah tugas

Tambahkan kod pengesahan SMS untuk dihantar ke Senarai yang sepadan Kodnya adalah seperti berikut:

jedis.lpush(mobile, code);

Di mana mudah alih adalah telefon bimbit. nombor dan kod adalah kod pengesahan.

3. Tugas penggunaan

Mulakan urutan pengguna untuk setiap Senarai untuk menghantar mesej SMS adalah seperti berikut:

new Thread(new SmsSender(jedis, mobile)).start();

Antaranya, SmsSender. kelas digunakan untuk menghantar SMS, parameter pembina jedis digunakan untuk menyambung ke pelayan Redis, dan mudah alih digunakan untuk menentukan Senarai yang perlu diproses.

4. Pelaksanaan rangkaian pengguna

Urutan pengguna mengeluarkan kod pengesahan yang perlu dihantar daripada Senarai melalui arahan BRPOP, dan kemudian memanggil SMS pihak ketiga menghantar antara muka untuk menghantarnya. Kod adalah seperti berikut:

public class SmsSender implements Runnable {
    private Jedis jedis;
    private String mobile;
    public SmsSender(Jedis jedis, String mobile) {
        this.jedis = jedis;
        this.mobile = mobile;
    }
    @Override
    public void run() {
        while (true) {
            List<String> codes = jedis.brpop(1, mobile);
            if (codes != null) {
                String code = codes.get(1);
                // 调用第三方短信接口发送验证码
                sendSms(mobile, code);
            }
        }
    }
}

Tamat masa 1 saat boleh dilaraskan mengikut keperluan sebenar.

Ringkasan

Artikel ini memperkenalkan cara menggunakan Redis untuk melaksanakan baris gilir tak segerak dan memberikan contoh aplikasi praktikal. Apabila melaksanakan baris gilir tak segerak, anda perlu memberi perhatian untuk menggunakan arahan LPUSH dan BRPOP, menetapkan tamat masa yang sesuai dan menggunakan berbilang Senarai untuk meningkatkan prestasi serentak. Dengan menggunakan baris gilir tak segerak Redis, anda boleh meningkatkan prestasi konkurensi sistem dengan berkesan dan meningkatkan pengalaman pengguna.

Atas ialah kandungan terperinci Kaedah Redis dan contoh aplikasi untuk melaksanakan baris gilir tak segerak. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!