C#使用TCP进行聊天通信(详细解析)

这篇具有很好参考价值的文章主要介绍了C#使用TCP进行聊天通信(详细解析)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

TCP通信可以使用Socket和TcpListene进行通信,TcpListene是Socket的一个封装,可以更好的操作Socket,底层依然是socket。

进行通信分为2部分,一个是服务端,一个是客户端。

一,服务端

C#使用TCP进行聊天通信(详细解析)

1.使用TcpListener实例化,得到服务器的ip和端口 

myListener = new TcpListener(IPAddress.Parse(textBox1.Text), Convert.ToInt32(textBox2.Text)); 

2.启动TcpListener

myListener.Start();   

3.创建一个线程 

Thread myThread = new Thread(ListenClientConnect); 

4.让这个线程,不停的监听客户端的请求

newClient = myListener.AcceptTcpClient();

5.从网络流中获得客户端的消息

 receiveString = user.br.ReadString();

6.把流写入给user

 user.bw.Write(message);  user.bw.Flush();

7. 停止监听

myListener.Stop();

二,客户端

C#使用TCP进行聊天通信(详细解析)

1.实例化

client = new TcpClient();

2.连接服务器

client.Connect(IPAddress.Parse(textBox3.Text), Convert.ToInt32(textBox2.Text));

3.获取网络流

NetworkStream networkStream = client.GetStream();

4.将网络流作为二进制读写对象

br = new BinaryReader(networkStream);bw = new BinaryWriter(networkStream);

5.读取服务器的流,接收消息

receiveString = br.ReadString();

6.向服务器写流,发送消息

 bw.Write(message);

7.释放资源,关闭连接

br.Close();

bw.Close();

client.Close();

信息传递的流程:

客户端登录
服务器监听
客户端发送消息
服务器收到消息


服务器收到消息后,把消息发给客户端
服务器又监听了(消息空了)

客户端收到消息
客户端又监听了  

拓展核心代码:

使用NetworkStream类,把流分别给BinaryReader读,BinaryWriter写。

必须按顺序  写  流

必须按顺序  读  流

服务器

using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;

namespace ConsoleApp2
{
    /// <summary>
    /// 服务端监听客户端信息,一旦有发送过来的信息,便立即处理
    /// </summary>
    class Program
    {
        //全局TcpClient
        static TcpClient client;
        //文件流建立到磁盘上的读写流
        static FileStream fs = new FileStream(@"D:\demo\6.jpg", FileMode.Create);
        //buffer
        static int bufferlength = 200;
        static byte[] buffer = new byte[bufferlength];
        //网络流
        static NetworkStream ns;
         static BinaryReader br;
       
        static void Main(string[] args)
        {
            ConnectAndListen();
        }

        static void ConnectAndListen()
        {
            //服务端监听任何IP 但是端口号是80的连接
            TcpListener listener = new TcpListener(IPAddress.Any, 8083);
            //监听对象开始监听
            listener.Start();
            while (true)
            {
                Console.WriteLine("等待连接");
                //线程会挂在这里,直到客户端发来连接请求
                client = listener.AcceptTcpClient();
                Console.WriteLine("已经连接");
                //得到从客户端传来的网络流
                ns = client.GetStream();

                br = new BinaryReader(ns);
                //如果网络流中有数据
                if (ns.DataAvailable)
                {
                    //同步读取网络流中的byte信息
                    //do
                    //{
                    //    ns.Read(buffer, 0, bufferlength);
                    //} while (ns.Length > 0);
                    string s = br.ReadString();
                    bool b = br.ReadBoolean();


                    // byte[] dataArray = br.ReadBytes(100000); //这里长度不对的话,会报错。


                    br.BaseStream.BeginRead(buffer, 0, bufferlength, ReadAsyncCallBack, null);

                    //byte[] dataArray = br.ReadBytes(br.BaseStream.ReadByte()); //这里长度不对的话,会报错。

                    //string sb = Encoding.Default.GetString(dataArray, 0, dataArray.Length);
                    //异步读取网络流中的byte信息
                    //ns.BeginRead(buffer, 0, bufferlength, ReadAsyncCallBack, null);
                }
            }
        }

        /// <summary>
        /// 异步读取
        /// </summary>
        /// <param name="result"></param>
        static void ReadAsyncCallBack(IAsyncResult result)
        {
            int readCount;
            //获得每次异步读取数量
            readCount = client.GetStream().EndRead(result);
            //如果全部读完退出,垃圾回收
            if (readCount < 1)
            {
                client.Close();
                ns.Dispose();
                fs.Dispose();
                return;
            }
            //将网络流中的图片数据片段顺序写入本地
            fs.Write(buffer, 0, 200);
            //再次异步读取
            //ns.BeginRead(buffer, 0, 200, ReadAsyncCallBack, null);

            br.BaseStream.BeginRead(buffer, 0, 200, ReadAsyncCallBack, null);
        }
    }
}

客户端:

using System;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;

namespace ConsoleApp1
{
    class Program
    {
        /// <summary>
        /// 客户端
        /// </summary>
        /// <param name="args"></param>
        static void Main(string[] args)
        {
            SendImageToServer(@"D:\demo\1\1.jpg");
        }

        static void SendImageToServer(string imgURl)
        {
            if (!File.Exists(imgURl)) return;
            //创建一个文件流打开图片
            FileStream fs = File.Open(imgURl, FileMode.Open);
            //声明一个byte数组接受图片byte信息
            byte[] fileBytes = new byte[fs.Length];
            using (fs)
            {
                //将图片byte信息读入byte数组中
                fs.Read(fileBytes, 0, fileBytes.Length);
                fs.Close();
            }
            //找到服务器的IP地址
            IPAddress address = IPAddress.Parse("127.0.0.1");
            //创建TcpClient对象实现与服务器的连接
            TcpClient client = new TcpClient();
            //连接服务器
            client.Connect(address, 8083);
            using (client)
            {
                //连接完服务器后便在客户端和服务端之间产生一个流的通道
                NetworkStream ns = client.GetStream();
                 BinaryWriter bw;
                using (ns)
                {
                    bw = new BinaryWriter(ns);
                    //通过此通道将图片数据写入网络流,传向服务器端接收
                    bw.Write("123");
                    bw.Write(false);


                    //StringBuilder sb1 = new StringBuilder();
                    //sb1.Append("456");
                    //byte[] dataArray = Encoding.Default.GetBytes(sb1.ToString());
                    //bw.Write(dataArray,0, dataArray.Length);

                    bw.Write(fileBytes, 0, fileBytes.Length);
                    //ns.Write(fileBytes, 0, fileBytes.Length);
                    //ns.Write("123");
                }
            }
        }
    }
}

文字使用br.ReadString()传递。

图片使用数组字节传递

 byte[] data = ImageToByte(pictureBox1.Image);

                //对原始的数据数组加上协议的头部字节
                byte[] result = new byte[data.Length + 1];

                //设置当前的协议头部字节是1:代表字符串
                result[0] = 3;                                      //发送

                //把原始的数据放到最终的字节数组里去
                Buffer.BlockCopy(data, 0, result, 1, data.Length);

                ClientSocekt.Send(result, 0, result.Length, SocketFlags.None);

拓展

上面可能有些复杂,下面使用简易方式分别表示TcpListene和TCP

TcpListene进行通信

服务端

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace tcplistener服务端
{
    class Program
    {
        static void Main(string[] args)
        {
            //1,TcpListener对socket进行了一层封装,这个类里面自己会去创建socket对象
            TcpListener listener = new TcpListener(IPAddress.Parse("127.0.0.1"), 7788);

            //2,开始进行监听
            listener.Start();

            //3,等待客户端连接过来
            TcpClient client = listener.AcceptTcpClient();

            //4,取得客户端发送过来的数据
            NetworkStream stream = client.GetStream();//得到了一个网络流  从这个网络流可以取得客户端发送过来的数据

            byte[] data = new byte[1024];//创建一个数据的容器,用来承接数据,此处有大小限制

            Thread t1 = new Thread(()=>ReadMsg(stream, data));    //开启线程读取消息
            t1.Start();

            Thread t2 = new Thread(()=>SendMsg(stream));    //开始线程发送消息
            t2.Start();


            //stream.Close();
            //client.Close();
            //listener.Stop();//停止监听
            //Console.ReadKey();


        }

        private static void SendMsg(NetworkStream stream)
        {
            while (true)
            {
                string message = Console.ReadLine();
                byte[] data = Encoding.UTF8.GetBytes(message);
                stream.Write(data, 0, data.Length);
            }
        }

        private static void ReadMsg(NetworkStream stream, byte[] data)
        {
            while (true)
            {
                //0 表示从数组的哪个索引开始存放数据
                //1024表示最大读取的字节数
                int length =   stream.Read(data, 0, 1024);//读取数据
                string message = Encoding.UTF8.GetString(data, 0, length);
                Console.WriteLine("收到了消息:" + message);
            }
        }
    }
}

客户端

using System;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace tcplistener客户端
{
    class Program
    {
        static void Main(string[] args)
        {
            //当我们创建tcpclient对象的时候,就会跟server去建立连接
            TcpClient client = new TcpClient("127.0.0.1", 7788);

            NetworkStream stream = client.GetStream();//通过网络流进行数据的交换
            //ReadLine用来读取数据,write用来写入数据其实就是发送数据
            //利用一个死循环,重复向服务器端发送数据
            Thread thread = new Thread(()=>SendMsg(stream));    //开启发送消息
            thread.Start( );

            byte[] data = new byte[1024];//创建一个数据的容器,用来承接数据
            Thread t1 = new Thread(() => ReadMsg(stream, data));    //开启读取消息
            t1.Start();


            //stream.Close();
            //client.Close();
            //Console.ReadKey();

        }

        private static void ReadMsg(NetworkStream stream, byte[] data)
        {
            while (true)
            {
                //0 表示从数组的哪个索引开始存放数据
                //1024表示最大读取的字节数
                int length = stream.Read(data, 0, 1024);//读取数据
                string message = Encoding.UTF8.GetString(data, 0, length);
                Console.WriteLine("收到了消息:" + message);
            }
        }

        private static void SendMsg(NetworkStream stream)
        {
            while (true)
            {
                string message = Console.ReadLine();
                byte[] data = Encoding.UTF8.GetBytes(message);
                stream.Write(data, 0, data.Length);
            }
        }
    }
}

 效果

C#使用TCP进行聊天通信(详细解析)

TCP进行通信

服务端

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace ConsoleApp4
{
    class Program
    {
        static void Main(string[] args)
        {
            //1、创建socket
            Socket tcpServer = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            //2、绑定ip跟端口号 127.0.0.1
            IPAddress ipaddress = IPAddress.Parse("127.0.0.1");
            //ipendpoint是对ip+端口做了一层封装的类
            EndPoint point = new IPEndPoint(ipaddress, 8090);
            //3、向操作系统申请一个可用的ip跟端口号 用来做通信
            tcpServer.Bind(point);
            //4、开始监听 (等待客户端连接)
            tcpServer.Listen(100);//参数是最大连接数
            Console.WriteLine("开始监听");

            //暂停当前线程,直到有一个客户端连接过来,之后进行下面的代码
            Socket clientSocket = tcpServer.Accept();
            //Console.WriteLine("一个客户端连接过来了");
            //使用返回的socket跟客户端做通信
            //string message = "hello 欢迎你";
            //byte[] data = Encoding.UTF8.GetBytes(message);//对字符串做编码,得到一个字符串的字节数组
            //clientSocket.Send(data);
            //Console.WriteLine("向客户端发送了一跳数据");

            byte[] data2 = new byte[1024];//创建一个字节数组用来当做容器,去承接客户端发送过来的数据

            Thread t1 = new Thread(() => ReadMsg(clientSocket, data2));    //开启线程读取消息
            t1.Start();

            Thread t2 = new Thread(() => SendMsg(clientSocket ));    //开启线程读取消息
            t2.Start();

            //int length = clientSocket.Receive(data2);
            //string message2 = Encoding.UTF8.GetString(data2, 0, length);//把字节数据转化成 一个字符串
            //Console.WriteLine("接收到了一个从客户端发送过来的消息:" + message2);

            //Console.ReadKey();


        }

        private static void SendMsg(Socket clientSocket )
        {
            while (true)
            {
                string message = Console.ReadLine();//读取用户的输入 把输入发送到服务器端
                byte[] data = Encoding.UTF8.GetBytes(message);//对字符串做编码,得到一个字符串的字节数组
                clientSocket.Send(data);
                //Console.WriteLine("向客户端发送了一跳数据");
            }
        }

        private static void ReadMsg(Socket clientSocket, byte[] data2)
        {
            while (true)
            {
                int length = clientSocket.Receive(data2);
                string message2 = Encoding.UTF8.GetString(data2, 0, length);//把字节数据转化成 一个字符串
                Console.WriteLine("收到了消息:" + message2);
            }
        }
    }
}

客户端

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;

namespace ConsoleApp1
{
    class Program
    {
        static void Main(string[] args)
        {
            //1,创建socket
            Socket tcpClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            //2,发起建立连接的请求
            IPAddress ipaddress = IPAddress.Parse("127.0.0.1");//可以把一个字符串的ip地址转化成一个ipaddress的对象
            EndPoint point = new IPEndPoint(ipaddress, 8090);
            tcpClient.Connect(point);//通过ip:端口号 定位一个要连接到的服务器端

            byte[] data = new byte[1024];
            //int length = tcpClient.Receive(data);//这里传递一个byte数组,实际上这个data数组用来接收数据
            length返回值表示接收了多少字节的数据
            //string message = Encoding.UTF8.GetString(data, 0, length);//只把接收到的数据做一个转化
            //Console.WriteLine(message);

            Thread thread = new Thread(() => SendMsg(tcpClient));    //开启发送消息
            thread.Start();

            Thread t1 = new Thread(() => ReadMsg(tcpClient, data));    //开启线程读取消息
            t1.Start();


            //Console.ReadKey();

        }

        private static void ReadMsg(Socket tcpClient, byte[] data2)
        {
            while (true)
            {
                int length = tcpClient.Receive(data2);
                string message2 = Encoding.UTF8.GetString(data2, 0, length);//把字节数据转化成 一个字符串
                Console.WriteLine("收到了消息:"+message2);
            }
        }

        private static void SendMsg(Socket tcpClient)
        {
            while (true)
            {
                //向服务器端发送消息
                string message2 = Console.ReadLine();//读取用户的输入 把输入发送到服务器端
                tcpClient.Send(Encoding.UTF8.GetBytes(message2));//把字符串转化成字节数组,然后发送到服务器端
            }
        }
    }
}

效果

C#使用TCP进行聊天通信(详细解析)

 两者区别不大,主要是NetworkStream类的使用。

来源:C#使用TCP进行聊天通信(详细解析)_c# tcp通信_故里2130的博客-CSDN博客文章来源地址https://www.toymoban.com/news/detail-440154.html

到了这里,关于C#使用TCP进行聊天通信(详细解析)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 使用Linux系统IO多路复用中eopll创建基于TCP通信协议的多人聊天室

    一.1.搭建好TCP的通信模型 2.创建红黑树根节点 3.将套接字事件添加到红黑树中,使其被监听 4.当套接字事件发生,表示有客户端连接,将连接事件加入到红黑树节点当中 5.每当连接事件发生时,表示客户端发送信息到服务器 6.每当有事件准备就绪时,将对应的红黑树节点信息

    2024年02月13日
    浏览(45)
  • C# 使用UDP进行网络通信

           在选择使用协议的时候,选择UDP必须要谨慎。在网络质量令人十分不满意的环境下,UDP协议数据包丢失会比较严重。但是由于UDP的特性:它不属于连接型协议,因而具有资源消耗小,处理速度快的优点,所以通常音频、视频和普通数据在传送时使用UDP较多,因为它们即

    2024年02月12日
    浏览(41)
  • python使用pymodbus库进行modbus tcp通信

    使用python解决工业通信问题是一个非常好的选择,python具有丰富的生态,可以轻松解决工业通信的各种问题。本篇主要介绍使用pymodbus库进行modbus tcp仿真,实现pc端读取plc或工业设备modbus变量。 安装pymodbus: 这里我们先创建一个虚拟的modbus设备,如果你手里有一个plc或者工业

    2024年01月22日
    浏览(60)
  • 利用python进行TCP通信接收数据进行处理,使用队列来存放接收的数据

            在上面的程序中,我们创建了一个队列 data_queue 来存放接收到的数据,并使用Python的socket模块创建了一个TCP服务器套接字 server_socket 。当有客户端连接请求时,程序会创建一个新线程来处理客户端请求,并在处理函数 handle_client 中将接收到的数据放入队列中。  

    2024年02月13日
    浏览(42)
  • C# | 使用AutoResetEvent和ManualResetEvent进行线程同步和通信

    使用AutoResetEvent和ManualResetEvent进行线程同步和通信 文章目录 使用AutoResetEvent和ManualResetEvent进行线程同步和通信 介绍 AutoResetEvent ManualResetEvent 异同点 使用场景和代码示例 AutoResetEvent 使用示例 ManualResetEvent 使用示例 阻塞多个线程并同时激活 介绍 在多线程编程中,AutoResetEven

    2024年02月20日
    浏览(40)
  • c#如何使用 USB(Universal Serial Bus)进行通信

    在C#中,可以使用System.Management命名空间下的ManagementObjectSearcher和ManagementObject类,通过WMI(Windows Management Instrumentation)API来实现USB通信。这种方式可以通过USB设备的设备ID、厂商ID等信息来寻找并打开USB设备,并进行数据读写。 以下是一个简单的USB通信示例代码:

    2024年02月02日
    浏览(45)
  • C# 使用NModbus4进行TCP读取,并且实现自动断线重连

    C# 使用NModbus4进行TCP读取,并且实现自动断线重连

    2024年02月09日
    浏览(46)
  • QT C++ 基于TCP通信的网络聊天室

    .ui .pro 在pro文件中添加network库 .h .main .cpp .ui .pro 在pro文件中添加network库 .h .main .cpp        

    2024年02月09日
    浏览(60)
  • Canoe CAPL语言实现TCP连接与通信流程(TCP相关API函数详细使用)

    本文主要讲解CAPL语言里是如何实现TCP连接通信的,所以在本文开始前需要一些前期准备。 1、 首先是需要了解TCP的报文格式,连接三次握手,断开连接四次挥手的相关知识,推荐以下两位博主文章。 深入浅出TCP三次握手 (多图详解) 两张动图-彻底明白TCP的三次握手与四次

    2024年02月07日
    浏览(238)
  • 【Unity】Socket网络通信(TCP) - 实现简单的多人聊天功能

    多客户端连接服务器其原理是在服务端保存客户端连入后与客户端通信的socket,由于等待客户端连接会阻塞主线程,所以结合多线程就能实现多客户端连入功能。多人聊天只需要将A客户端发来的消息,转发给除A客户端外的其他客户端,即可实现。如果你还不怎么熟悉服务端

    2024年02月03日
    浏览(64)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包