java实现服务器与客户端之间的TCP通信

简介: java实现服务器与客户端之间的TCP通信

服务器端: TCPServer.java

package com.zhanshen.demo;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
 * TCP通信的服务器端,接收客户端发的数据
 * java.net.ServerSocket
 *
 * 构造方法:
 *      ServerSocket(int port)
 *
 * 服务器必须明确,必须知道是哪个客户端请求的服务器
 * 所以可以使用accept方法获取请求到的客户端对象socket
 *
 * 成员方法:
 *      socket accept()   侦听并接收到此套接字的链接
 *
 * 服务器实现步骤:
 *      1. 创建服务器ServerSocket 对象和系统要制定的端口
 *      2. 使用ServerSocket对象中的方法accept 获取请求的客户端对象Socket
 *      3. 使用Socket对象中的getInputStream 获取网络字节输入流InputStream对象
 *      4. 使用网络字节输入流InputStream对象中的方法 read 读取客户端发送的请求
 *      5. 使用socket对象中的方法getOutputStream 获取网络字节输出流OutputStream对象
 *      6. 使用网络字节输出流 OutputStream对象中的write 来给客户端回写数
 *      7. 释放资源 Socket和ServerSocket
 *
 */
public class TCPServer {
    public static void main(String[] args) throws IOException {
        //1. 创建服务器socket
        ServerSocket serverSocket = new ServerSocket(8888);
        //2. 使用ServerSocket对象中的accept方法  获取客户端的socket
        Socket socket = serverSocket.accept();
        //3. 使用Socket对象中的getInputStream 获取网络字节输入流InputStream
        InputStream inputStream = socket.getInputStream();
        //4. 使用网络字节输入流InputStream 对象中的read 获取客户端发送的数据
        byte[] bytes = new byte[1024];
        int len = inputStream.read(bytes);
        System.out.println(new java.lang.String(bytes, 0, len));
        //5. 使用socket对象中的方法getOutputStream 获取字节输出流
        OutputStream outputStream = socket.getOutputStream();
        //6. 回写数据
        outputStream.write("收到. thank you".getBytes());
        //7. 释放资源
        socket.close();
        serverSocket.close();
    }
}

客户端: TCPClient.java

package com.zhanshen.demo;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
/**
 * TCP通讯的客户端,向服务器发送连接请求,给服务器发送数据,读取服务器回写的数据
 * 表示客户端的类 java.next.Socket
 * 套接字: 包含IP地址和端口号的网络单位
 *
 * 构造方法:
 *  Socket(String host, int port)
 *  host: 服务器主机的名名称或者IP
 * 成员方法:
 *  OutputStream getOutputStream()   返回此套接字的输出流
 *  InputStream getInputStream()     返回此套接字的输入流
 *  void close()  关闭套接字
 *
 * 实现步骤:
 *  1. 创建客户端对象socket   构造方法中绑定服务器的IP地址和端口号
 *  2. 使用getOutputStream() 获取网络字节输出流OutputStream对象
 *  3. 使用网络字节输出流OutputStream 对象中的方法write , 检查服务器发送数据
 *  4. 使用socket对象中的getInputStream 获取网络字节流InputStream对象
 *  5. 使用网络字节输入流InputStream对象中的read方法,读取服务器回写的数据
 *  6. 释放资源
 */
public class TCPClient {
    public static void main(String[] args) throws IOException {
        //1.创建一个客户端对象 Socket 构造方法绑定服务器的IP和端口号, 用本地做测试,也可以换成你的服务器IP
        Socket socket = new Socket("127.0.0.1", 8888);
        //2.使用Socket对象中的方法OutputStream() 获取网络字节输出流
        OutputStream outputStream = socket.getOutputStream();
        //3.使用网络字节流OutputStream对象中的方法write 向服务器发送数据
        outputStream.write("hello world".getBytes());
        //4.
        InputStream inputStream = socket.getInputStream();
        //5
        byte[] bytes = new byte[1024];
        int len = inputStream.read(bytes);
        System.out.println(new String(bytes, 0, len));
        //6/
        socket.close();
    }
}
相关文章
|
26天前
|
Java 调度
[Java]线程生命周期与线程通信
本文详细探讨了线程生命周期与线程通信。文章首先分析了线程的五个基本状态及其转换过程,结合JDK1.8版本的特点进行了深入讲解。接着,通过多个实例介绍了线程通信的几种实现方式,包括使用`volatile`关键字、`Object`类的`wait()`和`notify()`方法、`CountDownLatch`、`ReentrantLock`结合`Condition`以及`LockSupport`等工具。全文旨在帮助读者理解线程管理的核心概念和技术细节。
37 1
[Java]线程生命周期与线程通信
|
12天前
|
Java
JAVA多线程通信:为何wait()与notify()如此重要?
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是实现线程间通信的核心机制。它们通过基于锁的方式,使线程在条件不满足时进入休眠状态,并在条件满足时被唤醒,从而确保数据一致性和同步。相比其他通信方式,如忙等待,这些方法更高效灵活。 示例代码展示了如何在生产者-消费者模型中使用这些方法实现线程间的协调和同步。
26 3
|
1月前
|
存储 消息中间件 安全
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
【10月更文挑战第9天】本文介绍了如何利用JUC组件实现Java服务与硬件通过MQTT的同步通信(RRPC)。通过模拟MQTT通信流程,使用`LinkedBlockingQueue`作为消息队列,详细讲解了消息发送、接收及响应的同步处理机制,包括任务超时处理和内存泄漏的预防措施。文中还提供了具体的类设计和方法实现,帮助理解同步通信的内部工作原理。
JUC组件实战:实现RRPC(Java与硬件通过MQTT的同步通信)
|
27天前
|
安全 Java
Java多线程通信新解:本文通过生产者-消费者模型案例,深入解析wait()、notify()、notifyAll()方法的实用技巧
【10月更文挑战第20天】Java多线程通信新解:本文通过生产者-消费者模型案例,深入解析wait()、notify()、notifyAll()方法的实用技巧,包括避免在循环外调用wait()、优先使用notifyAll()、确保线程安全及处理InterruptedException等,帮助读者更好地掌握这些方法的应用。
17 1
|
27天前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法,并分享了最佳实践,帮助开发者避免常见陷阱,提高多线程程序的稳定性和效率。
34 1
|
27天前
|
Java
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。
在Java多线程编程中,`wait()` 和 `notify()/notifyAll()` 方法是线程间通信的核心机制。它们通过基于锁的方式,使线程在条件不满足时进入休眠状态,并在条件成立时被唤醒,从而有效解决数据一致性和同步问题。本文通过对比其他通信机制,展示了 `wait()` 和 `notify()` 的优势,并通过生产者-消费者模型的示例代码,详细说明了其使用方法和重要性。
25 1
|
1月前
|
Java
|
1月前
|
运维 Java Linux
【运维基础知识】Linux服务器下手写启停Java程序脚本start.sh stop.sh及详细说明
### 启动Java程序脚本 `start.sh` 此脚本用于启动一个Java程序,设置JVM字符集为GBK,最大堆内存为3000M,并将程序的日志输出到`output.log`文件中,同时在后台运行。 ### 停止Java程序脚本 `stop.sh` 此脚本用于停止指定名称的服务(如`QuoteServer`),通过查找并终止该服务的Java进程,输出操作结果以确认是否成功。
38 1
|
1月前
|
分布式计算 资源调度 Hadoop
大数据-01-基础环境搭建 超详细 Hadoop Java 环境变量 3节点云服务器 2C4G XML 集群配置 HDFS Yarn MapRedece
大数据-01-基础环境搭建 超详细 Hadoop Java 环境变量 3节点云服务器 2C4G XML 集群配置 HDFS Yarn MapRedece
77 4
|
前端开发 Java Linux
Java服务器宕机解决方法论(上)
Java服务器宕机解决方法论(上)
745 0
Java服务器宕机解决方法论(上)
下一篇
无影云桌面