3 篇笔记 写笔记

1. #0

   miss

   zho***[email protected]

   199

   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()

   miss

   zho***[email protected]

   7年前 (2019年07月27日)
2. #0

   miss

   zho***[email protected]

   153

   TCP 客户端

   客户端结构:

   tcpc = socket() # 创建客户端套接字
   tcpc.connect() # 尝试连接服务器
   while True: # 通讯循环
    tcpc.send()/tcpc.recv() # 对话(发送/接收)
   tcpc.close() # 关闭客户套接字

   时间戳客户端实例:

   #!/usr/bin/python3
   # -*-coding:utf-8 -*-
   from socket import *
   from time import ctime
   HOST = '192.168.164.141' #服务端ip
   PORT = 21566 #服务端端口号
   BUFSIZ = 1024
   ADDR = (HOST, PORT)
   tcpCliSock = socket(AF_INET, SOCK_STREAM) #创建socket对象
   tcpCliSock.connect(ADDR) #连接服务器
   while True:
    data = input('>>').strip()
    if not data:
    break
    tcpCliSock.send(data.encode('utf-8')) #发送消息
    data = tcpCliSock.recv(BUFSIZ) #读取消息
    if not data:
    break
    print(data.decode('utf-8'))
   tcpCliSock.close() #关闭客户端

   miss

   zho***[email protected]

   7年前 (2019年07月27日)
3. #0

   sean

   140***[email protected]

   42

   用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"))

   sean

   140***[email protected]

   5年前 (2021年06月24日)