Socket简单实现ssh笔记

Scoket概念：
socket本质上就是在2台网络互通的电脑之间，架设一个通道，两台电脑通过这个通道来实现数据的互相传递。我们知道网络通信都是基于 ip+port 方能定位到目标的具体机器上的具体服务，操作系统有0-65535个端口，每个端口都可以独立对外提供服务，如果把一个公司比做一台电脑，那公司的总机号码就相当于ip地址，每个员工的分机号就相当于端口，你想找公司某个人，必须先打电话到总机，然后再转分机。建立一个socket必须至少有2端，一个服务端，一个客户端，服务端被动等待并接收请求，客户端主动发起请求，连接建立之后，双方可以互发数据。（利用IP和端口实现两个设备的通信）。

Socket核心方法:

接收端：
import socket
socket.TCP/IP
listen(ip,port)
waiting()#等待数据
recv()#接收数据
send()#再发送数据

发送端：
import socket
socket.TCP/IP
connect(a.ip,a.port)#接受端主机的IP,端口(port:端口号)
socket.send(hello)#发送的数据sendall()名义上是一次性发送所有的数据，但是由于系统原因还是有限制的
socket.recv()#接收数据
socket.close()#关闭

实例列举：

服务器端：
import socket
server=socket.socket()#设置连接
server.bind((“localhost”,8888))#绑定连接(参数是一个元组)
server.listen(5)#监听
conn,addr=server.accept()#等待
data=conn.recv(1024)#接收(是byte类型的，需要转换（一般编为utf-8）)
conn.sendall(data)#一次性发送所有数据（由于系统原因，是发送不了所有的数据的）
server.close()

客户端：
import socket
client=socket.socket()
client=connect((“localhost”,8888))#建立连接，参数是一个元组
data=input().strip()#手工输入的是unicode类型，但是再传输的时候是要编码的
client.send(data.encode(“utf-8”))#发送数据
data=client.recv(1024)#收到的数据是utf-8编码的，所以直接输出是乱码
client.close()

粘包：
当你连续的调用send()时，由于接收时recv()有大小限制，会发生发送的数据量大于接收的数据量，导致接收的数据不是你期待的数据，这个时候就发生了粘包（两次发送的数据被同一次接收）为了避免这种错误，我们通常会设计反馈，即你发送一次数据，我们会吧发送的数据反馈给发送给你。这样两次发送中间夹杂着一次接收，避免了数据在缓冲中导致粘包。
一些注意的地方：

发送与接收的类型：

我们在Python3中，默认是Unicode，而在发送数据（send）时,函数send()的参数类型是：Byte,所以我们要进行数据的转换：

数据的校验：

字符串类型的，我们可以利用hashlib包中的md5算法来检验

文件类型的，我们可以对比两个文件的区别：

SocketServer：

这个比较方便，它集成了一些东西，很方便的，只是server端改变了一下书写方式，客户端不用改变

代码如下：

#this is server
import socketserver
class MyTCPHandler(socketserver.BaseRequestHandler):#类名随意，但是继承的不能改变
    def handle(self):#系统会自动调用这个函数，我们只需要在这个函数中写我们要实现的方法就可以了
        while True:
            try:
                self.data=self.request.recv(1024).strip()
                print("{} wrote".format(self.client_address))
                print(self.data)
                self.request.send(self.data.upper())
            except ConnectionResetError as e:
                print("error: ",e)
                break
if __name__ =="__main__":
    HOST,PORT="localhost",9999#声明IP与端口
    server=socketserver.ThreadingTCPServer((HOST,PORT),MyTCPHandler)#设置连接
    server.serve_forever()#建立连接，然后系统在连接成功以后会自动调用函数handle()

#this is client
import socket
client=socket.socket()
client.connect(("localhost",9999))
while True:
    cmd=input(">>").strip()
    if cmd =="":
        continue
    client.send(cmd.encode())
    data=client.recv(1024)
    print(data)

附：

socket一个最简单的通信：

#服务器端：
import socket
server=socket.socket()
server.bind(("localhost",8888))
server.listen()
conn,addr=server.accept()
count=10
while count:
    data=conn.recv(1024)
    print(data.decode("utf-8"))
    conn.send(data)
    count-=1
server.close()

#客户端
import socket
client=socket.socket()
client.connect(("localhost",8888))
while True:
    chioce=input(">>").strip()
    client.sendall(chioce.encode("utf-8"))
    data=client.recv(1024)
    if not data:
        break
    print(data.decode("utf-8"))
client.close()

星辰点缀

Socket简单实现ssh笔记

Scoket概念：

Socket核心方法:

实例列举：

粘包：

一些注意的地方：

SocketServer：