Java 1对1

文章目录

前言

客户端

服务器端

输出线程端

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();

? ? }

}

服务器端

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();

? ? }

输出线程端

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()+"输出线程退出");

? ? }

End

此代码我已经测试过可以实现最初的无线数据传输，客户端运行在一个电脑上，服务器端运行在另一台电脑上，这时只需要将客户端的目标ip地址改为服务器端电脑的ip地址（如果不知到如何查询，win+r -> cmd->ipconfig，就可以看到自己电脑的IPv4 地址）。

需要注意的是，当时的测试环境是两台电脑处于同一个WiFi热点下进行的。