文章目录
前言
客户端
服务器端
输出线程端
End
前言
TCP（Transmission Control Protocol）是一种面向连接的、可靠的网络传输协议，它提供了端到端的数据传输和可靠性保证。
本程序就是基于tcp协议编写而成的。
利用 TCP 协议进行通信的两个应用程序是有主次之分的，一个称为服务器程序，另一个称为客户机程序，两者的功能和编写方法大不一样。
代码结构图
在这里插入图片描述
客户端
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.util.Scanner;
public class Client {
public static void main(String[] args) throws IOException {
Scanner in = new Scanner(System.in);
// 发送数据
// 创建 Socket对象
// 创建对象时会连接服务器，如果连接不上会报错
// 127.0.0.1 代表本机地址
Socket socket = new Socket("127.0.0.1", 11451);
MyThread thread = new MyThread();
OutputStream os = socket.getOutputStream();
while (true) {
if (thread.getState() == Thread.State.NEW) {
thread.setName("芜湖");
thread.setSocket(socket);
thread.start();
}
String str = in.next();
os.write(str.getBytes());
if ("886".equals(str)) {
socket.shutdownOutput();
break;
}
}
System.out.println("主线程退出");
in.close();
os.close();
socket.close();
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
服务器端
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class Server {
public static void main(String[] args) throws IOException, InterruptedException {
Scanner in = new Scanner(System.in);
// 接收数据
// 创建ServerSocket对象
ServerSocket ss = new ServerSocket(11451); // 获取指定端口的数据
MyThread thread = new MyThread();
Socket socket = ss.accept();// 监听客户端的连接，获取连接
OutputStream os = socket.getOutputStream(); // 获取输出流
while (true) {
// 判断该线程是否启动
if (thread.getState() == Thread.State.NEW) {
thread.setName("呀呼");
thread.setSocket(socket);
thread.start();
}
// 从连接通道中获取输出流
// 写出数据
String str = in.next();
os.write(str.getBytes());
// 结束
if ("886".equals(str)) {
socket.shutdownOutput();
break;
}
}
System.out.println("主线程退出");
in.close();
os.close();
socket.close();
ss.close();
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
输出线程端
import java.io.*;
import java.net.Socket;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
public class MyThread extends Thread {
Socket socket;
public void setSocket(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
while (true) {
BufferedInputStream isr = null; // 获取输出流
try {
isr = new BufferedInputStream(socket.getInputStream());
int len;
byte[] bytes = new byte[1024];
while ((len = isr.read(bytes)) != -1) {
String target = new String(bytes, 0, len);
// 获取当前时间
LocalDateTime dateTime = LocalDateTime.now(); // get the current date and time
// 按照相应格式解析
DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-dd-MM HH:mm:ss");
// 输出当前时间
System.out.println(dateTime.format(formatter));
// 输出对方传输的内容
System.out.println(getName()+"："+target);
}
} catch (IOException e) {
break;
}
}
System.out.println(getName()+"输出线程退出");
}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
End
此代码我已经测试过可以实现最初的无线数据传输，客户端运行在一个电脑上，服务器端运行在另一台电脑上，这时只需要将客户端的目标ip地址改为服务器端电脑的ip地址（如果不知到如何查询，win+r -> cmd->ipconfig，就可以看到自己电脑的IPv4 地址）。
需要注意的是，当时的测试环境是两台电脑处于同一个WiFi热点下进行的。
 快速上手+实践，无废话纯享版)
![[Firefly-RK3399] TFTP/NFS网络启动内核与Buildroot文件系统](http://pic.xiahunao.cn/[Firefly-RK3399] TFTP/NFS网络启动内核与Buildroot文件系统)
