lsp 0.1.1

客户端

importsocketfromlspimportConnection,NEED_DATA,DataReceived,MessageEndsock=socket.socket()sock.connect(("localhost",10001))conn=Connection("client")answer=input("Send request?(y/n)")whileanswer=="y":# use connection send_json method to convert json object to bytesrequest_data=conn.send_json({"method":"didOpen"})# then we can send data to serversock.sendall(request_data)whileTrue:# and then we can get next_event of connection, it can indicate# that what should we do.event=conn.next_event()# we need to receive data from serverifeventisNEED_DATA:try:data=sock.recv(1024)exceptConnectionResetError:print('The server connection is closed, So I will leave:)')conn.close()sock.close()exit(0)else:print("return from sock.recv")conn.receive(data)# we have receive data from serverelifisinstance(event,DataReceived):print("Receive event, content:")print(event)elifisinstance(event,MessageEnd):print("Server sending data complete.")break# then we can call get_received_data() to extract out what we getheader,response_body=conn.get_received_data()print("Response header from server:")print(header)print("Response body from server:")print(response_body)answer=input("Send request?(y/n)")conn.go_next_circle()

服务器端

importsocketfromlspimportConnection,NEED_DATA,RequestReceived,DataReceived,MessageEndsock=socket.socket()sock.bind(("0.0.0.0",10001))sock.listen(1)client_sock,addr=sock.accept()print(f"get connection from {client_sock}")conn=Connection("server")try:whileTrue:whileTrue:# call next event to indicate what server socket should do.event=conn.next_event()# no data coming yet, so the return value is NEED_DATAifeventisNEED_DATA:data=client_sock.recv(1024)ifdata==b"":print("Client connection is closed, I will exit.")exit(0)conn.receive(data)# Request header is coming :)elifisinstance(event,RequestReceived):print("Receive request header")print(event.to_data())# Request data is coming :)elifisinstance(event,DataReceived):print("Receive request data")print(event.to_data())# client has send data completely.elifisinstance(event,MessageEnd):print("Data receive complete:)")break# so we can call con.get_received_data to fetch what client send.received_data=conn.get_received_data()print(f"Receiving data: {received_data}")# send response back to client.print(f"Sending response to client")data=conn.send_json({"Content":"I am received:)"})client_sock.sendall(data)print(f"For now, go to next circle")# then we need to call go_next_circle, to get another request from client.conn.go_next_circle()finally:sock.close()

有关更多用法示例，请签出examples/servers文件夹中的文件。

客户

客户端将从下一个事件中获取以下值：

1. 需要数据-这表示我们需要从服务器接收数据。
2. responseReceived-客户端有接收响应头。
3. datareceived-客户端已接收respone正文。
4. messageend-从服务器接收数据完成。

服务器

服务器端将从下一个事件中获取以下值：

1. 需要数据-这表示我们需要从客户端接收数据。
2. requestReceived-客户端有发送请求头，我们接收它。
3. datareceived-服务器从客户端接收响应正文。
4. messageend-客户端发送请求完成。