我要评论前言
文件上传有ftp、webapi、webservice等等，这次我们来实现一个基于socket通信的本地客户端上传文件到服务器的例子。
运行效果
一、socket（套接字）概念
说起socket通信，那就不得不介绍一下套接字（socket），套接字是通信的基石，是支持tcp/ip协议的网络通信的基本操作单元，套接字socket=（ip地址：端口号）。就是对网络中不同主机上的应用进程之间进行双向通信的端点的抽象。一个套接字就是网络上进程通信的一端，提供了应用层进程利用网络协议交换数据的机制。从所处的地位来讲，套接字上联应用进程，下联网络协议栈，是应用程序通过网络协议进行通信的接口，是应用程序与网络协议栈进行交互的接口，它包含进行网络通信必须的五种信息：连接使用的协议，本地主机的ip地址，本地进程的协议端口，远地主机的ip地址，远地进程的协议端口。
二、socket通信的建立
建立socket连接至少需要一对套接字，其中一个运行于客户端，称为clientsocket ，另一个运行于服务器端，称为serversocket 。
三、通信流程
根据连接启动的方式以及本地套接字要连接的目标，套接字之间的连接过程可以分为三个步骤：
(1)服务器监听。
(2)客户端请求。
(3)连接确认。
1.服务器监听
所谓服务器监听，是指服务器端套接字并不定位具体的客户端套接字，而是处于等待连接的状态，实时监控网络状态。
2.客户端请求
所谓客户端请求，是指由客户端的套接字提出连接请求，要连接的目标是服务器端的套接字。为此，客户端的套接字必须首先描述它要连接的服务器的套接字，指出服务器端套接字的地址和端口号，然后就向服务器端接字提出连接请求 。
3.连接确认
所谓连接确认，是指当服务器端套接字监听到或者说接收到客户端套接字的连接请求，就会响应客户端套接字的请求，建立一个新的线程，并把服务器端套接字的描述发送给客户端。一旦客户端确认了此描述，连接就建立好了。而服务器端套接字继续处于监听状态，接收其他客户端套接字的连接请求。
四、实现
1.clientsocket
本机ip地址在窗体加载的时候赋值。
private void frmmain_load(object sender, eventargs e)
{
//获得本机的ip地址
this.textbox4.text = dns.gethostbyname(dns.gethostname()).addresslist[0].tostring();
}接下来我们正式开始，点击浏览，选择需要上传的文件。此时我们获取当前文件的全路径、文件名称及合计字节。
/// <summary>
/// 浏览
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void button1_click(object sender, eventargs e)
{
//选择要进行传输的文件
if (this.openfiledialog1.showdialog() == dialogresult.ok)
{
fileinfo ezonefile = new fileinfo(this.openfiledialog1.filename);
this.textbox1.text = ezonefile.fullname;
this.textbox2.text = ezonefile.name;
this.textbox3.text = ezonefile.length.tostring();
}
}点击发送按钮，将文件以字节流的形式发送到服务器端，此时应该单独开一个子线程以保证监听运行，监听事件定义startsend。
/// <summary>
/// 开始发送
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void button2_click(object sender, eventargs e)
{
//开启文件传输子线程
thread tempthread = new thread(new threadstart(this.startsend));
tempthread.start();
}startsend事件中，根据文件路径创建一个文件对象，配置操作流、创建连接对象、ip\port等等关键信息。首先我们来创建一个帮助类fileclientsocket.cs
using system;
using system.collections.generic;
using system.linq;
using system.net.sockets;
using system.text;
namespace touchsocketclient
{
public class fileclientsocket
{
public static int senddata(socket s, byte[] data)
{
int total = 0;
int size = data.length;
int dataleft = size;
int sent;
while (total < size)
{
sent = s.send(data, total, dataleft, socketflags.none);
total += sent;
dataleft -= sent;
}
return total;
}
public static byte[] receivedata(socket s, int size)
{
int total = 0;
int dataleft = size;
byte[] data = new byte[size];
int recv;
while (total < size)
{
recv = s.receive(data, total, dataleft, socketflags.none);
if (recv == 0)
{
data = null;
break;
}
total += recv;
dataleft -= recv;
}
return data;
}
public static int sendvardata(socket s, byte[] data)
{
int total = 0;
int size = data.length;
int dataleft = size;
int sent;
byte[] datasize = new byte[4];
datasize = bitconverter.getbytes(size);
sent = s.send(datasize);
while (total < size)
{
sent = s.send(data, total, dataleft, socketflags.none);
total += sent;
dataleft -= sent;
}
return total;
}
public static byte[] receivevardata(socket s)
{
int total = 0;
int recv;
byte[] datasize = new byte[4];
recv = s.receive(datasize, 0, 4, socketflags.none);
int size = bitconverter.toint32(datasize, 0);
int dataleft = size;
byte[] data = new byte[size];
while (total < size)
{
recv = s.receive(data, total, dataleft, socketflags.none);
if (recv == 0)
{
data = null;
break;
}
total += recv;
dataleft -= recv;
}
return data;
}
}
}startsend方法实现
private void startsend()
{
//创建一个文件对象
fileinfo ezonefile = new fileinfo(this.textbox1.text);
//打开文件流
filestream ezonestream = ezonefile.openread();
//包的大小
int packetsize = int.parse(this.textbox6.text);
//包的数量
int packetcount = (int)(ezonestream.length / ((long)packetsize));
//最后一个包的大小
int lastdatapacket = (int)(ezonestream.length - ((long)(packetsize * packetcount)));
//指向远程服务端节点
ipendpoint ipep = new ipendpoint(ipaddress.parse(txtip.text.trim()), int.parse(this.textbox5.text));
//创建套接字
socket client = new socket(addressfamily.internetwork, sockettype.stream, protocoltype.tcp);
//连接到发送端
client.connect(ipep);
//获得客户端节点对象
ipendpoint clientep = (ipendpoint)client.remoteendpoint;
//获得客户端的ip地址
//this.textbox7.text=clientep.address.tostring();
//发送[文件名]到客户端
fileclientsocket.sendvardata(client,system.text.encoding.unicode.getbytes(ezonefile.name));
//发送[包的大小]到客户端
fileclientsocket.sendvardata(client,system.text.encoding.unicode.getbytes(packetsize.tostring()));
//发送[包的总数量]到客户端
fileclientsocket.sendvardata(client,system.text.encoding.unicode.getbytes(packetcount.tostring()));
//发送[最后一个包的大小]到客户端
fileclientsocket.sendvardata(client,system.text.encoding.unicode.getbytes(lastdatapacket.tostring()));
//数据包
byte[] data = new byte[packetsize];
//开始循环发送数据包
for (int i = 0; i < packetcount; i++)
{
//从文件流读取数据并填充数据包
ezonestream.read(data, 0, data.length);
//发送数据包
fileclientsocket.sendvardata(client, data);
}
//如果还有多余的数据包,则应该发送完毕!
if (lastdatapacket != 0)
{
data = new byte[lastdatapacket];
ezonestream.read(data, 0, data.length);
fileclientsocket.sendvardata(client, data);
}
//关闭套接字
client.close();
//关闭文件流
ezonestream.close();
messagebox.show("文件传输完毕!");
}至此客户端部分已经完成，下面开始实现服务端。
2.serversocket
我们新建一个控制台应用程序，touchsocketserver。
在main方法中 注册接收事件，并开始子线程进行处理。
static void main(string[] args)
{
//开启接收线程
thread tempthread = new thread(new threadstart(startreceive));
tempthread.start();
}同样我们服务端也需要一个server类（filesocketserver.cs）
namespace touchsocketserver
{
public class filesocketserver
{
public static int senddata(socket s, byte[] data)
{
int total = 0;
int size = data.length;
int dataleft = size;
int sent;
while (total < size)
{
sent = s.send(data, total, dataleft, socketflags.none);
total += sent;
dataleft -= sent;
}
return total;
}
public static byte[] receivedata(socket s, int size)
{
int total = 0;
int dataleft = size;
byte[] data = new byte[size];
int recv;
while (total < size)
{
recv = s.receive(data, total, dataleft, socketflags.none);
if (recv == 0)
{
data = null;
break;
}
total += recv;
dataleft -= recv;
}
return data;
}
public static int sendvardata(socket s, byte[] data)
{
int total = 0;
int size = data.length;
int dataleft = size;
int sent;
byte[] datasize = new byte[4];
datasize = bitconverter.getbytes(size);
sent = s.send(datasize);
while (total < size)
{
sent = s.send(data, total, dataleft, socketflags.none);
total += sent;
dataleft -= sent;
}
return total;
}
public static byte[] receivevardata(socket s)
{
int total = 0;
int recv;
byte[] datasize = new byte[4];
recv = s.receive(datasize, 0, 4, socketflags.none);
int size = bitconverter.toint32(datasize, 0);
int dataleft = size;
byte[] data = new byte[size];
while (total < size)
{
recv = s.receive(data, total, dataleft, socketflags.none);
if (recv == 0)
{
data = null;
break;
}
total += recv;
dataleft -= recv;
}
return data;
}
}
}接收函数
private static void startreceive()
{
//创建一个网络端点
console.foregroundcolor = consolecolor.darkred;
console.writeline($"{datetime.now} [初始化网络端点]");
ipendpoint ipep = new ipendpoint(ipaddress.any, int.parse("1005"));
//messagebox.show(ipaddress.any);
//创建一个套接字
socket server = new socket(addressfamily.internetwork, sockettype.stream, protocoltype.tcp);
//绑定套接字到端口
server.bind(ipep);
//开始侦听(并堵塞该线程)
console.writeline($"{datetime.now} [开始侦听并堵塞该线程]");
server.listen(10);
while (true)
{
try
{
socket client = server.accept();
clientsocket = client;
thread tempthread = new thread(new threadstart(create));
tempthread.start();
}
catch (exception ex)
{
int k = 0;
}
}
}创建文件函数
public static void create()
{
console.foregroundcolor = consolecolor.green;
console.writeline($"{datetime.now} [创建对象]");
socket client = clientsocket;
//确认连接
//socket client = server.accept();
//获得客户端节点对象
console.foregroundcolor = consolecolor.yellow;
ipendpoint clientep = (ipendpoint)client.remoteendpoint;
console.writeline($"{datetime.now} 请求对象：[{clientep.address}]");
//获得[文件名]
string sendfilename = system.text.encoding.unicode.getstring(filesocketserver.receivevardata(client));
console.writeline($"{datetime.now} 文件名称：[{sendfilename}]");
//获得[包的大小]
string bagsize = system.text.encoding.unicode.getstring(filesocketserver.receivevardata(client));
//获得[包的总数量]
int bagcount = int.parse(system.text.encoding.unicode.getstring(filesocketserver.receivevardata(client)));
//获得[最后一个包的大小]
string baglast = system.text.encoding.unicode.getstring(filesocketserver.receivevardata(client));
//自动创建文件夹
string path = $@"{system.appdomain.currentdomain.basedirectory}\log\{clientep.address}({datetime.now.tostring("yyyymmddhhmmssffffff")})";
directory.createdirectory(path);
//创建一个新文件
filestream myfilestream = new filestream($@"{path}\" + sendfilename, filemode.create, fileaccess.write);
console.writeline($"{datetime.now} 创建目标：[已创建]");
//已发送包的个数
int sendedcount = 0;
while (true)
{
byte[] data = filesocketserver.receivevardata(client);
if (data.length == 0)
{
break;
}
else
{
sendedcount++;
//将接收到的数据包写入到文件流对象
myfilestream.write(data, 0, data.length);
//显示已发送包的个数
}
}
//关闭文件流
myfilestream.close();
//关闭套接字
client.close();
console.writeline($"{datetime.now} 传输结果：[成功]");
}到此这篇关于c# socket文件上传至服务器的文章就介绍到这了,更多相关c# socket文件上传内容请搜索代码网以前的文章或继续浏览下面的相关文章希望大家以后多多支持代码网！
发表评论