Membina bilik sembang masa nyata menggunakan Redis dan C#: Bagaimana untuk mencapai komunikasi segera

Membina ruang sembang masa nyata menggunakan Redis dan C#: Bagaimana untuk mencapai komunikasi segera

Pengenalan:
Dalam era Internet hari ini, pemesejan segera telah menjadi cara komunikasi yang semakin penting. Sama ada media sosial, permainan dalam talian atau perkhidmatan pelanggan dalam talian, bilik sembang langsung memainkan peranan penting. Artikel ini akan memperkenalkan cara menggunakan Redis dan C# untuk membina ruang sembang masa nyata yang ringkas dan memahami mekanisme pemesejan berdasarkan model terbitkan/langganan.

1. Persediaan
Sebelum kita mula, kita perlu menyediakan beberapa alatan dan persekitaran:

1. Visual Studio: untuk menulis dan menyahpepijat kod C#.
2. Redis: digunakan untuk menyimpan mesej dalam bilik sembang.
3. StackExchange.Redis: Pustaka C# untuk berinteraksi dengan Redis.

2. Persediaan projek

1. Buat projek aplikasi konsol C# baharu.
2. Pasang perpustakaan StackExchange.Redis dalam konsol pengurus pakej NuGet.

3 Sambung ke Redis
Dalam kaedah Utama di pintu masuk program, kita perlu mewujudkan sambungan dengan Redis. Berikut ialah kod sampel:

using StackExchange.Redis;

class Program
{
    static void Main(string[] args)
    {
        ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost"); 
        ISubscriber subscriber = redis.GetSubscriber();

        // 接下来的代码将在后面的章节中逐步添加
    }
}

Dalam kod di atas, kami mula-mula mencipta objek ConnectionMultiplexer, yang digunakan untuk menyambung ke Redis. Kemudian, kami menggunakan kaedah GetSubscriber() untuk mencipta objek ISubscriber, yang digunakan untuk menerbitkan dan melanggan mesej. ConnectionMultiplexer对象，该对象用于连接到Redis。然后，我们使用GetSubscriber()方法创建了一个ISubscriber对象，该对象用于发布和订阅消息。

四、实现发布和订阅

1. 实现发布消息功能：

   static void PublishMessage(ISubscriber subscriber)
   {
    Console.WriteLine("请输入消息内容：");
    string message = Console.ReadLine();
   
    subscriber.Publish("chatroom", message);
   }

   以上代码中，我们通过Console.ReadLine()方法获取用户输入的消息内容，并使用subscriber.Publish()方法将消息发布到名为"chatroom"的频道中。

2. 实现订阅消息功能：

   static void SubscribeMessage(ISubscriber subscriber)
   {
    subscriber.Subscribe("chatroom", (channel, message) =>
    {
        Console.WriteLine($"收到新消息：{message}");
    });
   }

   以上代码中，我们使用subscriber.Subscribe()

   4. Laksanakan penerbitan dan langganan

Laksanakan fungsi penerbitan mesej:

static void Main(string[] args)
{
    ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("localhost");
    ISubscriber subscriber = redis.GetSubscriber();

    Console.WriteLine("欢迎来到实时聊天室！");

    Task.Run(() => SubscribeMessage(subscriber));

    while (true)
    {
        Console.WriteLine("请输入操作：1. 发布消息；2. 退出");
        string option = Console.ReadLine();

        switch (option)
        {
            case "1":
                PublishMessage(subscriber);
                break;
            case "2":
                return;
            default:
                Console.WriteLine("无效的操作，请重新输入！");
                break;
        }
    }
}

Dalam kod di atas, kami memperoleh kandungan mesej yang dimasukkan oleh pengguna melalui kaedah Console.ReadLine() , dan gunakan subscriber.Publish() menerbitkan mesej ke saluran bernama "chatroom".

Laksanakan fungsi mesej langganan:
1. rrreee
Dalam kod di atas, kami menggunakan kaedah subscriber.Subscribe() untuk melanggan saluran bernama "chatroom" dan mencetaknya apabila mesej baharu diterima.
3. 5 Jalankan bilik sembang

Sepadukan fungsi penerbitan dan langganan ke dalam projek:

rrreee
Dalam kod di atas, kami terus menerima operasi pengguna melalui gelung sementara, dan memilih untuk menerbitkan mesej atau keluar dari kod. program berdasarkan Fungsi operasi.

🎜6. Jalankan dan uji🎜🎜🎜Jalankan program dan masuk ke ruang sembang masa nyata. 🎜🎜Masukkan "1" dan kemudian masukkan kandungan mesej yang ingin anda terbitkan. Mesej akan disiarkan secara automatik ke saluran "ruang sembang". 🎜🎜Jalankan berbilang kejadian pada mesin yang sama dan anda boleh melihat bahawa mesej akan disiarkan ke semua kejadian yang melanggan saluran "ruang sembang". 🎜🎜🎜Kesimpulan: 🎜Melalui contoh mudah di atas, struktur asas menggunakan Redis untuk membina ruang sembang masa nyata dalam C# telah selesai. Pembaca boleh menjalankan pembangunan dan pengoptimuman selanjutnya berdasarkan struktur ini, seperti menambah pengesahan pengguna, storan rekod sembang dan fungsi lain. Saya harap artikel ini dapat membantu anda memahami cara menggunakan Redis dan C# untuk membina ruang sembang masa nyata. 🎜

Atas ialah kandungan terperinci Membina bilik sembang masa nyata menggunakan Redis dan C#: Bagaimana untuk mencapai komunikasi segera. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!