Sorry for the radio silence, I was on holiday in Alaska. Now I’m back with extra vigor to continue our evolving tutorial. \ud83d\ude42<\/p>\n
NOTE: Source code for all of the files and functionality referenced in the next few posts is available here.<\/a><\/em><\/p>\n At the root of a custom transport implementation is the creation of your channels. The channel layer uses a factory pattern for constructing channels. We are implementing the Datagram message exchange pattern<\/a>. So our Only the factory classes need to be public, not the IChannel<\/a> and IListener<\/a> implementations that they generate. Indigo provides some base class helpers for this process.<\/p>\n <\/p>\n <\/p>\n <\/p>\n In our sample code<\/a>, the Factory implementations are contained in UdpChannelFactory.cs<\/em> and UdpListenerFactory.cs<\/em>. The IChannel implementations are in UdpOutputChannel.cs<\/em> and UdpInputChannel.cs<\/em>. The IListener implementation is in UdpInputListener.cs<\/em>. There are some implementation details of the factories (such as UdpChannelFactory derives from ChannelFactoryBase. It overrides the following properties and methods to accomplish the bulk of its work:<\/p>\n <\/p>\n <\/p>\n <\/p>\n We also override OnOpen() and OnClosed() so that we can setup and tear-down our IBufferManager at the appropriate points in the state machine<\/a>.<\/p>\n UdpOutputChannel is our internal implementation of IOutputChannel<\/a>. In the constructor we validate our arguments and, based on the EndpointAddress passed in, construct a System.Net.EndPoint<\/a> for our destination . We have 2 places where we need to clean up the socket, as the Channel can close gracefully using Close(), or ungracefully using Abort(). In the Abort() case we want to ensure that our base method gets called, which is why it’s in a finally block:<\/p>\n } }<\/p><\/div>\n<\/div>\n For Close(), we simply cleanup the socket and call our base class (if this throws, the infrastructure will call Abort() to ensure our channel is cleaned up):<\/p>\n We then implement Send() and BeginSend()\/EndSend(). This breaks down into two main sections. First we serialize the message into a byte array:<\/p>\n Then we send the resulting data on the wire:<\/p>\n At this point our Send() call has finished its transmission task and we have sent a UDP datagram containing a text encoding serialization of a SOAP message. Next I will cover the IListenerFactory implementation to receive this message.<\/p>\n","protected":false},"excerpt":{"rendered":" Sorry for the radio silence, I was on holiday in Alaska. Now I’m back with extra vigor to continue our evolving tutorial. \ud83d\ude42 NOTE: Source code for all of the files and functionality referenced in the next few posts is available here. At the root of a custom transport implementation is the creation of your […]<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[11],"tags":[],"class_list":["post-29","post","type-post","status-publish","format-standard","hentry","category-indigo"],"_links":{"self":[{"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/posts\/29","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/kennyw.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=29"}],"version-history":[{"count":0,"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/posts\/29\/revisions"}],"wp:attachment":[{"href":"https:\/\/kennyw.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=29"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/kennyw.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=29"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/kennyw.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=29"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}IChannelFactory<\/a><\/code> (client\/proxy) will support creating IOutputChannel<\/a>s and our IListenerFactory<\/a><\/code> (service) will support listening for IInputChannel<\/a>s.<\/p>\n\n
CommunicationObject<\/code> is a base class that implements ICommunicationObject<\/a> and enforces the common state machine<\/a>. <\/li>\nChannelManagerBase(:CommunicationObject)<\/code> is a base class that implements IChannelManager and takes care of managing a collection of channels that are created (IChannelFactory) or accepted (IListenerFactory). ChannelManagerBase works in conjunction with ChannelBase, which is a base class that implements IChannel<\/a>.<\/li>\nChannelFactoryBase(:ChannelManagerBase)<\/code> is a base class that implements IChannelFactory<\/a> and consolidates the myriad CreateChannel() overloads into a single OnCreateChannel() abstract method. It also handles the concept of an InnerChannelFactory.<\/li>\nListenerFactoryBase(:ChannelManagerBase)<\/code> is a base class that implements IListenerFactory<\/a>. It takes care of managing a collection of listeners that are created, and works in conjunction with ListenerBase<\/code>, which is a base class that implements IListener<\/a>. It also handles the concept of an InnerListenerFactory.<\/li>\n<\/ul>\nIBufferManager<\/code> and MessageEncoderFactory<\/code>) deserving of their own future topics. For the moment I will simply note that these utilities are very helpful in managing serialized message buffers and performing conversions between Message and serialized byte arrays.<\/p>\nUdpChannelFactory <\/a><\/h4>\n
public override<\/code> MessageVersion MessageVersion { get<\/code>; } <\/div>\npublic override string<\/code> Scheme { get<\/code>; }<\/div>\n\"soap.udp\"<\/code> as our addressing scheme. <\/div>\npublic override bool<\/code> CanCreateChannel<TChannel>()<\/div>\nprotected override<\/code> TChannel OnCreateChannel<TChannel>(EndpointAddress remoteAddress)<\/div>\nUdpOutputChannel <\/a><\/h4>\n
\nIn our OnOpen() override we create the Socket that we will use for sending data to this EndPoint:<\/p>\ntry<\/code>
\n {<\/p>\nthis<\/code>.socket.Close(0);<\/div>\n
\n finally<\/code>
\n {<\/p>\nbase<\/code>.OnAbort();<\/div>\nthis<\/code>.socket.Close();
\n base<\/code>.OnClose();<\/div>\n<\/div>\nbyte<\/code>> messageBuffer = EncodeMessage(message);<\/div>\n<\/div>\nthis<\/code>.socket.SendTo(messageBuffer.Array, messageBuffer.Offset, messageBuffer.Count, SocketFlags.None, this<\/code>.remoteEndPoint);<\/div>\n<\/div>\n