C\#RabbitMQ 를 조작 하 는 전체 인 스 턴 스

1.RabbitMQ 다운로드
http://www.rabbitmq.com/install-windows.html

2.OTP 다운로드
http://www.erlang.org/downloads

3.OTP,RabbitMQ 설치


4.RabbitMQ 설정
bat 디 렉 터 리 찾기

관련 명령 실행

1.사용자 비밀번호 추가 rabbitmqctl adduser wenli wenli
2.wenli 를 관리자 rabbitmqctl set 로 설정user_tags wenli administrator
3.RabbitMQ 를 시작 하 는 웹 관리 rabbitmq-plugins enable rabbitmqmanagement
4.가상 호스트 만 들 기

5.사용자 권한 설정
사용자 이름 을 클릭 하여 설정

가상 hosts 권한 을 사용자 wenli 에 부여 합 니 다.

6.Exchange 만 들 기

5.C\#console 만 들 기
1.RabbitMQ 드라이버 다운로드https://github.com/yswenli/Wenli.Data.RabbitMQ/releases/tag/Release1.0.0
2.인용 추가
3.설정 추가

4.테스트 코드:

using System;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace Wenli.Data.RabbitMQ.Console
{
  using Console = System.Console;

  class Program
  {
    static void Main(string[] args)
    {
      Console.Title = "Wenli.Data.RabbitMQ.Console";
      Console.WriteLine("    mq");

      try
      {
        Test();
      }
      catch (Exception ex)
      {
        Console.WriteLine("err:" + ex.Message + ex.Source + ex.StackTrace);
      }

      Console.Read();
    }


    static void Test()
    {

      var topic = "testtopic";

      var cnn = RabbitMQBuilder.Get(MQConfig.Default).GetConnection();

      var operation = cnn.GetOperation(topic);

      Console.WriteLine("      【" + topic + "】");

      operation.Subscribe();

      Console.WriteLine("    ");

      Task.Factory.StartNew(() =>
      {
        while (true)
        {
          operation.Enqueue(Encoding.UTF8.GetBytes(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "   hello!"));
          Thread.Sleep(1);
        }
      });




      Console.WriteLine("    ");



      Task.Factory.StartNew(() =>
      {
        while (true)
        {
          var result = operation.Dnqueue();

          if (result == null)
          {
            Thread.Sleep(1);
          }
          else
          {
            Console.WriteLine(Encoding.UTF8.GetString(result));
          }
        }
      });

      Console.ReadLine();

      Console.WriteLine("      ");

      operation.UnSubscribe();

      Console.WriteLine("    ");
    }
  }
}

5.실행 결과:



이로써 C\#Rabbitmq 를 성공 적 으로 조작 하 였 습 니 다.
이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.