0
点赞
收藏
分享

微信扫一扫

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

窗外路过了谁 2024-07-24 阅读 9

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中文件传输。

举报

相关推荐

ThreadLocal 深入了解

深入了解路由

深入了解ECharts

深入了解VPC

深入了解Webpack 5

带你深入了解 symbol

0 条评论