企业官网建设流程全解析

（一）TCP、poll、epoll

TCP（传输控制协议）

• 是什么：TCP 是一种面向连接、可靠的网络传输协议。它把要发送的大块数据切成一个个“小段”（称为报文段），并在发送前为每段加上序号。接收方收到后会给发送方回送确认（ACK），如果发送方在一定时间内没有收到确认，就会重新发送该段。
• 通俗比喻：想象你在写信寄快递，每封信都有编号，收件人收到后会回一张收据。如果寄出的信件丢了，你会再寄一遍，直到收到收据为止。
• 开发实例：在 C/C++ 中使用socket()、connect()、send()、recv()等系统调用即可实现基于 TCP 的客户端/服务器。例如，一个最简单的回显服务器会在recv()读取到客户端发来的数据后，直接用send()把相同的数据返回给客户端。

poll（轮询）

• 是什么：poll是一种I/O 多路复用的系统调用。它让一个进程一次性监视多个文件描述符（如套接字、管道、文件等）的状态（是否可读、可写、异常等），并在有任意一个描述符准备好时返回。
• 通俗比喻：想象你是老师，要检查一堆学生的作业是否完成。你一次性把所有作业本都摆在桌子上，等到有学生把作业交上来，你立刻看到并批改，而不必一个一个去叫学生。
• 开发实例：在 Linux 下，使用struct pollfd数组把所有要监听的套接字放进去，然后调用poll(pfds, nfds, timeout)。返回后遍历数组，找到revents标记为可读或可写的套接字进行相应的recv()/send()操作。

  structpollfdfds[2];fds[0].fd=listen_fd;// 监听套接字fds[0].events=POLLIN;// 关注可读事件（新连接）fds[1].fd=client_fd;// 已连接的客户端fds[1].events=POLLIN;// 关注可读事件（收到数据）intret=poll(fds,2,-1);// 阻塞等待if(fds[0].revents&POLLIN){/* accept new connection */}if(fds[1].revents&POLLIN){/* recv data */}

epoll（高效的 I/O 多路复用）

• 是什么：epoll是 Linux 为了解决poll/select在大规模并发场景下性能瓶颈而推出的专用机制。它采用事件驱动的方式，只在真正有状态变化的文件描述符上触发回调，避免每次轮询都遍历全部描述符。
• 通俗比喻：继续老师的例子。如果班里有几千名学生，你不可能每次都把所有作业本都搬到桌子上检查。于是你让每个学生在作业完成后主动把作业本递到老师面前，老师只需要处理递来的作业本，效率大大提升。
• 开发实例：使用epoll_create1()创建 epoll 实例，epoll_ctl()把感兴趣的套接字加入（或删除）监视集合，epoll_wait()阻塞等待事件。返回的事件数组只包含真正有活动的套接字。

  intefd=epoll_create1(0);structepoll_eventev,events[10];ev.events=EPOLLIN;// 关注可读事件ev.data.fd=listen_fd;epoll_ctl(efd,EPOLL_CTL_ADD,listen_fd,&ev);while(1){intn=epoll_wait(efd,events,10,-1);for(inti=0;i<n;++i){if(events[i].data.fd==listen_fd){// 有新连接intconn=accept(listen_fd,NULL,NULL);ev.events=EPOLLIN;ev.data.fd=conn;epoll_ctl(efd,EPOLL_CTL_ADD,conn,&ev);}else{// 已连接的客户端有数据可读charbuf[1024];ssize_tcnt=read(events[i].data.fd,buf,sizeof(buf));// 处理数据...}}}

小结

（二）TCP、http、sse、wss、mqtt通讯协议对比

一、基本概念（通俗版）

二、技术对比与选型指南

1. 传输可靠性 vs 交互模式

   • TCP提供可靠的点对点传输，是所有上层协议（HTTP、WebSocket、MQTT）的基石。
   • HTTP只负责一次请求‑响应，适合“拉取”数据的场景。
   • SSE在 HTTP 长连接上实现单向推送，代码只需在浏览器端new EventSource(url)，不需要自己维护心跳或重连逻辑。
   • WebSocket / WSS实现全双工通信，客户端new WebSocket(url)，服务器可以随时主动发送，也能随时接收客户端消息。
   • MQTT采用发布‑订阅模型，客户端不直接相互通信，而是通过 Broker 进行主题（topic）转发，天然支持多对多广播。

2. 性能与资源消耗

   • SSE只支持文本（JSON）数据，协议开销极小，适合数千级别的单向推送[[6]]。
   • WebSocket（WSS）在保持一个 TCP 连接的前提下，能够以毫秒级延迟双向传输，适合高频交互（聊天、游戏）[[7]]。
   • MQTT报文头只有 2‑4 字节，QoS 机制可以在网络不佳时自动重传或丢弃，极其适合成千上万的物联网设备[[8]]。

3. 安全性

   • HTTP→HTTPS（TLS）可加密；WebSocket→WSS同理，使用wss://即可在传输层提供加密[[9]]。
   • SSE也可以通过 HTTPS（https://）实现加密，只是协议本身不自带加密层。
   • MQTT支持基于 TLS 的MQTTS（mqtts://），在需要机密传输的工业场景中常用。

4. 典型开发示例（代码片段）

   • TCP（C）

     intsock=socket(AF_INET,SOCK_STREAM,0);connect(sock,(structsockaddr*)&addr,sizeof(addr));send(sock,"hello",5,0);recv(sock,buf,sizeof(buf),0);close(sock);

   • HTTP（curl）

     curl-X GET https://api.example.com/users

   • SSE（浏览器）

     constes=newEventSource('/sse/price');es.onmessage=e=>console.log('price:',e.data);

   • WebSocket / WSS（浏览器）

     constws=newWebSocket('wss://chat.example.com');ws.onopen=()=>ws.send(JSON.stringify({type:'join',room:1}));ws.onmessage=e=>console.log('msg:',e.data);

   • MQTT（JavaScript Paho）

     constclient=newPaho.MQTT.Client('broker.example.com',8883,'web_'+Math.random());client.connect({useSSL:true,onSuccess:()=>{client.subscribe('sensor/+/temp');}});client.onMessageArrived=msg=>console.log(msg.topic,msg.payloadString);

5. 选型小结

三、总结

• TCP是所有网络通信的可靠基石。
• HTTP基于 TCP，适合一次性请求‑响应。
• SSE在 HTTP 长连接上实现单向推送，代码最简。
• WSS是加密版 WebSocket，提供全双工实时通信并保证安全。
• MQTT采用轻量的发布‑订阅模型，专为海量物联网设备设计。

根据业务需求（单向推送 vs 双向交互、设备规模、带宽限制、安全要求），在上述协议中挑选最合适的即可实现高效、可靠的网络通信。

（三）python实现示例

一、TCP（传输控制协议）

• 概念：TCP 是面向连接、可靠的传输层协议。发送方把要发送的字节流切成若干报文段，每段都有序号；接收方收到后会回送ACK（确认），发送方若在超时时间内未收到 ACK 就会重新发送该段。这样可以保证数据不丢失、顺序不乱。
• Python 示例（客户端）

fromsocketimport*server_name='127.0.0.1'# 服务器 IPserver_port=12000# 服务器端口client=socket(AF_INET,SOCK_STREAM)client.connect((server_name,server_port))msg=input('输入一句话：')client.send(msg.encode())# 发送reply=client.recv(1024).decode()# 接收print('服务器返回：',reply)client.close()

• Python 示例（服务器）

fromsocketimport*PORT=12000server=socket(AF_INET,SOCK_STREAM)server.bind(('',PORT))# 监听所有网卡server.listen(1)print('服务器已启动，等待连接…')whileTrue:conn,addr=server.accept()data=conn.recv(1024).decode()conn.send(data.upper().encode())# 把收到的内容转成大写再回传conn.close()

二、poll 与 epoll（I/O 多路复用）

• poll：一次性把多个文件描述符（套接字、文件等）放进pollfd数组，调用poll()后内核会检查哪些描述符已经准备好（可读、可写、异常），返回后只处理这些“活跃”的描述符。适用于几百到几千个连接，但每次调用都要遍历整个数组。
• epoll（Linux 专有）：采用事件驱动，只在真正有状态变化的描述符上触发回调，内部使用红黑树 + 双向链表，避免每次遍历，能够轻松支撑上万甚至上百万并发连接。

Python 示例（使用select.poll）

importsocket,select listen=socket.socket()listen.bind(('0.0.0.0',9000))listen.listen()poller=select.poll()poller.register(listen.fileno(),select.POLLIN)whileTrue:events=poller.poll()forfd,flaginevents:iffd==listen.fileno():conn,_=listen.accept()poller.register(conn.fileno(),select.POLLIN)else:conn=socket.fromfd(fd,socket.AF_INET,socket.SOCK_STREAM)data=conn.recv(1024)ifdata:conn.send(b'echo: '+data)else:# 客户端关闭poller.unregister(fd)conn.close()

Python 示例（使用select.epoll）

importsocket,select listen=socket.socket()listen.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)listen.bind(('0.0.0.0',9001))listen.listen()ep=select.epoll()ep.register(listen.fileno(),select.EPOLLIN)whileTrue:forfd,eventinep.poll():iffd==listen.fileno():conn,_=listen.accept()ep.register(conn.fileno(),select.EPOLLIN)else:conn=socket.fromfd(fd,socket.AF_INET,socket.SOCK_STREAM)data=conn.recv(1024)ifdata:conn.send(b'echo: '+data)else:ep.unregister(fd)conn.close()

三、HTTP（超文本传输协议）

• 概念：基于 TCP 的请求‑响应协议。客户端（浏览器或程序）发送GET/POST等请求，服务器返回状态码 + 报文体。在 AI 业务中常用来提供RESTful API，让前端或其他服务通过 HTTP 调用模型推理接口。
• Python 示例（Flask 简单 HTTP 服务）

fromflaskimportFlask,request,jsonify app=Flask(__name__)@app.route('/hello')defhello():name=request.args.get('name','World')returnf'Hello,{name}!'@app.route('/predict',methods=['POST'])defpredict():data=request.json# 前端发送的 JSON# 这里可以调用模型进行推理，示例直接回显result={'input':data,'output':'dummy_result'}returnjsonify(result)if__name__=='__main__':app.run(host='0.0.0.0',port=5000)# 运行在 5000 端口

四、SSE（Server‑Sent Events）

• 概念：在 HTTP 长连接上单向推送数据的技术。服务器端返回Content-Type: text/event-stream，随后不断发送data: ...\n\n格式的文本。浏览器端使用EventSource接收，适合实时监控、日志推送、股票行情等只需要服务器主动推送的场景。
• Python 示例（Flask 实现 SSE）

fromflaskimportFlask,Responseimporttime app=Flask(__name__)defevent_stream():i=0whileTrue:i+=1yieldf'data: 计数{i}\n\n'# 每秒推送一次time.sleep(1)@app.route('/counter')defcounter():returnResponse(event_stream(),mimetype='text/event-stream')if__name__=='__main__':app.run(threaded=True)# 必须开启多线程

• 浏览器端（HTML）（仅示例，实际使用时放在前端页面）

<script>constes=newEventSource('/counter');es.onmessage=e=>console.log('服务器推送：',e.data);</script>

五、WSS（WebSocket Secure）

• 概念：在 HTTP/HTTPS 端口上升级为全双工的WebSocket连接，ws://为明文，wss://为 TLS 加密版。建立一次握手后，客户端和服务器都可以随时主动发送二进制或文本帧，延迟通常在毫秒级。适用于聊天、实时协作、在线游戏、AI 推理流式返回（如 ChatGPT 的流式输出）。
• Python 示例（使用websockets库）

# server.pyimportasyncio,websocketsasyncdefecho(ws,path):asyncformsginws:awaitws.send(f'回显：{msg}')start_server=websockets.serve(echo,'0.0.0.0',8765,ssl=None)# 若要 wss，传入 ssl.SSLContextasyncio.get_event_loop().run_until_complete(start_server)asyncio.get_event_loop().run_forever()

# client.pyimportasyncio,websocketsasyncdefhello():asyncwithwebsockets.connect('ws://127.0.0.1:8765')asws:awaitws.send('你好，服务器')reply=awaitws.recv()print('服务器说：',reply)asyncio.get_event_loop().run_until_complete(hello())

如果需要wss（加密），只需在websockets.serve与websockets.connect中传入ssl参数，使用ssl.SSLContext加载证书即可。

六、MQTT（Message Queuing Telemetry Transport）

• 概念：轻量级的发布‑订阅协议，基于 TCP（可选 TLS）。客户端publish消息到某个topic，Broker 再把该 topic 的所有subscriber推送过去。报文头只有几字节，非常适合物联网、边缘设备、实时数据流。
• Python 示例（使用paho-mqtt）

# publisher.pyimportpaho.mqtt.clientasmqtt broker='broker.hivemq.com'# 公共测试 brokerclient=mqtt.Client()client.connect(broker,1883,60)client.publish('demo/temperature',payload='23.5',qos=0)print('已发布温度 23.5')client.disconnect()

# subscriber.pyimportpaho.mqtt.clientasmqttdefon_message(client,userdata,msg):print(f'收到主题{msg.topic}:{msg.payload.decode()}')broker='broker.hivemq.com'client=mqtt.Client()client.on_message=on_message client.connect(broker,1883,60)client.subscribe('demo/temperature')client.loop_forever()# 持续监听

• 适用场景：
  • TCP：需要可靠、顺序的数据传输（文件、数据库同步）。
  • poll/epoll：服务器需要同时管理大量长连接，epoll在高并发下性能最佳。
  • HTTP：一次性请求‑响应，适合REST API、模型推理的同步调用。
  • SSE：服务器单向推送实时更新，客户端不需要发送数据（如日志、监控面板）。
  • WSS：全双工、低延迟，适合聊天、协作编辑、流式 AI 输出。
  • MQTT：轻量、主题广播，适合IoT 设备、边缘计算、海量传感器数据。

小结（适用场景对照）

• 可靠点对点→TCP（如文件传输、远程调用）
• 大量并发、需要高效轮询→epoll（高并发 Web 服务、游戏服务器）
• 一次性请求‑响应→HTTP（RESTful API、模型同步推理）
• 服务器单向推送→SSE（实时监控、新闻推送）
• 全双工实时交互→WSS（聊天、协作、流式 AI）
• 轻量发布‑订阅→MQTT（物联网、传感器网络、实时数据分发）