Core가 .NET에서 Redis 게시 및 구독을 사용하는 방법에 대한 분석 예

이 기사는 주로 .net Core가 Redis를 사용하여 게시하고 구독하는 방법을 소개합니다. 편집자는 이것이 꽤 좋다고 생각합니다. 편집기를 따라 살펴보겠습니다

Redis는 매우 강력한 인메모리 데이터베이스로 일반적으로 캐시로 사용되지만, 예를 들어 유명한 분산 프레임워크인 dubbo는 Redis를 사용할 수 있습니다. . 서비스 등록 센터를 만듭니다. 다음으로 Redis를 이용한 .net core의 게시/구독 기능을 소개하겠습니다.

Redis 게시 및 구독

Redis 게시 및 구독(pub/sub)은 메시지 통신 모델입니다. 발신자(pub)는 메시지를 보내고 구독자(sub)는 메시지를 받습니다.
Redis 클라이언트는 원하는 수의 채널을 구독할 수 있습니다.

다음 그림은 채널1과 이 채널을 구독하는 세 클라이언트(클라이언트2, 클라이언트5, 클라이언트1) 사이의 관계를 보여줍니다.

PUBLISH 명령을 통해 채널 채널1에 새 메시지가 전송되면 이 메시지는 다음과 같습니다. 구독하는 세 클라이언트에게 전송됩니다.

Redis 명령 사용

먼저 subscribe redismessage 명령을 통해 두 클라이언트를 redismessage 채널에 구독합니다.

그런 다음 Redis에서 Redis를 엽니다. 클라이언트 측에서 게시 redismessage "메시지 콘텐츠" 명령을 사용하여 메시지를 게시하세요

.net 코어를 사용하여 구현

여기서 선택한 연결 드라이버는 StackExchange.Redis입니다. 여기서는 ServiceStack에 유의해야 합니다. .Redis 연결 드라이버는 점차 상용화를 위해 4.0 이상 버전에서는 제한이 있으므로 무료이고 사용하기 쉬운 StackExchange.Redis를 선택하고 nuget을 사용하여 설치합니다.

구독 클라이언트 구축

//创建连接
using (ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("127.0.0.1:6379"))
{
  ISubscriber sub = redis.GetSubscriber();

  //订阅名为 messages 的通道

  sub.Subscribe("messages", (channel, message) => {

    //输出收到的消息
    Console.WriteLine($"[{DateTime.Now:HH:mm:ss}] {message}");
  });
  Console.WriteLine("已订阅 messages");
  Console.ReadKey();
}

출판 클라이언트 구축

//创建连接
using (ConnectionMultiplexer redis = ConnectionMultiplexer.Connect("127.0.0.1:6379"))
{
  ISubscriber sub = redis.GetSubscriber();

  Console.WriteLine("请输入任意字符，输入exit退出");

  string input;

  do
  {
    input = Console.ReadLine();
    sub.Publish("messages", input);
  } while (input != "exit");
}

출판 클라이언트 1개와 구독 클라이언트 2개가 아래에서 실행됩니다.

위 내용은 Core가 .NET에서 Redis 게시 및 구독을 사용하는 방법에 대한 분석 예의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!