数据交换格式就像两个人在聊天一样，采用彼此都能听得懂的语言，你来我往，其中的语言就相当于 通信中的数据交换格式。有时候，为了防止聊天被人偷听，可以采用暗语。同理，计算机程序之间也 可以通过数据加密技术防止“偷听”。
数据交换格式主要分为纯文本格式、XML格式和JSON格式，其中纯文本格式是一种简单的、无格式 的数据交换方式。
一般来讲，JSON所用的字节数要比XML少，这也是很多人喜欢采用JSON格式的主要原
因，因此JSON也被称为“轻量级”的数据交换格式。下面介绍JSON数据交换格式案例：
以之前聊天工具修改为使用JSON进行数据交换。
服务器端ChatServer代码如下:
import org.json.JSONObject; import java.io.*; import java.net.ServerSocket; import java.net.Socket; /** * @author : 蔡政洁 * @email :caizhengjie888@icloud.com * @date : 2020/2/20 * @time : 11:38 下午 */ //服务器端用JSON数据进行数据交换格式 //{"message":"hello","position":"boss","name":"蔡政洁","age":20} public class ChatServer { public static void main(String[] args) { System.out.println("服务器端运行。。。。"); // 创建一个子线程，因为网络通信往往会有线程阻塞过程，放到子线程中处理就不会阻塞主线程了 Thread thread = new Thread(() ->{ try( // 创建一个ServerSocket监听8080端口的客户端请求 ServerSocket serverSocket = new ServerSocket(8080); // 使用accept方法阻塞等待客户端请求 Socket socket = serverSocket.accept(); // 从socket中获得数据输入流 DataInputStream in = new DataInputStream(socket.getInputStream()); // 从socket中获得数据输出流 DataOutputStream out = new DataOutputStream(socket.getOutputStream()); // System.in是标准输入流，然后使用标准输入流创建缓冲输入流 BufferedReader keyboardIn = new BufferedReader(new InputStreamReader(System.in)); ){ while (true){ // 接收数据，readUTF()是数据输入流读取字符串 String str = in.readUTF(); // JSON解码 JSONObject jsonObject = new JSONObject(str); // 打印接收的数据 System.out.printf("从客户端接收的数据：%s\n",jsonObject); // 发送数据 // 读取键盘输入的字符 String keyboardInputString = keyboardIn.readLine(); // 结束聊天 if (keyboardInputString.equals("bye")){ break; } // 编码 JSONObject jsonObject1 = new JSONObject(); jsonObject1.put("message",keyboardInputString); jsonObject1.put("position","经理"); jsonObject1.put("name","XXX"); jsonObject1.put("age",21); // 发送，writeUTF是数据输出流写入字符串 out.writeUTF(jsonObject1.toString()); out.flush(); } } catch (IOException e){ e.printStackTrace(); } System.out.println("服务器停止。。。"); }); thread.start(); } }
客户端ChatClient代码如下:
import org.json.JSONObject; import java.io.*; import java.net.ConnectException; import java.net.Socket; /** * @author : 蔡政洁 * @email :caizhengjie888@icloud.com * @date : 2020/2/20 * @time : 11:39 下午 */ //服务器端用JSON数据进行数据交换格式 //{"message":"hello","position":"boss","name":"蔡政洁","age":20} public class ChatClient { public static void main(String[] args) { System.out.println("客户端运行。。。"); Thread thread = new Thread(() ->{ try( // 向本机的8080端口发出连接请求 Socket socket = new Socket("127.0.0.1",8080); // 从socket中获得数据输入流 DataInputStream in = new DataInputStream(socket.getInputStream()); // 从socket中获得数据输出流 DataOutputStream out = new DataOutputStream(socket.getOutputStream()); // System.in是标准输入流，然后使用标准输入流创建缓冲输入流 BufferedReader keyboardIn = new BufferedReader(new InputStreamReader(System.in)); ){ while (true){ // 发送数据 // 获取键盘输入的字符串 String keyboardInputString = keyboardIn.readLine(); // 结束聊天 if (keyboardInputString.equals("bye")){ break; } JSONObject jsonObject = new JSONObject(); jsonObject.put("message",keyboardInputString); jsonObject.put("position","boss"); jsonObject.put("name","蔡政洁"); jsonObject.put("age",20); // 发送，writeUTF是数据输出流写入字符串 out.writeUTF(jsonObject.toString()); out.flush(); // 接收数据，readUTF()是数据输入流读取字符串 String str = in.readUTF(); // JSON解码 JSONObject jsonObject1 = new JSONObject(str); // 打印接受的数据 System.out.printf("从服务器接收的数据：%s\n",jsonObject1); } } catch (ConnectException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } System.out.println("客户端停止。。。"); }); thread.start(); } }
运行结果：
