Python学习笔记（七）

from socket import socket, AF_INET, SOCK_STREAM

##表示创建一个客户端的socket

client = socket(AF_INET, SOCK_STREAM) ##SOCK_STREAM --表示TCP； SOCK_DGRAM--表示UDP；

##定义一个连接的目标

con_address = ("IP地址",端口号)

##告诉客户端要连接的服务器的地址和端口号

client.connect(con_address)

##发送data

client.send("python学习笔记".encode("utf-8"))

##关闭
socket.close()

from socket import socket, AF_INET, SOCK_STREAM
##创建一个socket对象
server = socket(AF_INET, SOCK_STREAM)

##绑定端口号
server.bind("",端口号) ##第一个参数为空字符串时，表示本机的IP

##开启监听状态
server.listen(5)  ###参数为整型，表示消息可堆积的数量。

while true:
  socket, addr_info = server.accept() ##阻塞的，表示没有连接的时候，一直等待。返回值为socket 和 addr_info。wait for an incoming connection. Return a new socket representing the connection, and the address of the client. For IP sockets ,the address info is a pair (hostaddr,port).
  
  ##打印下
  print(socket, addr_info)
  
  ##读取接受到的信息
  recv_data = socket.recv(512).decode("utf-8")  ##512是我们定义的bufsize.这个方法返回的是bytes。
  print("{}发送过来的消息是:{}" .format(addr_info[0] , recv_data))

  ##关闭
  socket.close()

from socket import socket, AF_INET, SOCK_STREAM

##表示创建一个客户端的socket

client = socket(AF_INET, SOCK_STREAM) ##SOCK_STREAM --表示TCP； SOCK_DGRAM--表示UDP；

##定义一个连接的目标

con_address = ("IP地址",端口号)

##告诉客户端要连接的服务器的地址和端口号

client.connect(con_address)
while True:
  msg = input("客户端输入:")
  client.send(msg.encode("utf-8"))
  if msg == "byebye":
    break
  ##接受服务器端的msg
  recv_data = socket.recv(512).decode("utf-8")  ##512是我们定义的bufsize.这个方法返回的是bytes。
  print("服务器端发送过来的消息是:{}" .format(recv_data))
  if recv_data == "byebye":
    break
##关闭
socket.close()

from socket import socket, AF_INET, SOCK_STREAM
##创建一个socket对象
server = socket(AF_INET, SOCK_STREAM)

##绑定端口号
server.bind("",端口号) ##第一个参数为空字符串时，表示本机的IP

##开启监听状态
server.listen(5)  ###参数为整型，表示消息可堆积的数量。

while True:
  socket, addr_info = server.accept() ##阻塞的，
  while True: ###保证可以对多个客户端，不能因为一个客户端，关闭所有。
    ##读取接受到的信息
    recv_data = socket.recv(512).decode("utf-8")  
    print("客户端发送过来的消息是:{}" .format(recv_data))
    if recv_data == "byebye":  ##如果客户端说byebye,就退出
      break
    msg = input("服务器端输入:")
    socket.send(msg.encode("utf-8"))
    if msg == "byebye" : ##如果我们说了byebye,退出
      break  
  ##关闭
  socket.close()
  print(addr_info,"离开了!")

##服务器端，创建socket服务器

from socket import socket, AF_INET, SOCK_STREAM
from threading import Thread
##创建一个socket对象
server = socket(AF_INET, SOCK_STREAM)

##绑定端口号
server.bind("",端口号)##第一个参数为空字符串时，表示本机的IP

##开启监听状态
server.listen(5)  ###参数为整型，表示消息可堆积的数量

##任务
def send_msg(socket)
  while True:
    msg = input("输入要发送的消息:")
    socket.send(msg.encode("utf-8"))

def recv_msg(socket)
  while Ture:##可以持续收消息
    data=socket.recv(512).decode("utf-8")
    if len(data)==0:
      break
    print("收到客户端的消息是"，data)

while True:
  socket, addr_info = server.accept() ##阻塞的
  t_send = Thread(target=send_msg, args=(socket,))
  t_recv = Thread(target=recv_msg, args=(socket,))
  t_send.start()
  t_recv.start()

from socket import socket, AF_INET, SOCK_STREAM
from threading import Thread
##表示创建一个客户端的socket

client = socket(AF_INET, SOCK_STREAM) ##SOCK_STREAM --表示TCP； SOCK_DGRAM--表示UDP；

##定义一个连接的目标

con_address = ("IP地址",端口号)

##告诉客户端要连接的服务器的地址和端口号

client.connect(con_address)


##任务
def send_msg(socket)
  while True:
    msg = input("输入要发送的消息:")
    socket.send(msg.encode("utf-8"))

def recv_msg(socket)
  while Ture:##可以持续收消息
    data=socket.recv(512).decode("utf-8")
    if len(data)==0:
      break
    print("收到服务器端的消息是"，data)


t_send = Thread(target=send_msg, args=(client,))
t_recv = Thread(target=recv_msg, args=(client,))
t_send.start()
t_recv.start()

"""
cilent:浏览器客户端
浏览器发出请求（request），Server端返回响应（response）。
request 包含:request 行（里面有请求方法--get,协议--HTTP/1.1）、请求头【键值对】、请求体（POST请求时的数据）。
response 包含:response 行（里面有协议--HTTP/1.1，状态--例如200 ok）、响应头【键值对】、响应体（数据）。
"""


##服务器端，创建socket服务器
import gevent   ##导入协程的包
import gevent import monkey
##注意此时的socket 一定要来自gevent 的包,进行了继承和封装
##from socket import socket, AF_INET, SOCK_STREAM
from gevent import socket
from threading import Thread

monkey.patch_all()  

##创建一个socket对象
server = socket.socket()

##绑定端口号
server.bind("",端口号)---第一个参数为空字符串时，表示本机的IP

##开启监听状态
server.listen(5)  ###参数为整型，表示消息可堆积的数量

##处理客户端的访问
def handle_client(socket)
  recv_data = socket.recv(512).decode("utf-8")
  print(recv_data)

  ##每次访问返回的信息是
  
  msg ="欢迎来此访问！"
  ##格式化response,需要有响应行、响应头
  resp_line = "HTTP/1.1 200 OK
" ##
格式有换行要求
  resp_header = "Content-Type:text/html
charset=utf-8
Server:testServer
" 

  resp=  resp_line + resp_header +"
"+msg  ##拼凑完整的返回体。注意返回体结束结尾需是两个换行，添加一个

  socket.send(resp.encode("utf-8"))
  socket.colse() ##聊天结束

while True:
  socket, addr_info = server.accept()  
  print(addr_info,"请求访问！")
  gevent.spawn(handle_cilent,socket)