C#Tcp协议收发数据（TCPClient发，Socket收）

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Node.js›Node.js教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

运行这个程序前需要先关闭Windows防火墙，Win7系统关闭防火墙的方法是在控制面板的“控制面板\系统和安全\Windows 防火墙\自定义设置”路径中，将“家庭或工作（专用）网络位置设置”和“公用网络位置设置”下面的选项都选到“关闭Windows防火墙（不推荐）”。

1.界面设计

左侧为发送数据的输入框，单击“发送数据”把数据发送到指定IP地址的指定端口号。（本例中，IP地址和端口号都被写死到代码中）

2.程序代码

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Drawing;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using System.Windows.Forms;
 
using System.Net;

using System.Net.Sockets;

using System.IO;

using System.Threading;
 
namespace TcpClientTest
{

    public partial class FormMain : Form

    {

        public FormMain()

        {

            InitializeComponent();

        }
 
        private void FormMain_Load(object sender, EventArgs e)

        {

            //初始化控件

            txtSendMssg.Text = "测试数据";
 
            //打开Listener开始监听

            Thread thrListener = new Thread(new ThreadStart(Listen));

            thrListener.Start();

        }
 
        private void FormMain_FormClosing(object sender, FormClosingEventArgs e)

        {

            //强制关闭程序（强行终止Listener）

            Environment.Exit(0);

        }
 
        //发送数据

        private void btnSend_Click(object sender, EventArgs e)

        {

            TcpClient tcpClient = new TcpClient();

            //tcpClient.Connect(IPAddress.Parse("170.0.0.78"), 2014);

            tcpClient.Connect(IPAddress.Parse("127.0.0.1"), 2014);
 
            NetworkStream ntwStream = tcpClient.GetStream();

            if (ntwStream.CanWrite)

            {

                Byte[] bytSend = Encoding.UTF8.GetBytes(txtSendMssg.Text);

                ntwStream.Write(bytSend, 0, bytSend.Length);

            }

            else

            {

                MessageBox.Show("无法写入数据流");
 
                ntwStream.Close();

                tcpClient.Close();
 
                return;

            }
 
            ntwStream.Close();

            tcpClient.Close();

        }
 
        //监听数据

        private void Listen()

        {

            Socket listener = new Socket(AddressFamily.InterNetwork, 

                SocketType.Stream, ProtocolType.Tcp);

            listener.Bind(new IPEndPoint(IPAddress.Any, 2014));
 
            //不断监听端口

            while (true)

            {

                listener.Listen(0);

                Socket socket = listener.Accept();

                NetworkStream ntwStream = new NetworkStream(socket);

                StreamReader strmReader = new StreamReader(ntwStream);

                Invoke(new PrintRecvMssgDelegate(PrintRecvMssg), 

                    new object[] { strmReader.ReadToEnd() });

                socket.Close();

            }
 
            //程序的listener一直不关闭

            //listener.Close();

        }
 
        //线程内向文本框txtRecvMssg中添加字符串及委托

        private delegate void PrintRecvMssgDelegate(string s);

        private void PrintRecvMssg(string info)

        {

            txtRecvMssg.Text += string.Format("[{0}]:{1}\r\n", 

                DateTime.Now.ToLongTimeString(), info);

        }

    }
}

3.运行效果

在发送数据的文本框中分别输入“千山鸟飞绝”、“万径人踪灭”、“孤舟蓑笠翁”、“独钓寒江雪”四句话，输完一句话，单击一次“发送数据”按钮，就可以在接收数据里看到这四句话了。上面代码中，信息的发送时通过TcpClient连接到127.0.0.1的2014端口，信息的接收是通过Listen函数不断监听本机的2014端口实现的。从自己创建的线程中修改控件信息，用到了委托。

END