- 浏览: 73445 次
- 性别:
- 来自: 厦门
最新评论
-
BlueBing:
linyuliang 写道BlueBing 写道我想再做些修改 ...
IBatis Abator去除注释版 -
linyuliang:
BlueBing 写道我想再做些修改 可否提供下源码呢晚上我回 ...
IBatis Abator去除注释版 -
linyuliang:
xiaohu7924 写道为什么我用这个生成的名字不是你说的驼 ...
IBatis Abator去除注释版 -
xiaohu7924:
为什么我用这个生成的名字不是你说的驼锋名字,还是老样子
IBatis Abator去除注释版 -
BlueBing:
我想再做些修改 可否提供下源码呢
IBatis Abator去除注释版
最近一个项目要用到点对点文件传输,俺就到处找资料写程序,最后终于完成了,为了让别人少走些弯路,俺决定将俺程序中最重要的部分贡献出来,希望对大家有所帮助。
俺的程序分三部分,包括发送部分、接受部分和一个两者共享的通讯基类,这个基类才是俺心血的结晶:)
一、通讯基类
using System;
using System.Net.Sockets;
using System.Net ;
using System.IO ;
using System.Windows.Forms;
using System.Text;
namespace BaseClass
{
/// <summary>
/// 传送信息的格式为 给定长度的命令部分+给定长度的命令注释部分+可变长度的长度信息+可变长度的信息部分
/// </summary>
public class CommunClass
{
public CommunClass()
{
//
// TODO: 在此处添加构造函数逻辑
//
}
/// <summary>
/// 命令部分的长度
/// </summary>
private static readonly int CMDLEN = 50 ;
/// <summary>
/// 命令注释部分的长度
/// </summary>
private static readonly int DESCLEN = 100 ;
/// <summary>
/// 可变长度的长度信息部分所占的字节数
/// </summary>
private static readonly int DYNAMICLENGTHLEN = 10 ;
/// <summary>
/// 每次处理可变信息部分的长度
/// </summary>
private static readonly int DEALLEN = 1024 ;
/// <summary>
/// /应答的最大长度
/// </summary>
private static readonly int RESPONLEN = 20 ;
/// <summary>
/// 用于填充命令或注释不足长度部分的字符
/// </summary>
private static readonly char FILLCHAR = '^' ;
/// <summary>
/// 成功发送一部分数据后的回调方法(也可以认为是触发的事件,但严格来说还不是)
/// </summary>
public delegate void OnSend(int iTotal,int iSending) ;
/// <summary>
/// 根据给定的服务器和端口号建立连接
/// </summary>
/// <param name="strHost">服务器名</param>
/// <param name="iPort">端口号</param>
/// <returns></returns>
public static Socket ConnectToServer(string strHost,int iPort)
{
try
{
IPAddress ipAddress = Dns.Resolve(strHost).AddressList[0];
IPEndPoint ipPoint = new IPEndPoint(ipAddress,iPort) ;
Socket s = new Socket(AddressFamily.InterNetwork,SocketType.Stream,ProtocolType.Tcp) ;
s.Connect(ipPoint) ;
return s ;
}
catch (Exception e)
{
throw (new Exception("建立到服务器的连接出错" + e.Message)) ;
}
}
/// <summary>
/// 将文本写到Socket中
/// </summary>
/// <param name="s">要发送信息的Socket</param>
/// <param name="strInfo">要发送的信息</param>
/// <returns>是否成功</returns>
public static bool WriteTextToSocket(Socket s,string strInfo)
{
byte [] buf = Encoding.UTF8.GetBytes(strInfo) ;
try
{
s.Send(buf,0,buf.Length,SocketFlags.None) ;
return true ;
}
catch(Exception err)
{
MessageBox.Show("发送文本失败!"+err.Message) ;
return false ;
}
}
/// <summary>
/// 将命令文本写到Socket中
/// </summary>
/// <param name="s">要发送命令文本的Socket</param>
/// <param name="strInfo">要发送的命令文本</param><!----><o:p></o:p>
/// <returns>是否成功</returns>
public static bool WriteCommandToSocket(Socket s,string strCmd)
{
if (strCmd == "")
strCmd = "NOP" ;
strCmd = strCmd.PadRight(CMDLEN,FILLCHAR) ;
return WriteTextToSocket(s,strCmd) ;
}
/// <summary>
/// 将命令注释写到Socket中
/// </summary>
/// <param name="s">要发送命令注释的Socket</param>
/// <param name="strInfo">要发送的命令注释</param>
/// <returns>是否成功</returns>
public static bool WriteCommandDescToSocket(Socket s,string strDesc)
{
if (strDesc == "")
strDesc = "0" ;
strDesc = strDesc.PadRight(DESCLEN,FILLCHAR) ;
return WriteTextToSocket(s,strDesc) ;
}
/// <summary>
/// 发送可变信息的字节数
/// </summary>
/// <param name="s">要发送字节数的Socket</param>
/// <param name="iLen">字节数</param>
/// <returns>是否成功</returns>
public static bool WriteDynamicLenToSocket(Socket s,int iLen)
{
string strLen = iLen.ToString().PadRight(DYNAMICLENGTHLEN,FILLCHAR) ;
return WriteTextToSocket(s,strLen) ;
}
/// <summary>
/// 将缓存的指定部分发送到Socket
/// </summary>
/// <param name="s">要发送缓存的Socket</param>
/// <param name="buf">要发送的缓存</param>
/// <param name="iStart">要发送缓存的起始位置</param>
/// <param name="iCount">要发送缓存的字节数</param>
/// <param name="iBlock">每次发送的字节说</param>
/// <param name="SendSuccess">每次发送成功后的回调函数</param>
/// <returns>是否发送成功</returns>
public static bool WriteBufToSocket(Socket s,byte [] buf,int iStart,int iCount,int iBlock,OnSend SendSuccess)
{
int iSended = 0 ;
int iSending = 0 ;
while(iSended<iCount)
{
if (iSended + iBlock <= iCount)
iSending = iBlock ;
else
iSending = iCount - iSended ;
s.Send(buf,iStart+iSended,iSending,SocketFlags.None) ;
iSended += iSending ;
if (ReadResponsionFromSocket(s)=="OK")
if (SendSuccess != null)
SendSuccess(iCount,iSended) ;
else
return false;
}
return true ;
}
/// <summary>
/// 将长度不固定文本发送到socket
/// </summary>
/// <param name="s">要发送文本的Socket</param>
/// <param name="strText">要发送的文本</param>
/// <param name="OnSendText">成功发送一部分文本后的回调函数</param>
/// <param name="settextlen">得到文本长度的回调函数</param>
/// <returns></returns>
public static bool WriteDynamicTextToSocket(Socket s,string strText,
OnSend OnSendText)
{
byte [] buf = Encoding.UTF8.GetBytes(strText) ;
int iLen = buf.Length ;
try
{
WriteDynamicLenToSocket(s,iLen) ;
return WriteBufToSocket(s,buf,0,iLen, DEALLEN,OnSendText) ;
}
catch(Exception err)
{
MessageBox.Show("发送文本失败!"+err.Message) ;
return false ;
}
}
/// <summary>
/// 将文件写到Socket
/// </summary>
/// <param name="s">要发送文件的Socket</param>
/// <param name="strFile">要发送的文件</param>
/// <returns>是否成功</returns>
public static bool WriteFileToSocket(Socket s,string strFile,
OnSend OnSendFile)
{
FileStream fs = new FileStream(strFile,FileMode.Open,FileAccess.Read,FileShare.Read) ;
int iLen = (int)fs.Length ;
WriteDynamicLenToSocket(s,iLen) ;
byte [] buf = new byte[iLen] ;
try
{
fs.Read(buf,0,iLen) ;
return WriteBufToSocket(s,buf,0,iLen,DEALLEN,OnSendFile) ;
}
catch(Exception err)
{
MessageBox.Show("发送文件失败!"+err.Message) ;
return false ;
}
finally
{
fs.Close() ;
}
}
/// <summary>
/// 对方对自己消息的简单回应
/// </summary>
/// <param name="s"></param>
/// <returns></returns>
public static string ReadResponsionFromSocket( Socket s)
{
byte [] bufCmd = new byte[RESPONLEN] ;
int iCount = s.Receive(bufCmd) ;
string strRespon = Encoding.UTF8.GetString(bufCmd,0,iCount) ;
return strRespon ;
}<o:p></o:p>
/// <summary>
/// 从Socket读取命令
/// </summary>
/// <param name="s">要读取命令的Socket</param>
/// <returns>读取的命令</returns>
public static string ReadCommandFromSocket( Socket s)
{
byte [] bufCmd = new byte[CMDLEN] ;
int iCount = s.Receive(bufCmd,0,CMDLEN,SocketFlags.Partial) ;
string strCommand = Encoding.UTF8.GetString(bufCmd,0,CMDLEN) ;
return strCommand = strCommand.TrimEnd(FILLCHAR) ;
}
/// <summary>
/// 读取命令注释
/// </summary>
/// <param name="s">要读取命令注释的Socket</param>
/// <returns>读取的命令注释</returns>
public static string ReadCommandDescFromSocket( Socket s)
{
byte [] bufCmd = new byte[DESCLEN] ;
int iCount = s.Receive(bufCmd,0,DESCLEN,SocketFlags.Partial) ;
string strCommand = Encoding.UTF8.GetString(bufCmd,0,DESCLEN) ;
return strCommand = strCommand.TrimEnd(FILLCHAR) ;
}
/// <summary>
/// 读取可变部分的长度
/// </summary>
/// <param name="s">要读取可变部分长度的Socket</param>
/// <returns>读取的可变部分的长度</returns>
public static int ReadDynamicLenFromSocket( Socket s)
{
byte [] bufCmd = new byte[DYNAMICLENGTHLEN] ;
int iCount = s.Receive(bufCmd,0,DYNAMICLENGTHLEN,SocketFlags.Partial) ;
string strCommand = Encoding.UTF8.GetString(bufCmd,0,DYNAMICLENGTHLEN) ;
return int.Parse(strCommand.TrimEnd(FILLCHAR)) ;
}
/// <summary>
/// 读取文本形式的可变信息
/// </summary><o:p></o:p>
/// <param name="s">要读取可变信息的Socket</param>
/// <returns>读取的可变信息</returns>
public static string ReadDynamicTextFromSocket( Socket s)
{
int iLen = ReadDynamicLenFromSocket(s) ;
byte [] buf = new byte[iLen] ;
string strInfo = "" ;
int iReceiveded = 0 ;
int iReceiveing = 0 ;
while(iReceiveded<iLen)
{
if (iReceiveded + DEALLEN <= iLen)
iReceiveing = DEALLEN ;
else
iReceiveing = iLen - iReceiveded ;
s.Receive(buf,iReceiveded,iReceiveing,SocketFlags.None) ;
CommunClass.WriteTextToSocket(s,"OK") ;
iReceiveded+= iReceiveing ;
}
strInfo = Encoding.UTF8.GetString(buf,0,iLen) ;
return strInfo ;
}
/// <summary>
/// 读取文件形式的可变信息
/// </summary>
/// <param name="s">要读取可变信息的Socket</param>
/// <param name="strFile">读出后的文件保存位置</param>
/// <returns>是否读取成功</returns>
public static bool ReadDynamicFileFromSocket( Socket s,string strFile)
{
int iLen = ReadDynamicLenFromSocket(s) ;
byte [] buf = new byte[iLen] ;
FileStream fs = new FileStream(strFile,FileMode.Create,FileAccess.Write) ;
try
{
int iReceiveded = 0 ;
int iReceiveing = 0 ;
while(iReceiveded<iLen)
{if (iReceiveded + DEALLEN <= iLen)
iReceiveing = DEALLEN ;
else
iReceiveing = iLen - iReceiveded ;
s.Receive(buf,iReceiveded,iReceiveing,SocketFlags.None) ;
CommunClass.WriteTextToSocket(s,"OK") ;
iReceiveded+= iReceiveing ;
}
fs.Write(buf,0,iLen) ;
return true ;
}
catch(Exception err)
{
MessageBox.Show("接收文件失败"+err.Message) ;
return false ;
}
finally
{
fs.Close() ;
}
}
}//end class
}//end namespace
上面是俺的通讯基础类,有了这个类,再进行发送接受还不是小菜一碟吗?
发表评论
-
实现GridView控件的删除多条记录功能系列(1)
2005-08-10 14:15 1472在Asp.Net 2.0中新增的控件GridView可 ... -
实现GridView控件的删除多条记录功能系列(2)
2005-08-10 14:55 1324在上一篇中,我们已经开发了需要的CheckBox控件, ... -
实现GridView控件的删除多条记录功能系列(3)
2005-08-11 12:18 1334本篇将讲述如何解决GridView控件中使用Check ... -
[转]C#正则表达式小结
2007-09-24 11:38 1221地址: http://www.cnblogs.co ... -
[转]全面剖析C#正则表达式
2007-09-24 11:41 1391地址:http://fineboy.cnblogs.com/ ... -
(转贴)VS.NET下水晶报表分发时的问题及解决
2007-10-18 17:27 1181一、载入报表时报错 ... -
(转贴)图解使用VS.NET部署含水晶报表的网站
2007-10-18 17:56 2140Crystal Report ,中文名称“水晶报表”,因为做报 ... -
[转]VS2005 web程序自定义安装包的制作
2007-10-23 10:28 2122利用VS2005的“Web安装项目”建立安装包很难对安装过程进 ... -
[转]使用C#进行点对点通讯和文件传输(发送接收部分)
2007-10-24 11:00 1689上面介绍了通讯的基类,下面就是使用那个类进行发送和接收的部分: ... -
[转载]C#中串口通信编程
2007-10-24 11:01 4526原文及源代码位置:http://bbs.msproject.c ... -
[转]C#多线程编程实例实战
2007-10-24 11:02 1679单个写入程序/多个阅读程序在.Net类库中其实已经提供了实现, ... -
[转]实现同时只允许运行一个程序实例
2007-10-24 11:06 1141方法一: /// <summary> /// 从这 ... -
[转]IIS虚拟目录控制类
2007-10-24 11:08 450using System;using System.Data; ... -
[转]C# 调用API,实现注销远程登录本机的用户
2007-10-24 11:08 1854using System;using System.Manag ... -
[转]C#的usb通讯编程
2007-10-24 11:10 2820using System;using System.Colle ... -
[转]IIS站点管理类
2007-10-24 11:10 975using System;using System.Colle ... -
[转]使用.NET实现断点续传
2007-10-24 11:11 1334断点续传的原理 在了解HTTP断点续传的原理之前,先来说说HT ... -
[转]Datagridview 实现二维表头
2007-10-26 16:42 2345最近把我们的b/s系统,增加智能客户端的功能。确实智能客户端是 ... -
[转]Web项目下NHibernate的Session管理的解决方案
2007-11-07 10:47 3398NHibernate的Session的管理一直是个问题,在系统 ... -
[转] NHibernate对像版本控制使用示例
2007-11-07 10:49 1259<version name="Version& ...
相关推荐
源码中的"串口基类"很可能是对`SerialPort`类的一个封装,以提供更便于使用的接口和统一的管理方式。 源码中的关键知识点可能包括: 1. **创建SerialPort对象**:首先,你需要实例化一个`SerialPort`对象,指定串...
以上知识点是"C#基类工具类"的核心组成部分,它们涵盖了日常开发中许多常见的任务。通过封装这些功能,开发者可以快速构建应用程序,而无需每次都从头开始编写相同的代码。这样的工具类对于提高代码质量和开发效率...
Assistant创建显示图像的标签和文件 OWCChart统计图的封装类 2.Cookie&Session&Cache缓存帮助类 CacheHelper C#操作缓存的帮助类,实现了怎么设置缓存,怎么取缓存,怎么清理缓存等方法,只需要调用方法就可以...
11. **上传下载**:提供了文件上传和下载的类,支持断点续传和多线程,优化了大文件传输的性能。 12. **视频转换**:通过基类库可以调用外部工具或API进行视频格式转换,实现跨平台的多媒体处理。 13. **Http类**...
如果XML文档的结构与基类相匹配,并且我们只需要使用基类中定义的属性和方法,那么使用基类进行反序列化是合适的。反之,如果我们需要使用派生类中新增的特性,那么就应该选择派生类进行反序列化。同时,我们还可以...
注意,为了确保线程安全,可能需要使用锁或其他同步机制来控制对文件的写入。 总的来说,用C#实现HTTP协议下的多线程文件传输,涉及到HTTP协议的理解、C#的网络编程以及多线程技术的应用。通过合理地组织代码,可以...
### PDA通讯C#实现网络通讯 #### 一、引言 随着移动互联网技术的发展,手持设备(如PDA)在网络通信中的应用越来越广泛。在本文档中,我们将详细介绍如何利用C#语言来实现PDA与网络之间的通信,并具体探讨其中涉及...
总之,这个源码涵盖了C#中的Socket通信、文件传输、图片处理和聊天功能实现等多个方面,是学习和实践网络编程的宝贵资料。通过深入研究这个源码,开发者可以更好地理解如何在实际项目中应用这些技术,提升自己的编程...
总的来说,"C#上传下载文件源代码"提供了一个实用的工具集,可以帮助开发者快速实现文件在网络中的传输功能,同时涵盖了多种关键的编程概念和技术,包括网络通信、文件处理、异步操作以及安全性。通过理解和使用这些...
QT进程间的多个管道通信以及与C#客户端的并发通信是一个复杂但重要的技术点,尤其在分布式系统和跨平台应用开发中。以下将详细介绍这个主题。 首先,QT是一个强大的跨平台应用程序开发框架,支持多种编程语言,包括...
本项目是一个C#实现的ZIP压缩客户端程序,它允许用户通过代码操作来完成文件或文件夹的压缩任务,这在数据管理和传输中非常实用。下面我们将详细探讨这个程序涉及的关键知识点。 1. **C#语言基础**: C#是微软公司...
2. **XmlDocument类**:它是C#中最常用的XML处理类,可以加载XML文件,然后通过其提供的方法和属性对XML进行读写操作。例如,Load方法用于加载XML文件,GetElementsByTagName用于查找特定标签的节点。 3. **XmlNode...
本压缩包中的源码着重展示了如何在C#环境中对XML文件进行操作。下面将详细阐述相关知识点。 1. **XML基础** - XML是一种标记语言,它的主要目的是为了传输和存储数据,而不是显示数据。 - XML文档由元素(Element...
本文将深入探讨C#.Net中对XML文件进行操作的相关知识点。 一、XML基础 XML(Extensible Markup Language)是一种可扩展标记语言,用于存储和传输结构化数据。它具有自描述性,结构清晰,易于机器和人阅读。在C#.Net...
3. **异步流(Async Streams)**:这是一个强大的新特性,使得异步操作可以以流的形式处理,适用于大量数据的处理,如文件读写或网络传输,极大地提高了代码的效率和可读性。 4. **静态局部函数**:这些函数仅在...
在C#中,我们可以使用System.Xml命名空间中的类来对XML进行读取、写入、修改等操作。以下是这个学习项目中涉及的关键知识点: 1. **XmlDocument类**:这是C#中最常用的XML处理类,它提供了对XML文档的完整DOM...
- **测试友好**:由于模型和视图的分离,可以方便地对模型进行单元测试,而无需依赖于UI。 - **可重用性**:视图和模型可以独立存在,视图可以重用,模型也可以在其他地方使用。 总结,这个"MVC简单例子C#"涵盖了C#...
C# Remoting是.NET框架早期的一种远程方法调用技术,它允许对象在不同的应用程序域(AppDomain)之间进行通信,甚至是跨进程或跨网络。在这个完整的实例中,我们将深入探讨C# Remoting的关键概念和实践操作,以...