Socket Programming in C# (二)(转载)
2008-02-22 10:28
411 查看
Using the Sample Program
In order to use the source code and application here you would need to run the Server first:Here is the way Server looks like:
When you launch the Server, click Start to start listening. The Server listens at port 8221. So make sure you specify the port number 8221 in the port field of our client application. And in the IPAddress field of Client App enter the IP Address of the machine on which the Server is running. If you send some data to server from the client by pressing Tx button, you will see that data in the grayed out edit box.
That's it for now! The next part in this article will cover the Server program.
Getting Started
You can argue that one can overcome these shortcomings by multithreading meaning that one can spawn a new thread and let that thread do the polling which then notifies the main thread of the data. This concept could work well, but even if you create a new thread it would require your main thread to share the CPU time with this new thread. Windows operating system (Windows NT /2000 /XP) provide what is called Completion Port IO model for doing overlapped ( asynchronous) IO.The details of IO Completion port are beyond the scope of the current discussion, but to make it simple you can think of IO Completion Ports as the most efficient mechanism for doing asynchronous IO in Windows that is provided by the Operating system. Completion Port model can be applied to any kind of IO including the file read /write and serial communication.
The .NET asynchronous socket programming helper class's Socket provides the similar model.
BeginReceive
.NET framework's Socket class provides BeginReceive method to receive data asynchronously i.e., in an non-blocking manner The BeginReceive method has following signature:
public IAsyncResult BeginReceive( byte[] buffer, int offset, int size, SocketFlags socketFlags, AsyncCallback callback, object state );
The way
BeginReceivefunction works is that you pass the function a buffer , a callback function (delegate) which will be called whenever data arrives.
The last parameter, object, to the
BeginReceivecan be any class derived from object ( even null ) . When the callback function is called it means that the
BeginReceivefunction completed which means that the data has arrived. The callback function needs to have the following signature:
void AsyncCallback( IAsyncResult ar);
As you can see the callback returns void and is passed in one parameter ,
IAsyncResultinterface , which contains the status of the asynchronous receive operation.
The
IAsyncResultinterface has several properties. The first parameter -
AsyncState- is an object which is same as the last parameter that you passed to
BeginReceive(). The second property is
AsyncWaitHandlewhich we will discuss in a moment. The third property indicates whether the receive was really asynchronous or it finished synchronously. The important thing to follow here is that it not necessary for an asynchronous function to always finish asynchronously - it can complete immediately if the data is already present. Next parameter is
IsCompletewhich indicates whether the operation has completed or not.
If you look at the signature of the
BeginReceiveagain you will note that the function also returns
IAsyncResult. This is interesting. Just now I said that I will talk about the second peoperty of the
IAsyncResultin a moment. Now is that moment. The second parameter is called
AsyncWaitHandle.
The
AsyncWaitHandleis of type
WaitHandle, a class defined in the
System.Threadingnamespace.
WaitHandleclass encapsulates a
Handle(which is a pointer to int or handle ) and provides a way to wait for that handle to become signaled. The class has several static methods like
WaitOne( which is similar to
WaitForSingleObject)
WaitAll( similar to
WaitForMultipleObjectswith waitAll true ) ,
WaitAnyetc. Also there are overloads of these functions available with timeouts.
Coming back to our discussion of
IAsyncResultinterface, the handle in
AsyncWaitHandle(
WaitHandle) is signalled when the receive operation completes. So if we wait on that handle infinitely we will be able to know when the receive completed. This means if we pass that WaitHandle to a different thread, the different thread can wait on that handle and can notify us of the fact that the data has arrived and so that we can read the data. So you must be wondering if we use this mechanism why would we use callback function. We won't. Thats right. If we choose to use this mechanism of the WaitHandle then the callback function parameter to the BeginReceive can be null as shown here:
//m_asynResult is declared of type IAsyncResult and assumming that m_socClient has made a connection. m_asynResult = m_socClient.BeginReceive(m_DataBuffer,0,m_DataBuffer.Length,SocketFlags.None,null,null); if ( m_asynResult.AsyncWaitHandle.WaitOne () ) { int iRx = 0 ; iRx = m_socClient.EndReceive (m_asynResult); char[] chars = new char[iRx + 1]; System.Text.Decoder d = System.Text.Encoding.UTF8.GetDecoder(); int charLen = d.GetChars(m_DataBuffer, 0, iRx, chars, 0); System.String szData = new System.String(chars); txtDataRx.Text = txtDataRx.Text + szData; }
Even though this mechanism will work fine using multiple threads, we will for now stick to our callback mechanism where the system notifies us of the completion of asynchronous operation which is Receive in this case .
Lets say we made the call to
BeginReceiveand after some time the data arrived and our callback function got called.Now question is where's the data? The data is now available in the buffer that you passed as the first parameter while making call to
BeginReceive()method . In the following example the data will be available in m_DataBuffer :
BeginReceive(m_DataBuffer,0,m_DataBuffer.Length,SocketFlags.None,pfnCallBack,null);
But before you access the buffer you need to call EndReceive() function on the socket. The EndReceive will return the number of bytes received . Its not legal to access the buffer before calling EndReceive. To put it all together look at the following simple code:
byte[] m_DataBuffer = new byte [10]; IAsyncResult m_asynResult; public AsyncCallback pfnCallBack ; public Socket m_socClient; // create the socket... public void OnConnect() { m_socClient = new Socket (AddressFamily.InterNetwork,SocketType.Stream ,ProtocolType.Tcp ); // get the remote IP address... IPAddress ip = IPAddress.Parse ("10.10.120.122"); int iPortNo = 8221; //create the end point IPEndPoint ipEnd = new IPEndPoint (ip.Address,iPortNo); //connect to the remote host... m_socClient.Connect ( ipEnd ); //watch for data ( asynchronously )... WaitForData(); } public void WaitForData() { if ( pfnCallBack == null ) pfnCallBack = new AsyncCallback (OnDataReceived); // now start to listen for any data... m_asynResult = m_socClient.BeginReceive (m_DataBuffer,0,m_DataBuffer.Length,SocketFlags.None,pfnCallBack,null); } public void OnDataReceived(IAsyncResult asyn) { //end receive... int iRx = 0 ; iRx = m_socClient.EndReceive (asyn); char[] chars = new char[iRx + 1]; System.Text.Decoder d = System.Text.Encoding.UTF8.GetDecoder(); int charLen = d.GetChars(m_DataBuffer, 0, iRx, chars, 0); System.String szData = new System.String(chars); WaitForData(); }
The
OnConnectfunction makes a connection to the server and then makes a call to
WaitForData.
WaitForDatacreates the callback function and makes a call to
BeginReceivepassing a global buffer and the callback function. When data arrives the
OnDataReceiveis called and the m_socClient's
EndReceiveis called which returns the number of bytes received and then the data is copied over to a string and a new call is made to
WaitForDatawhich will call
BeginReceiveagain and so on. This works fine if you have one socket in you application.
Multiple Sockets
Now lets say you have two sockets connecting to either two different servers or same server (which is perfectly valid) . One way is to create two different delegates and attach a different delegate to differentBeginReceivefunction. What if you have 3 sockets or for that matter n sockets , this approach of creating multiple delegates does not fit well in such cases. So the solution should be to use only one delegate callback. But then the problem is how do we know what socket completed the operation.
Fortunately there is a better solution. If you look at the
BeginReceivefunction again, the last parameter is a state is an object. You can pass anything here . And whatever you pass here will be passed back to you later as the part of parameter to the callback function. Actually this object will be passed to you later as a IAsyncResult.AsyncState. So when your callback gets called, you can use this information to identify the socket that completed the operation. Since you can pass any thing to this last parameter, we can pass a class object that contains as much information as we want. For example we can declare a class as follows:
public class CSocketPacket { public System.Net.Sockets.Socket thisSocket; public byte[] dataBuffer = new byte[1024]; }
and call
BeginReceiveas follows:
CSocketPacket theSocPkt = new CSocketPacket (); theSocPkt.thisSocket = m_socClient; // now start to listen for any data... m_asynResult = m_socClient.BeginReceive (theSocPkt.dataBuffer ,0,theSocPkt.dataBuffer.Length ,SocketFlags.None,pfnCallBack,theSocPkt);
and in the callback function we can get the data like this:
public void OnDataReceived(IAsyncResult asyn) { try { CSocketPacket theSockId = (CSocketPacket)asyn.AsyncState ; //end receive... int iRx = 0 ; iRx = theSockId.thisSocket.EndReceive (asyn); char[] chars = new char[iRx + 1]; System.Text.Decoder d = System.Text.Encoding.UTF8.GetDecoder(); int charLen = d.GetChars(theSockId.dataBuffer, 0, iRx, chars, 0); System.String szData = new System.String(chars); txtDataRx.Text = txtDataRx.Text + szData; WaitForData(); } catch (ObjectDisposedException ) { System.Diagnostics.Debugger.Log(0,"1","/nOnDataReceived: Socket has been closed/n"); } catch(SocketException se) { MessageBox.Show (se.Message ); } }
To see the whole application download the code and you can see the code.
There is one thing which you may be wondering about. When you call
BeginReceive, you have to pass a buffer and the number of bytes to receive. The question here is how big should the buffer be. Well, the answer is it depends. You can have a very small buffer size say, 10 bytes long and if there are 20 bytes ready to be read, then you would require 2 calls to receive the data. On the other hand if you specify the length as 1024 and you know you are always going to receive data in 10-byte chunks you are unnecessarily wasting memory. So the length depends upon your application.
Server Side
If you have understood whatever I have described so far, you will easily understand the Server part of the socket application. So far we have been talking about a client making connection to a server and sending and receiving data.On the Server end, the application has to send and receive data. But in addition to adding and receiving data, server has to allow the clients to make connections by listening at some port. Server does not need to know client I.P. addresses. It really does not care where the client is because its not the server but client who is responsible for making connection. Server's responsibility is to manage client connections.
On the server side there has to be one socket called the Listener socket that listens at a specific port number for client connections. When the client makes a connection, the server needs to accept the connection and then in order for the server to send and receive data from that connected client it needs to talk to that client through the socket that it got when it accepted the connection. The following code illustrates how server listens to the connections and accepts the connection:
public Socket m_socListener; public void StartListening() { try { //create the listening socket... m_socListener = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp); IPEndPoint ipLocal = new IPEndPoint ( IPAddress.Any ,8221); //bind to local IP Address... m_socListener.Bind( ipLocal ); //start listening... m_socListener.Listen (4); // create the call back for any client connections... m_socListener.BeginAccept(new AsyncCallback ( OnClientConnect ),null); cmdListen.Enabled = false; } catch(SocketException se) { MessageBox.Show ( se.Message ); } }
If you look at the above code carefully you will see that its similar to we did in the asynchronous client. First of all the we need to create a listening socket and bind it to a local IP address. Note that we have given Any as the IPAddress (I will explain what it means later), and we have passed the port number as 8221. Next we made a call to
Listenfunction. The 4 is a parameter indicating backlog indicating the maximum length of the queue of pending connections.
Next we made a call to
BeginAcceptpassing it a delegate callback.
BeginAcceptis a non-blocking method that returns immediately and when a client has made requested a connection, the callback routine is called and you can accept the connection by calling
EndAccept. The
EndAcceptreturns a socket object which represents the incoming connection. Here is the code for the callback delegate:
public void OnClientConnect(IAsyncResult asyn) { try { m_socWorker = m_socListener.EndAccept (asyn); WaitForData(m_socWorker); } catch(ObjectDisposedException) { System.Diagnostics.Debugger.Log(0,"1","/n OnClientConnection: Socket has been closed/n"); } catch(SocketException se) { MessageBox.Show ( se.Message ); } }
Here we accept the connection and call
WaitForDatawhich in turn calls
BeginReceivefor the m_socWorker.
If we want to send data some data to client we use m_socWorker socket for that purpose like this:
Object objData = txtDataTx.Text; byte[] byData = System.Text.Encoding.ASCII.GetBytes(objData.ToString ()); m_socWorker.Send (byData);
Conclusion
And that's all there is to it! Here is how our client looks likeHere is how our server looks like
That is all there is to the socket programming.
相关文章推荐
- Socket Programming in C# (一)(转载)
- Socket Programming in C# - Part 2
- Interception and Interceptors in C# (Aspect oriented programming) 转载
- An Introduction to Socket Programming in .NET(转载)
- Asynchronous Socket Programming in C#: Part I
- Asynchronous Socket Programming in C#: Part II
- Asynchronous Socket Programming in C#: Part II
- Asynchronous Programming in C# 5.0 using async and await
- C++ socket programming in Linux
- 基于C#的Socket开发快速入门(转载)
- Chat Application using Web services in C#(转载)
- [转载]Hello Word Outlook Add-In using C#
- SOCKET Communication writen in C# (4) Socket 同步模式,异步模式操作
- [转载]C#实现的可复用Socket接收/发送共享缓冲区类
- <转载>在C#中利用Keep-Alive处理Socket网络异常断开的方法
- c# WINFORM SOCKET编程-简单聊天程序(服务端)(转载)
- [转载]在C#中使用异步Socket编程实现TCP网络服务的C/S的通讯构架(一)----基础类库部分 .
- Socket programming in C on Linux | tutorial
- 转载一个很经典的--C# Socket TCP和UDP报文及端口测试工具的开发(提供源码)
- Socket Programming in C#--Server Side