le mie informazioni di contatto
Posta[email protected]
2024-07-12
한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina
网络通信协议：通信协议是对计算机必须遵守的规则，只有遵守这些规则，计算机之间才能进行通信。
java.net 包中提供了两种常见的网络协议的支持
Handshake a tre vie in TCP: Nel protocollo TCP, nella fase di preparazione dell'invio dei dati, ci sono tre interazioni tra il client e il server per garantire l'affidabilità della connessione.
协议 + IP地址 + 端口号TCP通信能实现两台计算机之间的数据交互，通信的两端，要严格区分为客户端（Client）与服务端（Server）。
In Java vengono fornite due classi per implementare i programmi di comunicazione TCP:
Socket 类：该类实现客户端套接字，套接字指的是两台设备之间通讯的端点。
Metodo di costruzione:
public Socket(String host, int port) :Crea un oggetto socket e lo connette al numero di porta specificato sull'host specificato. Se l'host specificato è nullo, equivale a che l'indirizzo specificato sia l'indirizzo di loopback (L'indirizzo di loopback (127.xxx) è l'indirizzo di loopback locale (indirizzo di loopback))。
Metodi dei membri:
public InputStream getInputStream() : Restituisce il flusso di input per questo socket.public OutputStream getOutputStream() : Restituisce il flusso di output per questo socket.public void close() : Chiudi questa presa.public void shutdownOutput() : Disabilita il flusso di output per questo socket.ServerSocket 类：这个类实现了服务器套接字，该对象等待通过网络的请求。
Metodo di costruzione:
public ServerSocket(int port): utilizzare questo costruttore per associarlo a un puntatore durante la creazione di un oggetto ServerSocket.
Su un determinato numero di porta, il parametro port è il numero di porta.
Metodi dei membri:
public Socket accept() : ascolta e accetta connessioni e restituisce un nuovo oggetto Socket per la comunicazione con il client.questo metodo
Si bloccherà finché non verrà stabilita la connessione.
Analisi della comunicazione TCP:
Esempio di codice:
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerTCP {
public static void main(String[] args) throws IOException {
System.out.println("服务端启动 , 等待连接 .... ");
// 1.创建 ServerSocket对象，绑定端口，开始等待连接
ServerSocket ss = new ServerSocket(6666);
// 2.接收连接 accept 方法, 返回 socket 对象.
Socket server = ss.accept();
// 3.通过socket 获取输入流
InputStream is = server.getInputStream();
// 4.一次性读取数据
// 4.1 创建字节数组
byte[] b = new byte[1024];
// 4.2 据读取到字节数组中.
int len = is.read(b);
// 4.3 解析数组,打印字符串信息
String msg = new String(b, 0, len);
System.out.println(msg);
//5.关闭资源.
is.close();
server.close();
}
}
Il server specifica il numero di porta, ottiene l'oggetto Socket tramite il metodo accetta(), ottiene il flusso di input tramite l'oggetto client e infine legge i dati e attende il messaggio inviato dal client.
import java.net.Socket;
public class ClientTCP {
public static void main(String[] args) throws Exception {
System.out.println("客户端 发送数据");
// 1.创建 Socket ( ip , port ) , 确定连接到哪里.
Socket client = new Socket("localhost", 6666);
// 2.获取流对象 . 输出流
OutputStream os = client.getOutputStream();
// 3.写出数据.
os.write("你好么? tcp ,我来了".getBytes());
// 4. 关闭资源 .
os.close();
client.close();
}
}
Quando viene creato il client, specificare l'indirizzo IP e il numero di porta della connessione per facilitare la connessione al server, ottenere il flusso di output e i dati di output tramite l'oggetto Socket del client.
数据准备:Inserisci un file denominato test.jpg nell'unità D e crea una cartella di test
Esempio di codice:
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class FileUpload_Server {
public static void main(String[] args) throws IOException {
System.out.println("服务器 启动..... ");
// 1. 创建服务端ServerSocket
ServerSocket serverSocket = new ServerSocket(6666);
// 2. 循环接收,建立连接
while (true) {
Socket accept = serverSocket.accept();
/* 3. socket对象交给子线程处理,进行读写操作Runnable接口中,只有一个run方法,使用lambda表达式简化格式 */
new Thread(() -> {
try ( //3.1 获取输入流对象
BufferedInputStream bis = new BufferedInputStream(accept.getInputStream());
//3.2 创建输出流对象, 保存到本地 .
FileOutputStream fis = new FileOutputStream("D:/test/" + System.currentTimeMillis() + ".jpg");
BufferedOutputStream bos = new BufferedOutputStream(fis)) {
// 3.3 读写数据
byte[] b = new byte[1024 * 8];
int len;
while ((len = bis.read(b)) != -1) {
bos.write(b, 0, len);
}
// 4.=======信息回写===========================
System.out.println("back ........");
OutputStream out = accept.getOutputStream();
out.write("上传成功".getBytes());
out.close();
//5. 关闭 资源
bos.close();
bis.close();
accept.close();
System.out.println("文件上传已保存");
} catch (IOException e) {
e.printStackTrace();
}
}).start();
}
}
}
Qui creiamo prima un oggetto server, utilizziamo while(true) per garantire una connessione continua al server, quindi avviamo un thread per garantire che quando un utente carica un file di grandi dimensioni, l'efficienza del caricamento dei file da parte di altri utenti non verrà influenzata. Utilizzare il sistema millisecondi + '.jpg' per impostare il nome del file per garantire che il nome del file non venga sovrascritto a causa dello stesso nome del file durante il caricamento.
import java.io.*;
import java.net.Socket;
public class FileUpload_Client {
public static void main(String[] args) throws IOException {
// 1.创建流对象
// 1.1 创建输入流,读取本地文件
BufferedInputStream bis = new BufferedInputStream(new FileInputStream("D:\test.jpg"));
// 1.2 创建输出流,写到服务端
Socket socket = new Socket("localhost", 6666);
BufferedOutputStream bos = new BufferedOutputStream(socket.getOutputStream());
//2.写出数据.
byte[] b = new byte[1024 * 8 ];
int len ;
while (( len = bis.read(b))!=-1) {
bos.write(b, 0, len);
}
// 关闭输出流,通知服务端,写出数据完毕
socket.shutdownOutput();
System.out.println("文件发送完毕");
// 3. =====解析回写============
InputStream in = socket.getInputStream();
byte[] back = new byte[20];
in.read(back);
System.out.println(new String(back));
in.close();
// ============================
// 4.释放资源
socket.close();
bis.close();
}
}
Qui possiamo vedere che il nostro server ha salvato con successo il file inviato dall'utente sul disco rigido.
Gli amanti di Java sono invitati a conoscere l'articolo. L'autore continuerà ad aggiornarlo e attende con ansia la vostra attenzione e raccolta. . .
Si dedica alla ricerca tecnologica da più di 30 anni ed è esperto in vari linguaggi come Java, Linux, Javascript, php, css, ecc. Ha dato numerosi contributi nel campo dell'open source stazione di documentazione per gli sviluppatori per condividere alcuni problemi nello sviluppo della tecnologia per riferimento futuro
Posta[email protected]