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