java socket garbled code

Solution:

First use InputStreamReader on the server side to specify the client The input stream of the client is utf-8 encoded, and the OutputStreamWriter is used to specify the output stream to be utf-8 encoded;

Then set the utf-8 encoding similarly on the client.

in = new BufferedReader(new InputStreamReader(socket.getInputStream(),"UTF-8"));
out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF-8"));

Example:

Server:

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，最大鏈接數(shù)：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 {
			//讀取數(shù)據(jù)
			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;
				}
 
				//發(fā)送數(shù)據(jù)
				bw.write(str + "\r\n");		//加上分行符，以便服務(wù)器按行讀取
				bw.flush();
				
				
				//接收數(shù)據(jù)
				while((str = br.readLine()) != null) {
					str = str.trim();
					System.out.println("服務(wù)器回復(fù)：" + 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 {
		}
	}
}

php Chinese website, a large number of free Java introductory tutorials, welcome to learn online!

The above is the detailed content of java socket garbled code. For more information, please follow other related articles on the PHP Chinese website!