C# RabbitMQ 연동 기본 소스[Produce]

1. C# 자신의 프로젝트 오른쪽 클릭

2. Nuget 패키지 관리 클릭

3. 찾아보기 탭에서 RabbitMQ 검색

4. RabbitMQ.Client 설치 후 RabbitMQ 기본 소스 적용

 

 

C# 윈폼을 사용하여 코드를 작성하였으며,

RabbitMQ 사용하여(토픽)을 사용하여 메시지 생성(Produce) 및 소비(Consumer)를 구현하도록 하겠습니다.

 

 

 

 

using RabbitMQ.Client;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace test
{
    public class MqTest
    {
        public String MqSend() {
            String message = "";
            var factory = new ConnectionFactory()
            {
                HostName = "자신의 주소(localhost) 및 서버주소",
                //자신의 주소에서 테스트 할 경우 밑에 생략(Port,Name,Pass)
                Port = 5672,
                UserName = "guest",
                Password = "guest",
                /////////////////////////////////////////
                
            };
            using (var connection = factory.CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    channel.ExchangeDeclare(type: "topic",
                                         durable: false,
                                         exchange: "test",
                                         autoDelete: false,
                                         arguments: null);
                    message = "Hellow World!";
                    var body = Encoding.UTF8.GetBytes(message);

                    channel.BasicPublish(exchange: "test",
                                         routingKey: "my.test.mq01",
                                         basicProperties: null,
                                         body: body);
                    //Console.WriteLine("[x] Send {0}", message);
                }

                return message;
            }
        }