2024-07-12
한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina
网络通信协议：通信协议是对计算机必须遵守的规则，只有遵守这些规则，计算机之间才能进行通信。
java.net 包中提供了两种常见的网络协议的支持
Prise de contact à trois dans TCP : Dans le protocole TCP, lors de la phase de préparation de l'envoi des données, il existe trois interactions entre le client et le serveur pour assurer la fiabilité de la connexion.
协议 + IP地址 + 端口号TCP通信能实现两台计算机之间的数据交互，通信的两端，要严格区分为客户端（Client）与服务端（Server）。
En Java, deux classes sont fournies pour implémenter les programmes de communication TCP :
Socket 类：该类实现客户端套接字，套接字指的是两台设备之间通讯的端点。
Méthode de construction :
public Socket(String host, int port) :Crée un objet socket et le connecte au numéro de port spécifié sur l'hôte spécifié. Si l'hôte spécifié est nul, cela équivaut à ce que l'adresse spécifiée soit l'adresse de bouclage (L'adresse de bouclage (127.xxx) est l'adresse de bouclage locale (Loopback Address))。
Méthodes de membre :
public InputStream getInputStream() : renvoie le flux d'entrée pour ce socket.public OutputStream getOutputStream() : Renvoie le flux de sortie pour ce socket.public void close() : Fermez cette prise.public void shutdownOutput() : Désactive le flux de sortie pour ce socket.ServerSocket 类：这个类实现了服务器套接字，该对象等待通过网络的请求。
Méthode de construction :
public ServerSocket (int port) : utilisez ce constructeur pour le lier à un pointeur lors de la création d'un objet ServerSocket.
Sur un certain numéro de port, le paramètre port est le numéro de port.
Méthodes de membre :
public Socket accept() : écoutez et acceptez les connexions, et renvoyez un nouvel objet Socket pour la communication avec le client.cette méthode
Bloquera jusqu'à ce que la connexion soit établie.
Analyse des communications TCP :
Exemple de code :
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();
}
}
Le serveur spécifie le numéro de port, obtient l'objet Socket via la méthode accept(), obtient le flux d'entrée via l'objet client, et enfin lit les données et attend le message envoyé par le 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();
}
}
Lorsque le client est créé, spécifiez l'adresse IP et le numéro de port de la connexion pour faciliter la connexion au serveur, obtenez le flux de sortie et les données de sortie via l'objet Socket client.
数据准备:Placez un fichier nommé test.jpg sous le lecteur D et créez un dossier de test
Exemple de code :
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();
}
}
}
Ici, nous créons d'abord un objet serveur, utilisons while(true) pour assurer une connexion continue au serveur, puis démarrons un thread pour garantir que lorsqu'un utilisateur télécharge un fichier volumineux, l'efficacité des autres utilisateurs téléchargeant des fichiers ne sera pas affectée. Utilisez les millisecondes du système + « .jpg » pour définir le nom du fichier afin de garantir que le nom du fichier ne sera pas écrasé en raison du même nom de fichier lors du téléchargement.
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();
}
}
Ici, nous pouvons voir que notre serveur a enregistré avec succès le fichier envoyé par l'utilisateur sur le disque dur.
Les amateurs de Java sont invités à en savoir plus sur l'article. L'auteur continuera à le mettre à jour et attend avec impatience votre attention et votre collection. . .
Il se consacre à la recherche technologique depuis plus de 30 ans et maîtrise divers langages tels que java, linux, javascript, php, css, etc. Il a apporté de nombreuses contributions dans le domaine de l'open source. station de documentation pour les développeurs pour partager certains problèmes de développement technologique pour référence future.
