Code tronqué du socket Java
Solution :
Utilisez d'abord InputStreamReader pour spécifier le client sur côté serveur Le flux d'entrée du client est codé en utf-8, et OutputStreamWriter est utilisé pour spécifier le flux de sortie à encoder en utf-8
Ensuite, définissez l'encodage utf-8 de la même manière sur le client.
in = new BufferedReader(new InputStreamReader(socket.getInputStream(),"UTF-8")); out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8"));
Exemple :
Serveur :
import java.io.*; import java.net.*; public class SocketServerEx1 { public static void main(String args[]) { System.out.println("Server"); ServerSocket serverSocket = null; Socket clientSocket = null; int connects = 0; try { serverSocket = new ServerSocket(82, 5); //端口:82,最大链接数:5 //最多连接10次 while(connects < 10) { connects++; System.out.println("--------------------等待连接--------------------------"); clientSocket = serverSocket.accept(); //等待连接 System.out.println("第 " + connects + " 次连接"); ServiceClient(clientSocket); } serverSocket.close(); } catch(IOException ioe) { System.out.println("Error: " + ioe); } } public static void ServiceClient(Socket client) throws IOException { System.out.println("已链接"); InputStreamReader inSR = null; OutputStreamWriter outSW = null; try { //读取数据 inSR = new InputStreamReader(client.getInputStream(), "UTF-8"); BufferedReader br = new BufferedReader(inSR); outSW = new OutputStreamWriter(client.getOutputStream(), "UTF-8"); BufferedWriter bw = new BufferedWriter(outSW); String str = ""; while((str = br.readLine()) != null) { str = str.trim(); System.out.println("收到客户端消息:" + str); bw.write("已收到信息:" + str + " \r\n"); //向客户端反馈消息,加上分行符以便客户端接收 bw.flush(); } } finally { //System.out.println("Cleaning up connection: " + client); inSR.close(); outSW.close(); client.close(); } System.out.println("已断开"); } }
Client :
import java.io.*; import java.net.*; public class SocketClientEx1 { public static void main(String[] args) { System.out.println("Client"); try { Socket clientSocket = new Socket("localhost", 82); System.out.println("Client1:" + clientSocket); DataInputStream dataIS = new DataInputStream(clientSocket.getInputStream()); InputStreamReader inSR = new InputStreamReader(dataIS, "UTF-8"); BufferedReader br = new BufferedReader(inSR); DataOutputStream dataOS = new DataOutputStream(clientSocket.getOutputStream()); OutputStreamWriter outSW = new OutputStreamWriter(dataOS, "UTF-8"); BufferedWriter bw = new BufferedWriter(outSW); //输入信息 byte bytes[] = new byte[100]; while(true) { System.out.println("----------------------------------"); System.in.read(bytes); String str = new String(bytes); str = str.trim(); if (str == "exit") { break; } //发送数据 bw.write(str + "\r\n"); //加上分行符,以便服务器按行读取 bw.flush(); //接收数据 while((str = br.readLine()) != null) { str = str.trim(); System.out.println("服务器回复:" + str); break; } } inSR.close(); dataIS.close(); dataOS.close(); clientSocket.close(); } catch(UnknownHostException uhe) { System.out.println("Error:" + uhe.getMessage()); } catch(ConnectException ce) { System.out.println("Error:" + ce.getMessage()); } catch(IOException ioe) { System.out.println("Error:" + ioe.getMessage()); } finally { } } }
site Web chinois php, un grand nombre de tutoriels d'introduction à Java gratuits, bienvenue pour apprendre en ligne !
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!