C# Socket通信 小案例

本文将编写2个控制台应用程序，一个是服务器端（server），一个是客户端（client），

通过server的监听，有新的client连接后，接收client发出的信息。

 

server代码如下：

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

namespace Server
{
    class Program
    {
        static void Main(string[] args)
        {
            Socket server = new Socket(
                //寻址方式，InterNetwork是指IPv4的方式
                AddressFamily.InterNetwork,
                //套接字类型，一般都是采取stream，即流的形式
                SocketType.Stream,
                //通信协议，这里使用TCP
                ProtocolType.Tcp
                );
            //绑定端口，参数是IP地址和端口号，IP地址即本机的IP地址，端口号则随便，只要不是已经被占用的即可
            server.Bind(new IPEndPoint(IPAddress.Parse("192.168.1.101"), 12312));
            //设置监听的client上限
            server.Listen(5);
            Console.WriteLine("server is listening");
            //用于接收client连接的线程
            Thread tAccept = new Thread(() =>
            {
                //使用死循环
                while (true)
                {
                    //接收
                    Socket client = server.Accept();
                    Console.WriteLine("new client is connection,ip is" + client.RemoteEndPoint);
                    //用于接收信息的线程
                    Thread tReceive = new Thread(() =>
                    {
                        while (true)
                        {
                            byte[] bs = new byte[1024];
                            //使用字节数组接收
                            int length = client.Receive(bs);
                            string str = Encoding.UTF8.GetString(bs);
                            Console.WriteLine(str);
                        }
                    }
                        );
                    tReceive.IsBackground = true;
                    tReceive.Start();
                }
            }
                );
            tAccept.IsBackground = true;
            tAccept.Start();
            Console.ReadKey();
        }
    }
}

 

client代码如下：

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

namespace Client
{
    class Program
    {
        static void Main(string[] args)
        {
            Socket client = new Socket(
                AddressFamily.InterNetwork,
                SocketType.Stream,
                ProtocolType.Tcp
                );
            client.Connect(new IPEndPoint(IPAddress.Parse("192.168.1.101"), 12312));
            while (true)
            {
                Console.Write("please type something：");
                string str = Console.ReadLine();
                if (str.Equals("quit"))
                {
                    break;
                }
                byte[] bs = Encoding.UTF8.GetBytes(str);
                client.Send(bs);
            }

            //关闭通信的方式，这里不需用，因为会引发异常
            //client.Close();
            //client.Shutdown(SocketShutdown.Both);
            Console.ReadKey();
        }
    }
}

 

运行：

1、先运行server；

2、再运行client，输入内容后，server会显示内容，输入“quit”则关闭通信连接。

完成