没有合适的资源？快使用搜索试试~ 我知道了~

文库首页后端C#C# .NET

C# .NET

C#通讯代码

需积分: 0 43 下载量 37 浏览量 2008-07-03 16:10:48 上传评论收藏 164KB DOC 举报

温馨提示

试读

38页

C#的各种通讯代码,有Socket，TCP等

资源详情

资源评论

资源推荐

Socket 通讯:

public class XmlSocket

{

//异步 socket 诊听

// Incoming data from client.从客户端传来的数据

public static string data = null;

// Thread signal.线程用一个指示是否将初始状态设置为终止的布尔值初始化

ManualResetEvent 类的新实例。

public static ManualResetEvent allDone = new

ManualResetEvent(false);

//static void Main(string[] args)

//{

// StartListening();

//}

public static void StartListening()

{

// Data bu*er for incoming data. 传入数据缓冲

byte[] bytes = new Byte[1024];

// Establish the local endpoint for the socket. 建立本地端口

// The DNS name of the computer

// running the listener is "host.contoso.com".

IPAddress ipAddress;

String ipString = Con6gurationManager.AppSettings.Get("SocketIP");

if (ipString==null || ipString ==String.Empty)

{

IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());

ipAddress = ipHostInfo.AddressList[0];

}

else

{

ipAddress = IPAddress.Parse(ipString);

}

int port;

String portString =

Con6gurationManager.AppSettings.Get("SocketPort");

if (portString==null || portString==String.Empty)

{

port = 11001;

}

else

{

port = int.Parse(portString);

}

IPEndPoint localEndPoint = new IPEndPoint(ipAddress, port);

// Create a TCP/IP socket.

Socket listener = new Socket(AddressFamily.InterNetwork,

SocketType.Stream, ProtocolType.Tcp);

// Bind the socket to the local endpoint and listen for incoming

connections.绑定端口和数据

try

{

listener.Bind(localEndPoint);

listener.Listen(100);

while (true)

{

// Set the event to nonsignaled state.设置无信号状态的事件

allDone.Reset();

// Start an asynchronous socket to listen for connections.重新启

动异步连接

listener.BeginAccept(new AsyncCallback(AcceptCallback),

listener);

// Wait until a connection is made before continuing.等待连接创建

后继续

allDone.WaitOne();

}

catch (Exception e)

{

}

public static void AcceptCallback(IAsyncResult ar)

{

try

{

// Signal the main thread to continue.接受回调方法该方法的此节向主

应用程序线程发出信号，

//让它继续处理并建立与客户端的连接

allDone.Set();

// Get the socket that handles the client request.获取客户端请求句柄

Socket listener = (Socket)ar.AsyncState;

Socket handler = listener.EndAccept(ar);

// Create the state object.

StateObject state = new StateObject();

state.workSocket = handler;

handler.BeginReceive(state.bu*er, 0, StateObject.Bu*erSize, 0,

new AsyncCallback(ReadCallback), state);

}

catch (Exception e)

{

}

/// <summary>

/// 与接受回调方法一样，读取回调方法也是一个 AsyncCallback 委托。

/// 该方法将来自客户端套接字的一个或多个字节读入数据缓冲区，然后再次调用

BeginReceive 方法，直到客户端发送的数据完成为止。

/// 从客户端读取整个消息后，在控制台上显示字符串，并关闭处理与客户端的连接

的服务器套接字。

/// </summary>

/// <param name="ar">IAsyncResult 委托</param>

public static void ReadCallback(IAsyncResult ar)

{

try

{

String content = String.Empty;

// Retrieve the state object and the handler socket 创建自定义的状态

对象 from the asynchronous state object.

StateObject state = (StateObject)ar.AsyncState;

Socket handler = state.workSocket;//处理的句柄

// Read data from the client socket. 读出

int bytesRead = handler.EndReceive(ar);

if (bytesRead > 0)

{

//业务代码

string result = DoSomeThing(...);

String len =

Encoding.UTF8.GetBytes(result).Length.ToString().PadLeft(8, '0');

log.writeLine(len);

Send(len + result, handler);

}

catch (Exception e)

{

}

private static void Send(String data, Socket handler)

{

try

{

// Convert the string data to byte data using UTF8 encoding.

byte[] byteData = Encoding.UTF8.GetBytes(data);

// Begin sending the data to the remote device.

handler.BeginSend(byteData, 0, byteData.Length, 0,

new AsyncCallback(SendCallback), handler);

}

catch (Exception e)

{

}

/// <summary>

/// 发送

/// </summary>

/// <param name="ar"></param>

private static void SendCallback(IAsyncResult ar)

{

try

{

// Retrieve the socket from the state object.

Socket handler = (Socket)ar.AsyncState;

// Complete sending the data to the remote device.向远端发送数据

int bytesSent = handler.EndSend(ar);

StateObject state = new StateObject();

state.workSocket = handler;

handler.BeginReceive(state.bu*er, 0, StateObject.Bu*erSize,

0,new AsyncCallback(ReadCallback), state);

handler.Shutdown(SocketShutdown.Both);

handler.Close();

}

catch (Exception e)

{

}

剩余37页未读，继续阅读

内容反馈

kieth1985

粉丝: 0
资源: 13

上传资源快速赚钱

我的内容管理展开

我的资源快来上传第一个资源

我的收益

登录查看自己的收益

我的积分登录查看自己的积分

我的C币登录后查看C币余额

我的收藏

我的下载

下载帮助

前往需求广场，查看用户热搜

C# .NET

评论0

最新资源

C# .NET

评论0

C#.NET课程设计指导 C#.NET课程设计指导

c#.net论文c#.net论文c#.net论文c#.net论文c#.net论文

C#.net屏保设计

Visual C# .NET程序设计经典

Visual C#.NET项目实战开发从入门到精通 Part 2

Visual C# .NET程序设计经典 配套资源

Visual C#.NET数据库开发经典案例解析

Visual C#.NET技术内幕(修订版)源码

C# .NET工控上位机开发

应用程序设计编制（Visual C#平台）Visual C# .NET试题汇编（程序员级）

ArcObjects+GIS应用开发——基于C#.NET.pdf

Visual C#.NET数据库开发经典案例解析之生产管理系统

Visual C＃.NET开发实践：Visual C＃.NET开发实践.rar

C#.NET 画图(走势图,柱形图)

Visual C#.NET 从入门到精通1-4

C#.NET教程（基础）

c#.net做的学生信息管理系统

C# .net读取ini配置文件

C# .NET中Socket简单实用框架的使用教程

Visual C#.NET 程序设计教程课后答案（罗福强、白忠建）习题答案1-14

ILSpy 安装包和压缩包

DevExpress22.X完美Patch资源

基于C#与Sql Server的智慧星学生选课管理系统.rar

CefFlashBrowser - Flash浏览器

Prolific USB-to-Serial Comm Port

HslCommunication.dll 7.0.1 免费版本 全部源代码和测试工程

C#使用 MQTTnet 快速实现 MQTT 通信 Demo

vscode 1.77 安装包

StockMonitorInstaller-1.0.13

关于西门子PLC与上位机通讯的damo程序，以及更改后的S7.net+

最新资源

Visual C# .NET程序设计经典配套资源

HslCommunication.dll 7.0.1 免费版本全部源代码和测试工程