winform学习日志（二十三）---------------socket（TCP）发送文件

一：由于在上一个随笔的基础之上拓展的所以直接上代码，客户端：


using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Net.Sockets;

using System.Threading;

using System.Net;

using System.IO;


namespace client

{

    public partial class Client : Form

    {

        public Client()

        {

            InitializeComponent();


}

        //创建 1个客户端套接字 和1个负责监听服务端请求的线程

        Socket socketClient = null;

        Thread threadClient = null;

        private delegate void SetText(string text);

        /// <summary>

        /// 链接服务端

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void btn_login_Click(object sender, EventArgs e)

        {

            socketClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            //这里的ip地址，端口号都是服务端绑定的相关数据。

            IPAddress ip = IPAddress.Parse(tb_ip.Text.Trim());

            IPEndPoint endpoint = new IPEndPoint(ip, Convert.ToInt32(tb_socket.Text.Trim()));

            socketClient.Connect(endpoint);//链接有端口号与IP地址确定服务端.


ThreadStart thS = new ThreadStart(this.ReceMsg);


//客户端在接受服务端发送过来的数据是通过Socket 中的Receive方法，

            //该方法会阻断线程，所以我们自己为该方法创建了一个线程

            threadClient = new Thread(thS);

            threadClient.IsBackground = true;//设置后台线程

            threadClient.Start();


}

        //接收服务端数据

        public void ReceMsg()

        {

            while (true)//持续监听服务端发来的消息

            {

                //定义一个2M的内存缓冲区 用于临时性存储接收到的信息

                byte[] buffer = new byte[1024 * 1024 * 2];

                //将客户端套接字接收到的数据存入内存缓冲区, 并获取其长度

                int length = socketClient.Receive(buffer);

                //clientSocket.Receive(buffer);//接收服务端发送过来的数据

                string ReceiveMsg = System.Text.Encoding.UTF8.GetString(buffer,0,length);//把接收到的字节数组转成字符串显示在文本框中,如果没有长度,就会以零填充满,后面的日期就会不显示了。

                ShowMsg("接收到数据: " + ReceiveMsg);

            }

        }


//消息框里面数据

        void ShowMsg(string str)

        {

            if (this.tb_infor.InvokeRequired)

            {

                SetText st = new SetText(ShowMsg);

                this.Invoke(st, new object[] { str });

            }

            else

            {

                //string Ystr = "";

                //if (tb_infor.Text != "")

                //{

                //    Ystr = tb_infor.Text + "\r\n";

                //}

                //tb_infor.Text = Ystr + str + GetCurrentTime();

                //代替上面的方法

                tb_infor.AppendText(str + GetCurrentTime() + "\r\n");

            }

        }

        /// <summary>

        /// 打开文件

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void btn_openfile_Click(object sender, EventArgs e)

        {


if (openFileDialog1.ShowDialog() == DialogResult.OK)//这里需要小括号 ShowDialog()

            {

                tb_openfile.Text = openFileDialog1.FileName;

            }

        }

        #region

        /// <summary>

        /// 发送文件

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void btn_sendfile_Click(object sender, EventArgs e)

        {

            using (FileStream fs = new FileStream(tb_openfile.Text, FileMode.Open))

            {

                byte[] buffer = new byte[1024 * 1024 * 2];

                int readlength = fs.Read(buffer, 0, buffer.Length);

                byte[] filebuffer = new byte[readlength + 1];

                filebuffer[0] = 1;

                Buffer.BlockCopy(buffer, 0, filebuffer, 1, readlength); //第一参数：表示源数组,第二个：表示从源数组中的哪个位置开始拷贝,第三个：表示目标数组。,第四个：表示从目标数组的哪个位置开始填充.,五：表示：拷贝多少数据

                socketClient.Send(filebuffer);

            }

        }

        /// <summary>

        /// 发送消息

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void btn_sendmessage_Click(object sender, EventArgs e)

        {

            string txtMsg = tb_message.Text;

            sendmessage(txtMsg);


}

        /// <summary>

        /// 发送信息

        /// </summary>

        /// <param name="txtMsg"></param>

        private void sendmessage(string txtMsg)

        {

            //将输入的内容字符串转换为机器可以识别的字节数组

            byte[] buffer = Encoding.UTF8.GetBytes(txtMsg);

            byte[] messagebuffer = new byte[buffer.Length + 1];//定义一个新数组,加个标记位,标记是信息

            messagebuffer[0] = 0;//设置标识，表示发送的是字符串

            Buffer.BlockCopy(buffer, 0, messagebuffer, 1, buffer.Length);//源数组中的数据拷贝到新数组中

            socketClient.Send(messagebuffer);

            ShowMsg("发送的数据: " + txtMsg);


}

        #endregion

        /// <summary>

        /// 获取当前系统时间的方法

        /// </summary>

        /// <returns>当前时间</returns>

        private DateTime GetCurrentTime()

        {

            DateTime currentTime = new DateTime();

            currentTime = DateTime.Now;

            return currentTime;

        }


//快捷键 Enter发送信息

        private void tb_message_PreviewKeyDown(object sender, PreviewKeyDownEventArgs e)

        {//当光标位于文本框时 如果用户按下了键盘上的Enter键

            if (e.KeyCode == Keys.Enter)

            {

                    //则调用客户端向服务端发送信息的方法

                    sendmessage(tb_message.Text.Trim());


}


}


}

}

二：服务端


using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Windows.Forms;

using System.Net.Sockets;

using System.Net;

using System.Threading;

using System.IO;


namespace socket

{

    public partial class Server : Form

    {

        public Server()

        {

            InitializeComponent();

            //关闭对文本框的非法线程操作检查,不建议用

            //TextBox.CheckForIllegalCrossThreadCalls = false;

        }


Socket socketWatch = null;//负责监听客户端的套接字

        Thread threadWatch = null;//负责监听客户端的线程

        Thread threadMoveList = null;//负责去掉失败的socket的ip


//声明一个带参数委托处理文本显示

        private delegate void SetText(string text);

        //声明一个处理ip添加到listbox的委托

        private delegate void listboxAdd(string ipsocket);

        //声明一个处理在listbox去除ip的委托

        private delegate void listboxmove(string ipsocket);

        /// 开始服务端监听

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

        private void btn_StartServer_Click(object sender, EventArgs e)

        {

            #region

            //创建一个Socket实例

            //第一个参数表示使用ipv4

            //第二个参数表示发送的是数据流

            //第三个参数表示使用的协议是Tcp协议

            socketWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            //获取ip地址

            IPAddress ip = IPAddress.Parse(tb_ip.Text.Trim());

            //创建一个网络通信节点，这个通信节点包含了ip地址，跟端口号。

            //这里的端口我们设置为1029，这里设置大于1024，为什么自己查一下端口号范围使用说明。

            IPEndPoint endPoint = new IPEndPoint(ip, int.Parse(tb_socket.Text.Trim()));

            //设置SOCKET允许多个SOCKET访问同一个本地IP地址和端口号

            socketWatch.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);

            //Socket绑定网路通信节点

            socketWatch.Bind(endPoint);

            //将套接字的监听队列长度限制为10

            socketWatch.Listen(10);


ShowMsg("开启监听！");


//实力化一个线程上的委托

            ThreadStart threadDelegate = new ThreadStart(this.accpet);//还需要invoke

            //实力化一个处理线程委托的的新线程

            threadWatch = new Thread(threadDelegate);

            //等同于上面两句newthread = new Thread(new ThreadStart(this.accpet));

            threadWatch.IsBackground = true;

            threadWatch.Start();

            #endregion

        }


//消息框里面数据

       public void ShowMsg(string str)

        {

            if (this.tb_infor.InvokeRequired)

            {

                //实例化一个委托

                SetText d = new SetText(ShowMsg);

                this.Invoke(d, new object[] { str });

            }

            else

            {


//string Ystr = "";

                //if (tb_infor.Text != "")

                //{

                //    Ystr = tb_infor.Text + "\r\n";

                //}

                //this.tb_infor.Text = Ystr + str + GetCurrentTime();

                tb_infor.AppendText(str + GetCurrentTime() + "\r\n");

            }

        }


Dictionary<string, Socket> socketDir = new Dictionary<string, Socket>();//将每一个与客户端进行通信的Socket放到该集合中.

       public void accpet()

        {

            while (true)//注意该循环,服务端要持续监听,要不然一个客户端链接过后就无法链接第二个客户端了。

            {


Socket SocketConnection = null;//创建一个负责和客户端通信的套接字

                    //创建一个接收客户端通信的Socket


SocketConnection = socketWatch.Accept();

                    socketDir.Add(SocketConnection.RemoteEndPoint.ToString(), SocketConnection);//将负责与客户端进行通信的Socket实例添加到集合中。

                    //如果监听到客户端有链接，则运行到下一部，提示，链接成功！

                    listboxADD(SocketConnection.RemoteEndPoint.ToString());

                    ShowMsg("链接成功！");

                    //创建一个通信线程

                    ParameterizedThreadStart pts = new ParameterizedThreadStart(ServerRecMsg);

                    Thread thr = new Thread(pts);


//在定义窗体线程的时候,设置线程启动前状态就行了,解决异常

                    thr.SetApartmentState(ApartmentState.STA);


thr.IsBackground = true;

                    //启动线程

                    thr.Start(SocketConnection);


}


}

        /// <summary>

        /// 在ip栏里添加建立socket的ip

        /// </summary>

       private void listboxADD(string ipsocket)

       {

           if (this.ltb_IP.InvokeRequired)

           {

               listboxAdd list = new listboxAdd(listboxADD);

               this.Invoke(list,new object[]{ipsocket});

           }

           else

           {

               ltb_IP.Items.Add(ipsocket);

           }

       }


}

        /// <summary>

        /// 向客户端发送信息

        /// </summary>

        /// <param name="sender"></param>

        /// <param name="e"></param>

       private void btn_sendany_Click(object sender, EventArgs e)

       {

           string SendMsg = tb_message.Text;

           if (SendMsg != "")

           {

               byte[] buffer = System.Text.Encoding.UTF8.GetBytes(SendMsg); //将要发送的数据，生成字节数组。

               if (!string.IsNullOrEmpty(this.ltb_IP.Text))

               {

                   string ipendpoint = this.ltb_IP.SelectedItem .ToString();//在服务端，选择与客户端进行通信的IP地址与端口号

                   socketDir[ipendpoint].Send(buffer);//向客户端发送数据


ShowMsg("向客户端发送了:" + SendMsg);

               }

               else

               {

                   MessageBox.Show("请选择与哪个客户端进行通信");

               }


}


}

       /// <summary>

       /// 获取当前系统时间的方法

       /// </summary>

       /// <returns>当前时间</returns>

       private DateTime GetCurrentTime()

       {

           DateTime currentTime = new DateTime();

           currentTime = DateTime.Now;

           return currentTime;

       }


/// <summary>

        /// 接收客户端发来的信息

        /// </summary>

        /// <param name="socketClientPara">客户端套接字对象</param>

       private void ServerRecMsg(object socketClientPara)

       {

           Socket socketServer = socketClientPara as Socket;

           while (true)

           {

               int length = -1;

               //创建一个内存缓冲区 其大小为1024*1024字节  即1M

               byte[] arrServerRecMsg = new byte[1024 * 1024 * 2];

               try  //由于Socket中的Receive方法容易抛出异常，所以我们在这里要捕获异常。

               {

                   //将接收到的信息存入到内存缓冲区,并返回其字节数组的长度

                   length = socketServer.Receive(arrServerRecMsg);

               }

               catch (SocketException ex)//注意：在捕获异常时，先确定具体的异常类型。

               {

                   ShowMsg("出现了异常:" + ex.Message);

                   socketDir.Remove(socketServer.RemoteEndPoint.ToString());//如果出现了异常，将该Socket实例从集合中移除


//ParameterizedThreadStart Delegatemove = new ParameterizedThreadStart(listboxmoveway);//用ParameterizedThreadStart其方法可以带一个object类型的参数

                   //threadMoveList = new Thread(Delegatemove);

                   //threadMoveList.IsBackground = true;

                   //threadMoveList.Start();

                   //listboxmoveway(socketServer.RemoteEndPoint);//调用方法

                   //socketServer.Close();

                   break;//出现异常以后，终止整个循环的执行

               }

               catch (Exception ex)

               {

                   ShowMsg("出现了异常:" + ex.Message);

                   break;

               }

               if (arrServerRecMsg[0] == 0)//表示字符串

                {


//将机器接受到的字节数组转换为人可以读懂的字符串

                   string strSRecMsg = Encoding.UTF8.GetString(arrServerRecMsg, 1, length-1);

                   //将发送的字符串信息附加到文本框txtMsg上

                   ShowMsg("接受客户端数据:" + strSRecMsg);

                }

               else if (arrServerRecMsg[0] == 1)

               {

                   SaveFileDialog savefile=new SaveFileDialog();

                   if(savefile.ShowDialog()==DialogResult.OK)

                   {

                       using(FileStream fs=new FileStream(savefile.FileName,FileMode.Create))

                       {

                           fs.Write(arrServerRecMsg, 1, length - 1);//将文件写到磁盘上，从1开始到receiveLength-1

                              ShowMsg("文件写成功!" );

                       }

                   }


}


}


}


}

}

winform学习日志（二十三）---------------socket（TCP）发送文件,码迷,mamicode.com

时间： 2024-10-07 05:16:48

winform学习日志（二十三）---------------socket（TCP）发送文件的相关文章

winform学习日志（二十四）----------datetime和timer的使用（小小幻灯片）

一:展示图片 每秒换一次图片,一共六十张图片,00-59 二:代码 a,设计代码 namespace timePicture { partial class Form1 { /// <summary> /// 必需的设计器变量. /// </summary> private System.ComponentModel.IContainer components = null; /// <summary> /// 清理所有正在使用的资源. /// </summary

winform学习日志（二十八）----------将汉字转化为拼音，正则表达式和得到汉字的Unicode编码

一:上图,不清楚的看代码注解,很详细了 二:具体代码 窗体代码 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using System.Text.RegularExpressio

winform学习日志（二十六）----------控件treeview使用

一:实现功能,获得选中节点,在选中节点下添加节点,折叠,展开,删除,得到选中节点下checked项,选中根节点其下节点也选中,图标.上图 二:相关代码 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windo

winform学习日志（二十九）----------根据标点符号分行，StringBuilder的使用；将字符串的每个字符颠倒输出，Reverse的使用

一:根据标点符号分行,上图,代码很简单 二:代码 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; namespace Lines { public partial class Fr

winform学习日志（三十）----------从字符串总分离文件路径、命名、扩展名，Substring(),LastIndexOf()的使用；替换某一类字符串，Replace（）的用法

一:从字符串总分离文件路径.命名.扩展名,上图 二:代码 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; namespace FilePathString { public par

angular学习笔记(二十三)-$http(1)-api

之前说到的$http.get和$http.post,都是基于$http的快捷方式.下面来说说完整的$http: $http(config) $http接受一个json格式的参数config: config的格式如下: { method:字符串 , url:字符串, params:json对象, data:请求数据, headers:请求头, transformRequest:函数,转换post请求的数据的格式, transformResponse:函数,转换响应到的数据的格式, cache:布尔

Log4J学习【二十三】常用的Appender之SocketAppender

前面这几个Appender就是Log4J提供的基于文件系统的Appender.当然,在一些特殊的需要记录到文件的Appender来说,我们只需要选择一个合适的Appender来继承并完成自己的逻辑即可.关于自定义Appender,待会再看.下面来看几个比较特殊的Appender. 前面所有介绍的Appender都有一个共同的特点,就是他们都需要配置一个Layout对象,下面要介绍的这个Appender非常特殊,他本身不需要任何Layout对象,这个Appender就是SocketAppender

Linux学习笔记&lt;二十三&gt;——日志系统syslog

syslog服务 syslogd:系统,负责记录非内核产生的日志信息 klogd:内核,专门负责记录内核产生的日志信息 kernel启动的相关日志 kernel --> 物理终端(/dev/console) --> /var/log/dmesg 查看kernel启动的相关日志 #dmesg #cat /var/log/dmesg 日志存储采取滚动的方式(日志切割): messages messages.1 messages.2,... 配置文件/etc/logrotate.conf [[ema

winform学习日志（二十七）----------unicode编码、字符的转换和得到汉字的区位码

position:static(静态定位) 当position属性定义为static时,可以将元素定义为静态位置,所谓静态位置就是各个元素在HTML文档流中应有的位置 podisition定位问题.所以当没有定义position属性时,并不说明该元素没有自己的位置,它会遵循默认显示为静态位置,在静态定位状态下无法通过坐标值(top,left,right,bottom)来改变它的位置. position:absolute(绝对定位) 当position属性定义为absolute时,元素会脱离文档流