其实道理很简单，如果两个人想顺畅的交流，事先确定好交流的主题就能避免牛头不对马嘴的情况。
这里的主题其实就是：编码格式。

就是服务端和客户端创建writer和out时指定编码格式。

服务端代码：

package InternetCode.Socket.Exa508;import java.io.*;
import java.net.*;
import java.util.Scanner;public class ServerSocketFrame{private OutputStreamWriter out; // 创建流对象private PrintWriter writer; // 声明PrintWriter类对象private BufferedReader reader; // 声明BufferedReader对象private ServerSocket server; // 声明ServerSocket对象private Socket socket; // 声明Socket对象socketprivate Scanner scanner;public void getServer() {try {server = new ServerSocket(1978); // 实例化Socket对象System.out.println("服务器套接字已经创建成功\n"); // 输出信息while (true) { // 如果套接字是连接状态System.out.println("等待客户机的连接......\n"); // 输出信息socket = server.accept(); // 实例化Socket对象reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8")); // 实例化BufferedReader对象out = new OutputStreamWriter(socket.getOutputStream(), "UTF-8");writer = new PrintWriter(out, true);getClientInfo(); // 调用getClientInfo()方法}} catch (Exception e) {e.printStackTrace(); // 输出异常信息}}private void getClientInfo() {try {while (true) { // 如果套接字是连接状态String line = reader.readLine();if (line != null)System.out.println("接收到客户机发送的信息：" + line + "\n"); // 获得客户端信息}} catch (Exception e) {System.out.println("客户端已退出。\n"); // 输出异常信息} finally {try {if (reader != null) {reader.close();// 关闭流}if (socket != null) {socket.close(); // 关闭套接字}} catch (IOException e) {e.printStackTrace();}}}/*** 向客户端发送消息*/private void sendInfoToClient(){while(true){scanner=new Scanner(System.in);System.out.println("请输入要发送的消息:");String text=scanner.nextLine();if(text.equals("quit")){break;}writer.println(text);}}public static void main(String[] args) { // 主方法ServerSocketFrame frame = new ServerSocketFrame(); // 创建本类对象//此线程用于监听接收消息new Thread(new Runnable() {@Overridepublic void run() {frame.getServer();}}).start();//此线程用发送消息给客户端new Thread(new Runnable() {@Overridepublic void run() {frame.sendInfoToClient();}}).start();}}

客户端代码：

package InternetCode.Socket.Exa508;import java.awt.*;
import java.awt.BorderLayout;
import java.awt.event.*;
import java.io.*;
import java.net.*;
import java.util.Scanner;
import javax.swing.*;public class ClientSocketFrame { // 创建类继承JFrame类private OutputStreamWriter out; // 创建流对象private PrintWriter writer; // 声明PrintWriter类对象private BufferedReader reader; // 声明BufferedReader对象private Socket socket; // 声明Socket对象private Scanner scanner;private void connect() { // 连接套接字方法System.out.println("尝试连接......\n"); // 文本域中信息信息try { // 捕捉异常socket = new Socket("127.0.0.1", 1978); // 实例化Socket对象while (true) {out = new OutputStreamWriter(socket.getOutputStream(), "UTF-8");writer = new PrintWriter(out, true);reader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8")); // 实例化BufferedReader对象System.out.println("完成连接。\n"); // 文本域中提示信息getServerInfo();}} catch (Exception e) {e.printStackTrace(); // 输出异常信息}}private void getServerInfo() {try {while (true) { // 如果套接字是连接状态if (reader != null) {String line = reader.readLine();if (line != null)System.out.println("接收到服务器发送的信息：" + line + "\n"); // 获得客户端信息}}} catch (Exception e) {e.printStackTrace();} finally {try {if (reader != null) {reader.close();// 关闭流}if (socket != null) {socket.close(); // 关闭套接字}} catch (IOException e) {e.printStackTrace();}}}/*** 向服务器发送消息方法*/private void sendInfoToServer(){while(true){scanner=new Scanner(System.in);System.out.println("请输入要发送的消息:");String text=scanner.nextLine();if(text.equals("quit")){break;}writer.println(text);}}public static void main(String[] args) { // 主方法ClientSocketFrame client = new ClientSocketFrame(); // 创建本例对象//此线程用于监听接收消息new Thread(new Runnable() {@Overridepublic void run() {client.connect(); // 调用连接方法}}).start();//此线程用发送消息给服务器new Thread(new Runnable() {@Overridepublic void run() {client.sendInfoToServer(); // 调用连接方法}}).start();}}