【过程记录】windows和ubuntu两台电脑局域网进行socket通信收发数据和传输文件

Love The Way You Lie 2022-10-12 04:25 125阅读 0赞

###  ###

*   *  实验图片和前期准备：
     *  ubuntu作为服务端，windows客户端传输数据和文件：
     *  windows作为服务端，ubuntu作为客户端：

--------------------

## 实验图片和前期准备： ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70]  
服务端发送和接受i：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70 1]  
客户端接收服务端的时间：  
![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70 2][]  
设备：  
自己的笔记本电脑和jetsonnano一台+显示屏  
同一个wifi 查看ubuntu和windows的ip地址  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70 3]

注意：windows和ubuntu关闭防火墙！

## ubuntu作为服务端，windows客户端传输数据和文件： ##

服务端用python（jetsonnano)  
客户端用java写:(自己笔记本）  
服务端接收到文件并输出：  
![在这里插入图片描述][20210703181922323.png]  
代码

from socket import *
    import time
    from time import ctime
    host='192.168.31.177'
    port=8189
    bufsiz=1024
    addr=(host,port)
    tcpServer=socket(AF_INET,SOCK_STREAM)
    tcpServer.bind(addr)
    tcpServer.listen(5)
    
    while True:
        print('wait for connection..')
        tcpCliServer,addr= tcpServer.accept()
        print('..connect from',addr)
        while True:
            data = tcpCliServer.recv(bufsiz).decode() #decode() 方法以 encoding 指定的编码格式解码字符串。默认编码为字符串编码。
            print(data)
    ##str.decode(encoding='UTF-8',errors='strict') errors -- 设置不同错误的处理方案。
            if data == "yes":
                print("yee!")
            if not data:
                break
            #tcpCliServer.send('[%s]%s' % (bytes(ctime(),'utf-8'),str.encode(data)))
            
            tcpCliServer.send(bytes(ctime(), 'utf-8'))
            tcpCliServer.send(bytes("nice", 'utf-8'))
            #time.sleep(2)
            tcpCliServer.send(bytes("nn",'utf-8'));
    
        tcpCliServer.close()
    
    tcpServer.close()

客户端接收到的：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70 4]

public static void main(String[]args) throws IOException { 
    /* UdpClient udpClient = new UdpClient(); try { udpClient.go(); }catch (Exception e){ System.out.println(e); }*/
    int i = 0;
            Socket socket = new Socket("192.168.31.177",8189);
            OutputStream outputStream = socket.getOutputStream();
    // OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputStream);
    // outputStreamWriter.write(String.valueOf("我是中国人".getBytes(StandardCharsets.UTF_8)));
    
    
    
            File file = new File("D:\\Inventory.txt");
            DataOutputStream dataInputStream= new DataOutputStream(outputStream);
            FileInputStream fileInputStream = new FileInputStream(file);
            byte[]bytes = new byte[1024];
            try{ 
    
    
                dataInputStream.writeUTF(file.getName());
                dataInputStream.flush();
                System.out.println("传输文件");
                int len=0;
                while ((len = fileInputStream.read(bytes,0,bytes.length)) != -1)
                { 
                    dataInputStream.write(bytes,0,bytes.length);
                    dataInputStream.flush();
                }
    
            }catch (Exception e){ 
                System.out.println(e);
            }
    
    
    
            InputStream inputStream = socket.getInputStream();
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
            outputStream.write("我是中国人yaoo".getBytes(StandardCharsets.UTF_8));
            char[] charArr = new char[1000];
            int readLen = -1;
    
            if((readLen = (inputStreamReader.read(charArr))) != -1) { 
                while (i < 5) { 
                    i++;
                    outputStream.write(("我是"+i).getBytes(StandardCharsets.UTF_8));
                    String newString = new String(charArr, 0, readLen);
                    System.out.println(newString);
                }
                dataInputStream.close();
                fileInputStream.close();
                outputStream.close();
                inputStream.close();
                socket.close();
            }
    
        }

## windows作为服务端，ubuntu作为客户端： ##

自己笔记本作为服务端：

public class BeginThread extends Thread{ 
        private Socket socket;
        public BeginThread(Socket socket)
        { 
            super();
            this.socket = socket;
        }
        @Override
        public void run(){ 
            try{ 
                InputStream inputStream = socket.getInputStream();
                InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
                char[] charArr = new char[1000];
                int readLen = -1;
                while((readLen = (inputStreamReader.read(charArr))) != -1)
                { 
                    String newString = new String(charArr,0,readLen);
                      if(newString.matches("yes!"))
                        System.out.println("成功收到来自客户端的数据");
                    System.out.println(newString);
                }
    
                inputStreamReader.close();
                inputStream.close();//关闭两个流
                socket.close();//关闭socket
            }catch (IOException e){ 
                e.printStackTrace();
            }
        }
    
    }
    
    public class Server{ 
     public static void main(String[] args) throws IOException { 
            ServerSocket socket = new ServerSocket(8888);
       int runTag = 1;
            while (runTag == 1)
            { 
                Socket socket1 = socket.accept();
                BeginThread beginThread = new BeginThread(socket1);
                beginThread.start();
            }
          socket.close();
    }

服务端接收到数据：  
![在这里插入图片描述][20210703182629683.png]

客户端：

import socket               # 导入 socket 模块
     
    s = socket.socket()         # 创建 socket 对象
    host = "192.168.31.131" # windows的ip
    port = 8888               # 设置端口号
     
    s.connect((host, port))
    s.send('yes!'.encode('utf-8'))	#发送 TCP 数据，将 string 中的数据发送到连接的套接字。返回值是要发送的字节数量，该数量可能小于 string 的字节大小。
    
    s.close()

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70]: /images/20221005/8fd5de25e3d84467901fd64455b36452.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70 1]: /images/20221005/fba6ab2459d44fb4b3c0efd271e67c15.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70 2]: /images/20221005/459dbf3a25d643c2a1a9022f87817d06.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70 3]: /images/20221005/6fee92a2485448edbecf3db17b2d59ea.png
[20210703181922323.png]: /images/20221005/ed9ec2fcc4594486a8d644767fc8146d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMzU4NTc0_size_16_color_FFFFFF_t_70 4]: /images/20221005/3636fd10540a4479a6369bf88cd6b869.png
[20210703182629683.png]: /images/20221005/ea783dbf32f545a4893d34513af2eba7.png