数据交换格式就像两个人在聊天一样,采用彼此都能听得懂的语言,你来我往,其中的语言就相当于 通信中的数据交换格式。有时候,为了防止聊天被人偷听,可以采用暗语。同理,计算机程序之间也 可以通过数据加密技术防止“偷听”。
数据交换格式主要分为纯文本格式、XML格式和JSON格式,其中纯文本格式是一种简单的、无格式 的数据交换方式。
一般来讲,JSON所用的字节数要比XML少,这也是很多人喜欢采用JSON格式的主要原
因,因此JSON也被称为“轻量级”的数据交换格式。下面介绍JSON数据交换格式案例:
再次之前需要导入第三方JSON库,具体了解见链接:
https://blog.csdn.net/weixin_45366499/article/details/104430473
以之前聊天工具修改为使用JSON进行数据交换。
服务器端ChatServer代码如下:
import org.json.JSONObject;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
/**
* @author : 蔡政洁
* @email :[email protected]
* @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 :[email protected]
* @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();
}
}
运行结果:
以上内容仅供参考学习,如有侵权请联系我删除!
如果这篇文章对您有帮助,左下角的大拇指就是对博主最大的鼓励。
您的鼓励就是博主最大的动力!