zoukankan      html  css  js  c++  java
  • socket实现文件间通信的基本流程

    #TCP协议实现(发送消息的顺序无要求)(以conn为对象发送和接收消息)(字节流)
    #-------serve层
    import socket
    import time
    sk=socket.socket()
    sk.bind(('10.70.2.143',8080))                       #1.服务器地址 2.服务器端口,0~65535范围,但是0~1023最好不要用
    sk.listen()                                         #监听连接(所有电话集中在这里)
    while 1:
        conn,addr=sk.accept()                           #conn为客户端的ip地址,addr为客户端的端口(开始一个一个循环接电话)
        while 1:
            str_msg=conn.recv(1024).decode('utf-8')     #1024为传递数据的大小,recv为需要和谁通信就用其recv,比如说和这个人通电话;中文解码
            print(str_msg)
            if str_msg == 'q':
                break;
            #服务器输入
            msg_s = input(">>>")
            conn.send(msg_s.encode('utf-8'))
            if msg_s == 'q':
                break;
        conn.close();                                   #可以理解为挂断这个人的电话,但是并不关闭服务器(进入下一个循环,即接听下一个电话)
    sk.close()                                          #关闭服务器(即使有其他电话打进来也毫无作用)
    
    
    
    #-------client层
    import socket
    sk = socket.socket()
    sk.connect(('10.70.2.143',8080))                        #1.服务器的IP 2.服务器的端口
    while 1:
        msg_s = input('>>>')
        sk.send(msg_s.encode('utf-8'))                      #传中文需要编码为utf-8格式
        if msg_s == 'q':
            break
        msg_r = sk.recv(1024).decode('utf-8')
        if msg_r == 'q':
            break
        print(msg_r)
    sk.close()
    
    #---------------------------------------------------------------------
    #UDP协议实现(必须是客户端先发消息)(以addr为对象发送和接收消息)(允许一个服务器同时和多个客户端通信)
    #-------server层
    import socket
    sk = socket.socket(type=socket.SOCK_DGRAM)# udp协议
    sk.bind(('10.70.2.143',8080))
    while 1:
        msg_r,addr = sk.recvfrom(1024)# 接收来自于哪里的消息
        print(msg_r.decode('utf-8'),addr)
        msg_s = input(('>>>'))
        sk.sendto(msg_s.encode('utf-8'),addr)# 发给谁的消息
    sk.close()
    
    
    
    #-------client层
    import socket
    sk = socket.socket(type=socket.SOCK_DGRAM)
    while 1:
        msg_s = input('>>>')
        sk.sendto(msg_s.encode('utf-8'),('10.70.2.143',8080))
        msg_r,addr = sk.recvfrom(1024)
        print(msg_r.decode('utf-8'))
    sk.close()
  • 相关阅读:
    操作系统之进程篇(3)
    指针和数组及内存管理
    进程篇(3: 基本进程控制:进程的退出)--请参照本博客“操作系统”专栏
    Java面向对象程序设计--泛型编程
    进程篇(1: 进程运行环境)--请参照本博客“操作系统”专栏
    操作系统之进程篇(1)
    分类器性能指标之ROC曲线、AUC值
    如何理解似然函数?
    sigmoid函数简介
    Hive分析窗口函数
  • 原文地址:https://www.cnblogs.com/god-for-speed/p/11719017.html
Copyright © 2011-2022 走看看