4장. 예
이 장에서는 예제 프로그램을 통해 AMQ .NET을 사용하는 방법을 보여줍니다.
자세한 내용은 AMQ .NET 예제 제품군 및 AMQP.Net Lite 예제 를 참조하십시오.
4.1. 메시지 전송
이 클라이언트 프로그램은 < connection-url >을 사용하여 서버에 연결하고, 대상 < address >에 대한 보낸 사람을 생성하고, < message-body >를 포함하는 메시지를 전송하고, 연결을 종료하고 종료합니다.
예: 메시지 전송
namespace SimpleSend
{
using System;
using Amqp; 1
class SimpleSend
{
static void Main(string[] args)
{
string url = (args.Length > 0) ? args[0] : 2
"amqp://guest:guest@127.0.0.1:5672";
string target = (args.Length > 1) ? args[1] : "examples"; 3
int count = (args.Length > 2) ? Convert.ToInt32(args[2]) : 10; 4
Address peerAddr = new Address(url); 5
Connection connection = new Connection(peerAddr); 6
Session session = new Session(connection);
SenderLink sender = new SenderLink(session, "send-1", target); 7
for (int i = 0; i < count; i++)
{
Message msg = new Message("simple " + i); 8
sender.Send(msg); 9
Console.WriteLine("Sent: " + msg.Body.ToString());
}
sender.Close(); 10
session.Close();
connection.Close();
}
}
}
- 1
Amqp; Amqp 네임스페이스에 정의된 가져오기 유형 사용. AMQP는 라이브러리 파일 Amqp.Net.chunk에 대한 프로젝트 참조에 의해 정의되며 AMQ . NET과 관련된 모든 클래스, 인터페이스 및 값 유형을 제공합니다.- 2
- 명령 줄 arg[0]
url은 AMQP 연결에 대한 호스트 또는 가상 호스트의 네트워크 주소입니다. 이 문자열은 연결 전송, 사용자 및 암호 자격 증명, 원격 호스트의 연결에 대한 포트 번호를 설명합니다. URL 은 브로커, 독립 실행형 피어 또는 라우터 네트워크의 인그레스 지점을 처리할 수 있습니다. - 3
- arg[1]
대상은 원격 호스트의 메시지 대상 끝점 또는 리소스의 이름입니다. - 4
- arg[2
]는 전송할 메시지 수입니다. - 5
peerAddr는 AMQP 연결을 생성하는 데 필요한 구조입니다.- 6
- AMQP 연결을 생성합니다.
- 7
sender는 메시지를 전송할 수 있는 클라이언트 SenderLink 입니다. 링크는 임의로 이름이 send-1 로 지정됩니다. 사용 환경에 적합한 링크 이름을 사용하고 사용 중인 시스템에서 트래픽을 식별하는 데 도움이 됩니다. 링크 이름은 제한되지 않지만 동일한 세션 내에서 고유해야 합니다.- 8
- 메시지 send loop에서 새 메시지가 생성됩니다.
- 9
- 메시지가 AMQP 피어로 전송됩니다.
- 10
- 모든 메시지가 전송되면 프로토콜 오브젝트가 순서대로 종료됩니다.
예제 실행
예제 프로그램을 실행하려면 명령줄에서 컴파일하고 실행합니다. 자세한 내용은 3장. 시작하기의 내용을 참조하십시오.
<install-dir>\bin\Debug>simple_send "amqp://guest:guest@localhost" service_queue