TCP socket通信,深入了解项目框架

1.运用BIO 进行网络通信

 客户端与服务端通过socket进行不断交互。

2.服务端(为了多个客户端能够同时与服务器连接)

服务器使用多线程。在主线程不断监听端口,如果有客户端连接端口,就连接客户端执行子线程中,在子线程中不断客户端发来的处理请求。

public static void main(String[] args) {
		try {
			//注册端口   
			ServerSocket serverSocket = new ServerSocket(PORT);

			// 循环一直等待所有可能的客户端连接 
			while(true){
				Socket socket = serverSocket.accept();
				new ServerReader(socket).start();
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

 在子线程中,不断处理客户端发来的请求...

3.客户端实时更新信息

客户端,这里一般使用长连接,一个客户端只使用一个socket并且不关闭,当关闭socket时,这个客户端就下线了,这样在服务端使用一个集合储存socket,就可以知道所有在线用户

在客户端开两个线程,一个主函数就行不断加载UI界面,另一个线程进行接受服务端返回的信息,并根据信息,执行相应的程序。这里可以指向socket 并更新UI界面。

 在这个线程里面就行更改界面。

4.文件传输

package com.test.po;

import java.io.*;

public class MyFile {
    private String name;
    private ByteArrayOutputStream fileData;


    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public MyFile(String name) {
        this.name = name;
    }

    public MyFile() {
    }
    public Integer ReadeFileData(File file){
        if(!file.isFile())return 0;
        try {
            FileInputStream fileInputStream = new FileInputStream(file);
            ByteArrayOutputStream buffer = new ByteArrayOutputStream();
            byte[] tem = new byte[1024*1024]; //1mb
            int len;
            while ((len = fileInputStream.read(tem)) != -1) {
                buffer.write(tem, 0, len);
            }
            fileInputStream.close();
            fileData = buffer;
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
        return 1;
    }
    public Integer WriteFileData(File file){
        if(fileData == null)return 0;
       if(!file.exists()){
           try {
               file.createNewFile();
           } catch (IOException e) {
               e.printStackTrace();
               return 0;
           }
       }
        try {
            FileOutputStream fileOutputStream = new FileOutputStream(file);
            fileData.writeTo(fileOutputStream);
            fileData.flush();
            fileData.close();
        } catch (Exception e) {
            e.printStackTrace();
            return 0;
        }
        return 1;
    }
}

包装一下,这两种方式就可以进行文件的读写,

上面可以进行文件的复制,在socket中文件传输。

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2024-07-17 04:42:06       70 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2024-07-17 04:42:06       74 阅读
  3. 在Django里面运行非项目文件

    2024-07-17 04:42:06       62 阅读
  4. Python语言-面向对象

    2024-07-17 04:42:06       72 阅读

热门阅读

  1. ubuntu使用vcan做本地测试

    2024-07-17 04:42:06       25 阅读
  2. ARP协议

    2024-07-17 04:42:06       27 阅读
  3. 基于Go1.19的站点模板爬虫

    2024-07-17 04:42:06       26 阅读
  4. 刷题Day54|99. 岛屿数量、100. 岛屿的最大面积

    2024-07-17 04:42:06       26 阅读
  5. 日耗100和100W投手思维的区别

    2024-07-17 04:42:06       22 阅读
  6. C语言经典程序100案例

    2024-07-17 04:42:06       19 阅读
  7. 【数据结构】顺序表

    2024-07-17 04:42:06       21 阅读
  8. 类和对象(2

    2024-07-17 04:42:06       29 阅读
  9. Elasticsearch:6.0及其ES-Head插件安装

    2024-07-17 04:42:06       25 阅读