Transport: WSE 3.0 TCP Interoperability

아티클
09/05/2008

WSE 3.0 TCP Interoperability Transport 샘플에서는 TCP 이중 세션을 사용자 지정 WCF(Windows Communication Foundation) 전송으로 구현하는 방법을 보여 줍니다. 또한 채널 계층의 확장성을 사용하여 연결을 통해 기존에 배포된 시스템과 상호 작용할 수 있는 방법도 보여 줍니다. 다음 단계에서는 이 사용자 지정 WCF 전송을 빌드하는 방법을 설명합니다.

TCP 소켓에서 시작하여 DIME 프레이밍을 사용하여 메시지 경계를 나타내는 IDuplexSessionChannel의 클라이언트 및 서버 구현을 만듭니다.
WSE TCP 서비스에 연결되고 클라이언트 IDuplexSessionChannel을 통해 프레임 메시지를 보내는 채널 팩터리를 만듭니다.
들어오는 TCP 연결을 수락하고 해당하는 채널을 생성하도록 채널 수신기를 만듭니다.
네트워크 관련 예외가 CommunicationException의 적절한 파생 클래스로 정규화되는지 확인합니다.
사용자 지정 전송을 채널 스택에 추가하는 바인딩 요소를 추가합니다. 자세한 내용은 Adding a Binding Element를 참조하십시오.

IDuplexSessionChannel 만들기

WSE 3.0 TCP 상호 운용성 전송을 작성하는 첫 번째 단계는 Socket 위에 IDuplexSessionChannel의 구현을 만드는 것입니다. WseTcpDuplexSessionChannel은 ChannelBase에서 파생됩니다. 메시지를 보내는 논리는 (1) 메시지를 바이트로 인코딩한 다음 (2) 이러한 바이트를 프레이밍하여 연결을 통해 보내는 두 가지 주요 작업으로 구성됩니다.

ArraySegment<byte> encodedBytes = EncodeMessage(message);

WriteData(encodedBytes);

또한 Send() 호출이 IDuplexSessionChannel을 순서대로 유지하고 기본 소켓에 대한 호출이 올바르게 동기화되도록 잠금을 설정합니다.

WseTcpDuplexSessionChannel은 Message와 byte[] 간의 변환에 MessageEncoder를 사용합니다. WseTcpDuplexSessionChannel은 전송이기 때문에 채널이 구성된 원격 주소를 적용하는 작업도 담당합니다. EncodeMessage는 이 변환을 위한 논리를 캡슐화합니다.

this.RemoteAddress.ApplyTo(message);

return encoder.WriteMessage(message, maxBufferSize, bufferManager);

Message를 바이트로 인코딩한 다음에는 연결을 통해 전송해야 합니다. 이렇게 하려면 메시지 경계를 정의하기 위한 시스템이 필요합니다. WSE 3.0에서는 프레이밍 프로토콜로 DIME 버전을 사용합니다. WriteData는 프레이밍 논리를 캡슐화하여 byte[]를 일련의 DIME 레코드로 래핑합니다.

메시지를 수신하는 논리도 매우 유사합니다. 한 가지 복잡한 문제는 소켓 읽기가 요청된 것보다 적은 수의 바이트를 반환할 수 있다는 사실을 다루는 것입니다. 메시지를 수신하기 위해 WseTcpDuplexSessionChannel은 연결이 끊긴 상태에서 바이트를 읽고 DIME 프레이밍을 디코딩한 다음 byte[]를 Message로 변환하는 데 MessageEncoder를 사용합니다.

기본 WseTcpDuplexSessionChannel은 연결된 소켓을 수신하는 것으로 가정합니다. 기본 클래스는 소켓 종료를 처리합니다. 소켓 닫기를 처리하는 세 위치는 다음과 같습니다.

OnAbort -- 소켓을 강제로 닫습니다(강제 닫기).
On[Begin]Close -- 소켓을 정상적으로 닫습니다(정상 닫기).
session.CloseOutputSession -- 아웃바운드 데이터 스트림을 종료합니다(절반 닫기).

채널 팩터리

TCP 전송을 작성하는 다음 단계는 클라이언트 채널을 위한 IChannelFactory의 구현을 만드는 것입니다.

WseTcpChannelFactory는 ChannelFactoryBase<IDuplexSessionChannel>에서 파생됩니다. 이는 OnCreateChannel을 재정의하여 클라이언트 채널을 생성하는 팩터리입니다.

protected override IDuplexSessionChannel OnCreateChannel(EndpointAddress remoteAddress, Uri via)

{

return new ClientWseTcpDuplexSessionChannel(encoderFactory, bufferManager, remoteAddress, via, this);

}

ClientWseTcpDuplexSessionChannel은 기본 WseTcpDuplexSessionChannel 에 논리를 추가하여 channel.Open 시에 TCP 서버에 연결합니다. 다음 코드에 나온 것처럼 먼저 호스트 이름이 IP 주소로 확인됩니다.

hostEntry = Dns.GetHostEntry(Via.Host);

그런 다음에는 다음 코드에 나온 것처럼 호스트 이름이 루프의 사용 가능한 첫 번째 IP 주소에 연결됩니다.

IPAddress address = hostEntry.AddressList[i];

socket = new Socket(address.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

socket.Connect(new IPEndPoint(address, port));

채널 계약의 일부로 도메인 관련 예외를 래핑합니다(예: CommunicationException의 SocketException).

채널 수신기

TCP 전송을 작성하는 다음 단계는 서버 채널을 수락하기 위한 IChannelListener의 구현을 만드는 것입니다.

WseTcpChannelListener는 ChannelListenerBase<IDuplexSessionChannel>에서 파생되고 On[Begin]Open 및 On[Begin]Close를 재정의하여 수신 소켓의 수명을 제어합니다. OnOpen에서는 IP_ANY를 수신 대기하는 소켓이 만들어집니다. 더 고급 구현에서는 IPv6을 수신 대기하는 두 번째 소켓도 만들 수 있습니다. 또한 호스트 이름에 IP 주소를 지정할 수도 있습니다.

IPEndPoint localEndpoint = new IPEndPoint(IPAddress.Any, uri.Port);

this.listenSocket = new Socket(localEndpoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

this.listenSocket.Bind(localEndpoint);

this.listenSocket.Listen(10);

새 소켓을 수락하면 이 소켓으로 서버 채널이 초기화됩니다. 모든 입력 및 출력은 기본 클래스에서 이미 구현되었으므로 이 채널은 소켓의 초기화를 담당합니다.

바인딩 요소 추가

팩터리와 채널이 빌드되었으므로 이제 바인딩을 통해 ServiceModel 런타임에 노출해야 합니다. 바인딩은 서비스 주소와 연결된 통신 스택을 나타내는 바인딩 요소의 컬렉션입니다. 스택의 각 요소는 바인딩 요소로 표현됩니다.

이 샘플에서 바인딩 요소는 TransportBindingElement에서 파생된 WseTcpTransportBindingElement로, IDuplexSessionChannel을 지원하고 다음 메서드를 재정의하여 바인딩과 연결된 팩터리를 빌드합니다.

public IChannelFactory<TChannel> BuildChannelFactory<TChannel>(BindingContext context)

{

return (IChannelFactory<TChannel>)(object)new WseTcpChannelFactory(this, context);

}

public IChannelListener<TChannel> BuildChannelListener<TChannel>(BindingContext context)

{

return (IChannelListener<TChannel>)(object)new WseTcpChannelListener(this, context);

}

또한 BindingElement를 복제하고 체계(wse.tcp)를 반환하기 위한 멤버를 포함합니다.

WSE TCP 테스트 콘솔

이 샘플 전송을 사용하기 위한 테스트 코드는 TestCode.cs에서 제공합니다. 다음 지침은 WSE TcpSyncStockService 샘플을 설치하는 방법을 보여 줍니다.

이 테스트 코드는 인코딩으로 MTOM을 사용하고 전송으로 WseTcpTransport를 사용하는 사용자 지정 바인딩을 만듭니다. 또한 다음 코드에 나온 것처럼 WSE 3.0을 준수하도록 AddressingVersion을 설정합니다.

CustomBinding binding = new CustomBinding();

MtomMessageEncodingBindingElement mtomBindingElement = new MtomMessageEncodingBindingElement();

mtomBindingElement.MessageVersion = MessageVersion.Soap11WSAddressingAugust2004;

binding.Elements.Add(mtomBindingElement);

binding.Elements.Add(new WseTcpTransportBindingElement());

이 테스트 코드는 두 개의 테스트로 구성됩니다. 첫 번째 테스트에서는 WSE 3.0 WSDL에서 생성된 코드를 사용하여 형식화된 클라이언트를 설정합니다. 두 번째 테스트에서는 채널 API 위에서 바로 메시지를 보냄으로써 WCF를 클라이언트와 서버로 모두 사용합니다.

샘플을 실행하면 다음과 같은 출력이 표시됩니다.

클라이언트

Calling soap://stockservice.contoso.com/wse/samples/2003/06/TcpSyncStockService

Symbol: FABRIKAM
        Name: Fabrikam, Inc.
        Last Price: 120

Symbol: CONTOSO
        Name: Contoso Corp.
        Last Price: 50.07
Press enter.

Received Action: http://SayHello
Received Body: to you.
Hello to you.
Press enter.

Received Action: http://NotHello
Received Body: to me.
Press enter.

서버

Listening for messages at soap://stockservice.contoso.com/wse/samples/2003/06/TcpSyncStockService

Press any key to exit when done...

Request received.
Symbols:
        FABRIKAM
        CONTOSO

샘플을 설치, 빌드 및 실행하려면

이 샘플을 실행하려면 WSE 3.0과 WSE TcpSyncStockService 샘플이 설치되어 있어야 합니다. WSE 3.0은 MSDN에서 다운로드할 수 있습니다.

참고

WSE 3.0은 Windows Server 2008에서는 지원되지 않으므로 이 운영 체제에서는 TcpSyncStockService 샘플을 설치하거나 실행할 수 없습니다.

TcpSyncStockService 샘플을 설치했으면 다음 작업을 수행합니다.
1. Visual Studio에서 TcpSyncStockService를 엽니다. TcpSyncStockService 샘플은 WSE 3.0과 함께 설치되며 이 샘플 코드에 포함되어 있지 않습니다.
2. StockService 프로젝트를 시작 프로젝트로 설정합니다.
3. StockService 프로젝트에서 StockService.cs를 열고 StockService 클래스의 [Policy] 특성을 주석으로 처리합니다. 이렇게 하면 샘플에서 보안을 사용하지 않습니다. WCF는 WSE 3.0 보안 끝점과 상호 운용할 수 있지만 여기서는 이 샘플이 사용자 지정 TCP 전송 위주로 작동하도록 보안을 사용하지 않습니다.
4. F5 키를 눌러 TcpSyncStockService를 시작합니다. 새 콘솔 창에서 서비스가 시작됩니다.
5. Visual Studio에서 이 TCP 전송 샘플을 엽니다.
6. TcpSyncStockService를 실행하는 컴퓨터 이름과 일치하도록 TestCode.cs의 "hostname" 변수를 업데이트합니다.
7. F5 키를 눌러 TCP 전송 샘플을 시작합니다.
8. TCP 전송 테스트 클라이언트가 새 콘솔에서 시작됩니다. 클라이언트는 서비스에서 스톡 할당량을 요청한 다음 콘솔 창에 결과를 표시합니다.

다음을 통해 공유