你也可以写个聊天程序 - C# Socket学习1

简述

我们做软件工作的虽然每天都离不开网络，可网络协议细节却不是每个人都会接触和深入了解。我今天就来和大家一起学习下socket，并写一个简单的聊天程序。

一些基础类

首先我们每天打开浏览器访问网页信息都是使用的http/https协议，而http是通过的tcp建立的连接。tcp底层又是通过的socket套接字进行的通信。所以他们之间的抽象关系是：

我们在学习socket编程的时候可能会需要用到ipendpoint、dns、ipaddress等类，再往上tcp相关有tcplistener、tcpclient、networkstream，再往上就是大家熟悉的httpclient等。
ipendpoint、dns、ipaddress基础作用如下：

//根据dns获取域名绑定的ip
foreach (var address in dns.gethostentry("www.baidu.com").addresslist)
{
    console.writeline($"百度ip:{address}");
}

//字符串转ip地址
ipaddress ipaddress = ipaddress.parse("192.168.1.101");

//通过ip和端口构造ipendpoint对象，用于远程连接
//通过ip可以确定一台电脑，通过端口可以确定电脑上的一个程序
ipendpoint ipendpoint = new ipendpoint(ipaddress, 80);

利用socket编写聊天程序

我们首先从socket开始讲起。
要实现socket通信，先得有个服务端的监听，再有个客户端的连接，然后客户端和服务端就可以通信了。如下：

服务端代码如下：

//1 创建socket对象
socketserver = new socket(addressfamily.internetwork, sockettype.stream, protocoltype.tcp);

//2 绑定ip和端口
ipaddress ip = ipaddress.parse("127.0.0.1");
ipendpoint ipendpoint = new ipendpoint(ip, 50001);
socketserver.bind(ipendpoint);

//3、开启侦听(等待客户机发出的连接),并设置最大客户端连接数为10
socketserver.listen(10);

//4、【阻塞】，等待客户端连接
socket newsocket = socketserver.accept();

//5、【阻塞】，等待读取客户端发送过来的数据
byte[] data = new byte[1024 * 1024];
int readleng = newsocket.receive(data, 0, data.length, socketflags.none);

//6、读取数据
var msg = encoding.utf8.getstring(data, 0, readleng);

客户端代码如下：

//1 创建socket对象
socketclient = new socket(addressfamily.internetwork, sockettype.stream, protocoltype.tcp);

//2 连接到服务端
ipaddress ip = ipaddress.parse("127.0.0.1");
ipendpoint ipendpoint = new ipendpoint(ip, 50001);
socketclient.connect(ipendpoint);

//3 发送消息到服务端
socketclient.send(encoding.utf8.getbytes("你好，农码一生"));

到此，我们就可以开启服务端的服务，并接受客户端的发来的消息了。
不过，这里有个很大的问题，服务端只能建立一个客户端连接和接受一次客户端发来的消息。如果想要连接更多的客户端和接受无数次的消息，服务端代码两处阻塞的地方需要另外开一个线程然后包到循环里面去。
修改后的服务端代码如下：

void .... ()
{
    //1 创建socket对象
    socketserver = new socket(addressfamily.internetwork, sockettype.stream, protocoltype.tcp);
    
    //2 绑定ip和端口
    ipaddress ip = ipaddress.parse("127.0.0.1");
    ipendpoint ipendpoint = new ipendpoint(ip, 50001);
    socketserver.bind(ipendpoint);
    
    //3、开启侦听(等待客户机发出的连接),并设置最大客户端连接数为10
    socketserver.listen(10);
    
    //开启新的线程，循环等待新的客户端连接
    task.run(() => { accept(socketserver); });
}

void accept(socket socket)
{
    while (true)
    {
        //4、【阻塞】，等待客户端连接
        socket newsocket = socket.accept();
        
        //开启新的线程，循环等待接收新的数据
        task.run(() => { receive(newsocket); });
    }
}

void receive(socket newsocket)
{
    while (true)
    {
        //5、【阻塞】，等待读取客户端发送过来的数据
        byte[] data = new byte[1024 * 1024];
        int readleng = newsocket.receive(data, 0, data.length, socketflags.none);
        
        //6、读取数据
        var msg = encoding.utf8.getstring(data, 0, readleng); 
    }
} 

到此，服务端就可以接受多个客户端的连接和接收多次客户端发来的消息了。不过我们可能还需客服端能接收服务端发来的消息，这个你可以自己尝试下。文末会提供完整的代码参考。

注意：
用socket来编写聊天软件是长连接，有状态的。不确定服务端什么时候会发送消息过来，我们也可以连续发送消息而不响应。所以，对于消息的接收就需要开一个新的线程循环接收。
而对于http来说，虽然它是也是通过tcp建立的通信，但在数据请求完毕后会马上关闭连接，这个过程很短。每次访问都会建立一个新的连接，是无状态的。
对于浏览器来说是一问一答的形式，先发送请求（send），然后接收响应（receive）所以就可以做到不开启新的线程，直接有序的同步的完成。这个在下一篇《模拟浏览器的请求和服务端的响应》会具体分析。

利用tcp编写聊天程序

虽然上面我们利用socket类实现了一个简单的聊天程序，但是微软觉得socket太复杂。为了让你们早点干完活，早点下班，于是又在socket的基础上有封装了两个相关的类tcplistener、tcpclient。
利用tcplistener、tcpclient来实现同上面相同的功能。
服务端代码：

void ...()
{
    //1 开启监听
    tcplistener tcplistener = new tcplistener(ipaddress.parse("127.0.0.1"), 9999);
    tcplistener.start(10); //最多同时接收10个用户连接
    
    //开启一个线程，循环等待客户端的连接
    task.run(() => { accept(); });
}


//等待客户端的连接
void accept()
{
    while (true)
    {
        //2 【阻塞】等待客户端的连接
        tcpclient tcpclient = tcplistener.accepttcpclient();
        networkstream networkstream = tcpclient.getstream();
        
        //开启一个新的线程 等待新的消息
        task.run(() => { read(networkstream, tcpclient); });
    }
}

//接收消息
void read(networkstream networkstream)
{
    while (true)
    { 
        byte[] buffer = new byte[1024 * 1024];
        //3 【阻塞】等待接收新的消息
        var readlen = networkstream.read(buffer, 0, buffer.length);
        var msg  = encoding.utf8.getstring(buffer, 0, readlen); 
    }
}

客户端代码：

//1 连接服务端
tcpclient tcpclient = new tcpclient();
tcpclient.connect(ipaddress.parse(textbox1.text), int.parse(textbox2.text));

//2 发送消息到服务端
byte[] buffer = encoding.utf8.getbytes("你好，农码一生");
networkstream.write(buffer, 0, buffer.length);

用tcplistener、tcpclient的实现也算ok了，tcplistener代码写的服务端和socket通信也是完成没问题的，因为他们最后都是socket。
对此你有觉得比socket简单和容易理解？其实我更习惯socket。

注意：

// 1、断开连接使用
socketclient?.shutdown(socketshutdown.both);
socketclient?.close();

// 2、服务端需要判断
int readleng = newsocket.receive(data, 0, data.length, socketflags.none);
if (readleng == 0)//客户端断开连接
{
    //停止会话（禁用socket上的发送和接收，该方法允许socket对象一直等待，直到将内部缓冲区的数据发送完为止）
    newsocket.shutdown(socketshutdown.both);
    //关闭连接
    newsocket.close();
    //跳出循环
    return;
}

3、具体请参考文末提供的完整demo

效果图

结束

• 完整demo：https://github.com/zhaopeiym/blogdemocode/tree/master/socket编程
• 本文已同步至索引目录：《iotclient开发系列》
• 关于demo本来打算用.net core3.0来写的，可是winform的设计器不争气。所以demo还是用的.net fx，只有tcplistener是用的.net core控制台写的。
• 为什么要写这个，一是学习下底层的协议通信，二是为了实现一套物联网设备通讯协议做准备。类似这位大佬的hsl。