当前位置:  编程技术>.net/c#/asp.net

C#之Socket操作类实例解析

    来源: 互联网  发布时间：2014-11-02

    本文导语:  本文展示了一个C#的Socket操作类的完整实例，并附带了用法说明，分享给大家供大家参考之用。具体方法如下： 主要功能代码如下： using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Net.Sockets; usi...

本文展示了一个C#的Socket操作类的完整实例，并附带了用法说明，分享给大家供大家参考之用。具体方法如下：

主要功能代码如下：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net.Sockets;
using System.Collections;
using System.Net;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters.Binary;
using System.IO;
using System.Collections.Specialized;
using System.Threading;
public class DuxSocketClient
{
 #region 私有字段
 /// 
 /// 设置数据缓冲区大小 默认1024
 /// 
 private static int m_maxpacket = 1024 * 4;
 public delegate void SendFileProgress(int progress);
 public delegate void ReceiveFileProgress(int progress);
 #endregion
 #region 服务器侦听
 /// 
 /// 服务器侦听方法 返回null则说明没有链接上
 /// 
 /// 返回一个套接字(Socket)
 public static Socket ListenerSocket(TcpListener listener)
 {
  try
  {
   Socket socket = listener.AcceptSocket();
   return socket;
  }
  catch
  {
   return null;
  }
 }
 /// 
 /// 服务器侦听方法 返回null则说明没有链接上
 /// 
 /// 
 /// 返回一个网络流
 public static NetworkStream ListenerStream(TcpListener listener)
 {
  try
  {
   TcpClient client = listener.AcceptTcpClient();
   return client.GetStream();
  }
  catch
  {
   return null;
  }
 }
 #endregion
 #region 客户端连接
 public static Socket ConnectSocket(TcpClient tcpclient, IPEndPoint ipendpoint)
 {
  try
  {
   tcpclient.Connect(ipendpoint);
   return tcpclient.Client;
  }
  catch
  {
   return null;
  }
 }
 public static Socket ConnectSocket(TcpClient tcpclient, IPAddress ipadd, int port)
 {
  try
  {
   tcpclient.Connect(ipadd, port);
   return tcpclient.Client;
  }
  catch
  {
   return null;
  }
 }
 public static NetworkStream ConnectStream(TcpClient tcpclient, IPEndPoint ipendpoint)
 {
  try
  {
   tcpclient.Connect(ipendpoint);
   return tcpclient.GetStream();
  }
  catch
  {
   return null;
  }
 }
 public static NetworkStream ConnectStream(TcpClient tcpclient, IPAddress ipadd, int port)
 {
  try
  {
   tcpclient.Connect(ipadd, port);
   return tcpclient.GetStream();
  }
  catch
  {
   return null;
  }
 }
 #endregion
 #region Socket接收数据
 /// 
 /// 接受固定长度字符串
 /// 
 /// 
 /// 
 /// 
 public static byte[] ReceiveFixData(Socket socket, int size)
 {
  int offset = 0;
  int recv = 0;
  int dataleft = size;
  byte[] msg = new byte[size];
  while (dataleft > 0)
  {
   recv = socket.Receive(msg, offset, dataleft, 0);
   if (recv == 0)
   {
    break;
   }
   offset += recv;
   dataleft -= recv;
  }
  return msg;
 }
 /// 
 /// 接收变长字符串
 /// 为了处理粘包问题 ,每次发送数据时 包头(数据字节长度) + 正文
 /// 这个发送小数据
 /// 设置包头的字节为8,不能超过8位数的字节数组
 /// 
 /// 
 /// byte[]数组
 public static byte[] ReceiveVarData(Socket socket)
 {
  //每次接受数据时,接收固定长度的包头,包头长度为8
  byte[] lengthbyte = ReceiveFixData(socket, 8);
  //length得到字符长度 然后加工处理得到数字
  int length = GetPacketLength(lengthbyte);
  //得到正文
  return ReceiveFixData(socket, length);  
 }
 /// 
 /// 接收T类对象,反序列化
 /// 
 /// 接收T类对象,T类必须是一个可序列化类
 /// 
 /// 
 public static T ReceiveVarData(Socket socket)
 {
  //先接收包头长度 固定8个字节
  byte[] lengthbyte = ReceiveFixData(socket, 8);
  //得到字节长度
  int length = GetPacketLength(lengthbyte);
  byte[] bytecoll = new byte[m_maxpacket];
  IFormatter format = new BinaryFormatter();
  MemoryStream stream = new MemoryStream();
  int offset = 0; //接收字节个数
  int lastdata = length; //还剩下多少没有接收,初始大小等于实际大小
  int receivedata = m_maxpacket; //每次接收大小
  //循环接收
  int mark = 0; //标记几次接收到的数据为0长度
  while (true)
  {
   //剩下的字节数是否小于缓存大小
   if (lastdata < m_maxpacket) 
   {
    receivedata = lastdata; //就只接收剩下的字节数
   }
   int count = socket.Receive(bytecoll,0,receivedata,0);
   if (count > 0)
   {
    stream.Write(bytecoll, 0, count);
    offset += count;
    lastdata -= count;
    mark = 0;
   }
   else
   {
    mark++;
    if (mark == 10)
    {
     break;
    }
   }
   if (offset == length)
   {
    break;
   }
  }
  stream.Seek(0, SeekOrigin.Begin); //必须要这个 或者stream.Position = 0;
  T t = (T)format.Deserialize(stream);
  stream.Close();
  return t;
 }
 /// 
 /// 在预先得到文件的文件名和大小
 /// 调用此方法接收文件
 /// 
 /// 
 /// 路径必须存在
 public static bool ReceiveFile(Socket socket, string path, string filename, long size,ReceiveFileProgress progress)
 {
  bool ret = false;
  if (Directory.Exists(path))
  {
   //主要是防止有重名文件
   string savepath = GetPath(path, filename); //得到文件路径
   //缓冲区
   byte[] file = new byte[m_maxpacket];
   int count = 0; //每次接收的实际长度
   int receivedata = m_maxpacket; //每次要接收的长度
   long offset = 0; //循环接收的总长度
   long lastdata = size; //剩余多少还没接收
   int mark = 0;
   using (FileStream fs = new FileStream(savepath, FileMode.OpenOrCreate, FileAccess.Write))
   {
    if (size > 0)
    {
     while (true)
     {
      if (lastdata < receivedata)
      {
       receivedata = Convert.ToInt32(lastdata);
      }
      count = socket.Receive(file, 0, receivedata, SocketFlags.None);
      if (count > 0)
      {
       fs.Write(file, 0, count);
       offset += count;
       lastdata -= count;
       mark = 0;
      }
      else
      {
       mark++; //连续5次接收为0字节 则跳出循环
       if (mark ==10)
       {
        break;
       }
      }
      //接收进度
      if (progress != null)
      {
       progress(Convert.ToInt32(((Convert.ToDouble(offset) / Convert.ToDouble(size)) * 100)));
      }
      //接收完毕
      if (offset == size)
      {
       ret = true;
       break;
      }
     }
    }
    fs.Close();
   }
  }
  return ret;
 }
 public static bool ReceiveFile(Socket socket, string path, string filename, long size)
 {
  return ReceiveFile(socket, path, filename, size,null);
 }
 /// 
 /// 预先不知道文件名和文件大小 用此方法接收
 /// 此方法对于的发送方法是SendFile()
 /// 
 /// 
 /// 要保存的目录
 public static void ReceiveFile(Socket socket, string path)
 {
  //得到包头信息字节数组 (文件名 + 文件大小 的字符串长度)
  //取前8位
  byte[] info_bt = ReceiveFixData(socket, 8);
  //得到包头信息字符长度
  int info_length = GetPacketLength(info_bt);
  //提取包头信息,(文件名 + 文件大小 的字符串长度)
  byte[] info = ReceiveFixData(socket, info_length);
  //得到文件信息字符串 (文件名 + 文件大小)
  string info_str = System.Text.Encoding.UTF8.GetString(info);
  string[] strs = info_str.Split('|');
  string filename = strs[0]; //文件名
  long length = Convert.ToInt64(strs[1]); //文件大小
  //开始接收文件
  ReceiveFile(socket, path, filename, length);
 }
 private static int GetPacketLength(byte[] length)
 {
  string str = System.Text.Encoding.UTF8.GetString(length);
  str = str.TrimEnd('*'); ;//("*", "");
  int _length = 0;
  if (int.TryParse(str, out _length))
  {
   return _length;
  }
  else
  {
   return 0;
  }
 }
 /// 
 /// 得到文件路径(防止有文件名重复)
 /// 如:aaa.txt已经在directory目录下存在,则会得到文件aaa(1).txt
 /// 
 /// 目录名
 /// 文件名
 /// 文件路径
 static int i = 0;
 static string markPath = String.Empty;
 public static string GetPath(string directory, string file)
 {
  if (markPath == String.Empty)
  {
   markPath = Path.Combine(directory, file);
  }
  string path = Path.Combine(directory, file);
  if (File.Exists(path))
  {
   i++;
   string filename = Path.GetFileNameWithoutExtension(markPath) + "(" + i.ToString() + ")";
   string extension = Path.GetExtension(markPath);
   return GetPath(directory, filename + extension);
  }
  else
  {
   i = 0;
   markPath = String.Empty;
   return path;
  }
 }
 #endregion
 #region Socket发送数据
 /// 
 /// 发送固定长度消息
 /// 发送字节数不能大于int型最大值
 /// 
 /// 
 /// 
 /// 返回发送字节个数
 public static int SendFixData(Socket socket, byte[] msg)
 {
  int size = msg.Length; //要发送字节长度
  int offset = 0;     //已经发送长度
  int dataleft = size;  //剩下字符
  int senddata = m_maxpacket; //每次发送大小
  while (true)
  {
   //如过剩下的字节数 小于 每次发送字节数
   if (dataleft < senddata)
   {
    senddata = dataleft;
   }
   int count = socket.Send(msg, offset, senddata, SocketFlags.None);
   offset += count;
   dataleft -= count;
   if (offset == size)
   {
    break;
   }
  }
  return offset;
 }
 /// 
 /// 发送变长信息 格式 包头(包头占8位) + 正文
 /// 
 /// 
 /// 发送文本
 /// 
 public static int SendVarData(Socket socket, string contact)
 {
  //得到字符长度
  int size = System.Text.Encoding.UTF8.GetBytes(contact).Length;
  //包头字符
  string length = GetSendPacketLengthStr(size);
  //包头 + 正文
  byte[] sendbyte = System.Text.Encoding.UTF8.GetBytes(length + contact);
  //发送
  return SendFixData(socket, sendbyte);
 }
 /// 
 /// 发送变成信息
 /// 
 /// 
 /// 
 /// 
 public static int SendVarData(Socket socket, byte[] bytes)
 {
  //得到包头字节
  int size = bytes.Length;
  string length = GetSendPacketLengthStr(size);
  byte[] lengthbyte = System.Text.Encoding.UTF8.GetBytes(length);
  //发送包头
  SendFixData(socket, lengthbyte);  //因为不知道正文是什么编码所以没有合并
  //发送正文
  return SendFixData(socket, bytes);
 }
 /// 
 /// 发送T类型对象,序列化
 /// 
 /// T类型
 /// 
 /// T类型对象,必须是可序列化的
 /// 
 public static int SendSerializeObject(Socket socket, T obj)
 {
  byte[] bytes = SerializeObject(obj);
  return SendVarData(socket, bytes);
 }
 /// 
 /// 发送文件
 /// 
 /// socket对象
 /// 文件路径
 /// 是否发送文件(头)信息,如果当前知道文件[大小,名称]则为false
 /// 
 /// 
 public static bool SendFile(Socket socket, string path,bool issend,SendFileProgress progress)
 {
  bool ret = false;
  if (File.Exists(path))
  {
   FileInfo fileinfo = new FileInfo(path);
   string filename = fileinfo.Name;
   long length = fileinfo.Length;
   //发送文件信息
   if (issend)
   {
    SendVarData(socket, filename + "|" + length);
   }
   //发送文件
   long offset = 0;
   byte[] b = new byte[m_maxpacket];
   int mark = 0;
   using (FileStream fs = new FileStream(path, FileMode.Open, FileAccess.Read))
   {
    int senddata = b.Length;
    long i = length;
    //循环读取发送
    while (true)
    {
     int count = fs.Read(b, 0, senddata);
     if (count > 0)
     {
      socket.Send(b, 0, count, SocketFlags.None);
      offset += count;
      mark = 0;
     }
     else
     {
      mark++;
      if (mark == 10)
      {
       break;
      }
     }
     if (progress != null)
     {
      progress(Convert.ToInt32(((Convert.ToDouble(offset) / Convert.ToDouble(length)) * 100)));
     }
     if (offset == length)
     {
      break;
     }
     Thread.Sleep(50); //设置等待时间,以免粘包
    }
   }
  }
  return ret;
 }
 /// 
 /// 发送文件,不需要进度信息
 /// 
 /// socket对象
 /// 文件路径
 /// 是否发生(头)信息
 /// 
 public static bool SendFile(Socket socket, string path,bool issend)
 {
  return SendFile(socket, path, issend, null);
 }
 /// 
 /// 发送文件,不需要进度信息和(头)信息
 /// 
 /// socket对象
 /// 文件路径
 /// 
 public static bool SendFile(Socket socket, string path)
 {
  return SendFile(socket, path, false, null);
 }
 private static byte[] SerializeObject(object obj)
 {
  IFormatter format = new BinaryFormatter();
  MemoryStream stream = new MemoryStream();
  format.Serialize(stream, obj);
  byte[] ret = stream.ToArray();
  stream.Close();
  return ret;
 }
 private static string GetSendPacketLengthStr(int size)
 {
  string length = size.ToString() + "********"; //得到size的长度
  return length.Substring(0, 8); //截取前前8位
 }
 #endregion
 #region NetworkStream接收数据
 //没写
 #endregion
 #region NetworkStream发送数据
 //没写
 #endregion
}

用法说明:

每个接收的方法都对应着有发送方法

如:

发送方法:

SendFixData(socket,"01");

接收方法:

ReceiveFixData(socket,2); //size 就为2

不知道发送文本长度:

string txt = ????  //不知道有多少字符

发送方法:

SendVarData(socket,txt); //有重载版

接收方法:

ReceiveVarData(socket);

希望本文所述实例对大家C#程序设计有所帮助。


    
 
 

您可能感兴趣的文章:

  • 使用C#开发Socket通讯的方法
  • C# Socket连接请求超时机制实现代码分享
  • c# socket编程udp客户端实现代码分享
  • C# Socket粘包处理讲解示例
  • C#实现Socket通信的解决方法
  • c# socket网络编程接收发送数据示例代码
  • 学习C# Socket入门实例代码
  • C#实现的Socket服务器端、客户端代码分享
  • c#(Socket)同步套接字代码示例
  • c#(Socket)同步套接字代码的实例代码
  • C#中使用Socket获取网页源代码的代码
  • C#使用Socket获取网页源代码的实例代码
  • c#(Socket)异步套接字代码示例
  • C# Socket 异步套接字的代码一例
  • C#开发之Socket网络编程TCP/IP层次模型、端口及报文等探讨
  • 在python中的socket模块使用代理实例
  • Java实现的基于socket通信的实例代码
  • 那位高手能给小弟我一个C/C++的SOCKET程序实例
  • 实现了基于TCP的Java Socket编程实例代码
  • Java网络编程基础教程之Socket入门实例
  • php socket实例之telnet实现的聊天程序
  • java socket编程实例代码讲解
  • php socket客户端及服务器端应用实例
  • C语言实现socket简单通信实例
  • 想java通过socket和c++通讯，哪位有这方面资料或实例?
  • .net socket客户端实例代码分享
  • PHP异步调用socket与php异步执行实例
  • 用socket建立http连接的一段实例程序，有点毛病，大家过来看看啊！！！
    •  
    本站(WWW.)旨在分享和传播互联网科技相关的资讯和技术，将尽最大努力为读者提供更好的信息聚合和浏览方式。
    本站(WWW.)站内文章除注明原创外，均为转载、整理或搜集自网络。欢迎任何形式的转载，转载请注明出处。












  • 相关文章推荐
  • socket 域名解析
  • java命名空间java.net类socket的类成员方法: socket定义及介绍
  • re socket编程中 ACCEPT返回的socket与原socket（他参数中的）端口号一样吗？
  • java命名空间java.nio.channels类socketchannel的类成员方法: socket定义及介绍
  • libevent2需要从socket读一段数据写入一个socket中，同时发送给另一个socket
  • java命名空间java.nio.channels类serversocketchannel的类成员方法: socket定义及介绍
  • vc做的的socket应用和unix下socket?
  • java命名空间java.nio.channels类datagramchannel的类成员方法: socket定义及介绍
  • QSocketDevice ( int socket, Type type )中那个 int socket 是哪里来得?
  • java命名空间java.net类socket的类成员方法: getsendbuffersize定义及介绍
  • socket编程 通过man socket， 没有找到socket函数的第一参数该填什么 怎样利用man手册
  • java命名空间java.net类socket的类成员方法: getreceivebuffersize定义及介绍
  • 线程间可否通过管道传递SOCKET句柄？还有其他方式传递SOCKET么？
  • java命名空间java.net类socket的类成员方法: gettrafficclass定义及介绍
  • [FreeBSD] 大神，求解，control socket ： can‘t to any socket
  • java命名空间java.net类socket的类成员方法: getport定义及介绍
  • 两个 Socket 互相通信，其中一个如何判断另一个 Socket 是否已经意外断开了连接？
  • java命名空间java.net类socket的类成员方法: getlocalport定义及介绍
  • 大家帮忙推荐一本linux socket编程的入门书,我刚接触socket,谢谢!!
  • java命名空间java.net类socket的类成员方法: getinetaddress定义及介绍
  • 我的ping程序怎么老是出现Socket operation on non-socket
  • java命名空间java.net类socket的类成员方法: isconnected定义及介绍
  • sco unix 下输入 man socket 居然显示 man:socket not found up有分


    • 站内导航:


    特别声明:169IT网站部分信息来自互联网,如果侵犯您的权利,请及时告知,本站将立即删除！

    ©2012-2021,,E-mail:www_#163.com(请将#改为@)

    浙ICP备11055608号-3