TCP 服务端

服务端结构：

tcps = socket() #创建服务器套接字
tcps.bind()      #把地址绑定到套接字
tcps.listen()      #监听链接
while True:      #服务器无限循环
    tcpc = tcps.accept() #接受客户端链接
    while True:         #通讯循环
        tcpc.recv()/tcpc.send() #对话(接收与发送)
    tcpc.close()    #关闭客户端套接字
tcps.close()        #关闭服务器套接字(可选)

时间戳服务端实例：

#!/usr/bin/python3
# -*-coding:utf-8 -*-
from socket import *
import time
COD = 'utf-8'
HOST = '192.168.164.141' # 主机ip
PORT = 21566 # 软件端口号
BUFSIZ = 1024
ADDR = (HOST, PORT)
SIZE = 10 
tcpS = socket(AF_INET, SOCK_STREAM) # 创建socket对象
tcpS.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #加入socket配置，重用ip和端口
tcpS.bind(ADDR) # 绑定ip端口号
tcpS.listen(SIZE)  # 设置最大链接数
while True:
    print("服务器启动，监听客户端链接")
    conn, addr = tcpS.accept() 
    print("链接的客户端", addr)
    while True:
        try:
            data = conn.recv(BUFSIZ) # 读取已链接客户的发送的消息
        except Exception:
            print("断开的客户端", addr)
            break
        print("客户端发送的内容:",data.decode(COD))
        if not data:
            break
        msg = time.strftime("%Y-%m-%d %X") #获取结构化事件戳
        msg1 = '[%s]:%s' % (msg, data.decode(COD))
        conn.send(msg1.encode(COD)) #发送消息给已链接客户端
    conn.close() #关闭客户端链接
tcpS.closel()

用socket实现的一个简易聊天室功能，支持@用户私聊。

服务端代码：

import socket
import threading

# 客户端地址 名称
addr_name = {}

# 所有客户端
all_clients = []

# 名称 客户端
name_client = {}

server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

host = socket.gethostname()

port = 9999

server.bind((host, port))

server.listen(5)

lock = threading.Lock()

print("开启聊天室")


def handle_sock(sock, addr):
    while True:
        try:
            data = sock.recv(1024)
            msg = data.decode("utf-8")
            print("send msg")
            from_name = addr_name[str(addr)]
            if msg.startswith('@'):
                index = msg.index(' ')
                # 私聊人                
                to_name = msg[1:index]
                # 接收者客户端               
                to_sock = name_client[to_name]
                # 发送的消息                
                to_msg = msg[index:]
                send_one(to_sock, addr, from_name + ":" + to_msg)
            else:
                # 群发消息                
                send_all(all_clients, addr, from_name + ":" + msg)
        except ConnectionResetError:
            exit_name = addr_name[str(addr)]
            exit_client = name_client[exit_name]
            all_clients.remove(exit_client)
            msg = exit_name + " 退出了群聊"           
            send_all(all_clients, addr, msg)
            break


def send_all(socks, addr, msg):
    for sock in socks:
        sock.send(msg.encode("utf-8"))


def send_one(sock, addr, msg):
    sock.send(msg.encode("utf-8"))


while True:
    sock, addr = server.accept()
    name = sock.recv(1024).decode("utf-8")
    addr_name[str(addr)] = name
    name_client[name] = sock
    all_clients.append(sock)
    hello = name + "加入了聊天室"    
    send_all(all_clients, addr, hello)
    client_thread = threading.Thread(target=handle_sock, args=(sock, addr))
    client_thread.start()

客户端代码：

import socket
import threading

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

host = socket.gethostname()

port = 9999s.connect((host, port))
name = "cc"
s.send(name.encode("utf-8"))


def receive_handle(sock, addr):
    while True:
        data = sock.recv(1024)
        print(data.decode("utf-8"))

# 开启线程监听接收消息
receive_thread = threading.Thread(target=receive_handle, args=(s, '1'))
receive_thread.start()

while True:
    re_data = input()
    s.send(re_data.encode("utf-8"))