Java网络编程之基于TCP协议
作者：花伤情犹在 发布时间：2023-08-20 14:05:51
标签：Java,TCP,网络编程
一、单向通信
功能：客户端发送一句话到服务器：
客户端：
public class TestClient {//客户端
//这是一个main方法，是程序的入口：
public static void main(String[] args) throws IOException {
//1.创建套接字：指定服务器的ip和端口号：
Socket s = new Socket("192.168.199.217",8888);
//2.对于程序员来说，向外发送数据 感受 --》利用输出流：
OutputStream os = s.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
//利用这个OutputStream就可以向外发送数据了，但是没有直接发送String的方法
//所以我们又在OutputStream外面套了一个处理流：DataOutputStream
dos.writeUTF("你好");
//3.关闭流 + 关闭网络资源：
dos.close();
os.close();
s.close();
}
}
服务器端：
public class TestServer {//服务器
//这是一个main方法，是程序的入口：
public static void main(String[] args) throws IOException {
//1.创建套接字： 指定服务器的端口号
ServerSocket ss = new ServerSocket(8888);
//2.等着客户端发来的信息：
Socket s = ss.accept();//阻塞方法:等待接收客户端的数据，什么时候接收到数据，什么时候程序继续向下执行。
//accept()返回值为一个Socket，这个Socket其实就是客户端的Socket
//接到这个Socket以后，客户端和服务器才真正产生了连接，才真正可以通信了
//3.感受到的操作流：
InputStream is = s.getInputStream();
DataInputStream dis = new DataInputStream(is);
//4.读取客户端发来的数据：
String str = dis.readUTF();
System.out.println("客户端发来的数据为："+str);
//5.关闭流+关闭网络资源：
dis.close();
is.close();
s.close();
ss.close();
}
}
测试：
先开启客户端还是先开启服务器：先开服务器，再开启客户端 侧面验证：先开客户端：出错。
如图：
二、双向通信
客户端：
import java.io.*;
import java.net.Socket;
public class TestClient {//客户端
//这是一个main方法，是程序的入口：
public static void main(String[] args) throws IOException {
//1.创建套接字：指定服务器的ip和端口号：
Socket s = new Socket("192.168.199.217",8888);
//2.对于程序员来说，向外发送数据 感受 --》利用输出流：
OutputStream os = s.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
//利用这个OutputStream就可以向外发送数据了，但是没有直接发送String的方法
//所以我们又在OutputStream外面套了一个处理流：DataOutputStream
dos.writeUTF("你好");
//接收服务器端的回话--》利用输入流：
InputStream is = s.getInputStream();
DataInputStream dis = new DataInputStream(is);
String str = dis.readUTF();
System.out.println("服务器端对我说："+str);
//3.关闭流 + 关闭网络资源：
dis.close();
is.close();
dos.close();
os.close();
s.close();
}
}
服务器端：
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class TestServer {//服务器
//这是一个main方法，是程序的入口：
public static void main(String[] args) throws IOException {
//1.创建套接字： 指定服务器的端口号
ServerSocket ss = new ServerSocket(8888);
//2.等着客户端发来的信息：
Socket s = ss.accept();//阻塞方法:等待接收客户端的数据，什么时候接收到数据，什么时候程序继续向下执行。
//accept()返回值为一个Socket，这个Socket其实就是客户端的Socket
//接到这个Socket以后，客户端和服务器才真正产生了连接，才真正可以通信了
//3.感受到的操作流：
InputStream is = s.getInputStream();
DataInputStream dis = new DataInputStream(is);
//4.读取客户端发来的数据：
String str = dis.readUTF();
System.out.println("客户端发来的数据为："+str);
//向客户端输出一句话：---》操作流---》输出流
OutputStream os = s.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
dos.writeUTF("你好，我是服务器端，我接受到你的请求了");
//5.关闭流+关闭网络资源：
dos.close();
os.close();
dis.close();
is.close();
s.close();
ss.close();
}
}
注意：关闭防火墙
三、对象流传送
封装的User类：
import java.io.Serializable;
public class User implements Serializable {
private static final long serialVersionUID = 9050691344308365540L;
private String name;
private String pwd;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getPwd() {
return pwd;
}
public void setPwd(String pwd) {
this.pwd = pwd;
}
public User(String name, String pwd) {
this.name = name;
this.pwd = pwd;
}
}
客户端：
import java.io.*;
import java.net.Socket;
import java.util.Scanner;
public class TestClient {//客户端
//这是一个main方法，是程序的入口：
public static void main(String[] args) throws IOException {
//1.创建套接字：指定服务器的ip和端口号：
Socket s = new Socket("192.168.199.217",8888);
//录入用户的账号和密码：
Scanner sc = new Scanner(System.in);
System.out.println("请录入您的账号：");
String name = sc.next();
System.out.println("请录入您的密码：");
String pwd = sc.next();
//将账号和密码封装为一个User的对象：
User user = new User(name,pwd);
//2.对于程序员来说，向外发送数据 感受 --》利用输出流：
OutputStream os = s.getOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(os);
oos.writeObject(user);
//接收服务器端的回话--》利用输入流：
InputStream is = s.getInputStream();
DataInputStream dis = new DataInputStream(is);
boolean b = dis.readBoolean();
if(b){
System.out.println("恭喜，登录成功");
}else{
System.out.println("对不起，登录失败");
}
//3.关闭流 + 关闭网络资源：
dis.close();
is.close();
oos.close();
os.close();
s.close();
}
}
服务器：
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class TestServer {//服务器
//这是一个main方法，是程序的入口：
public static void main(String[] args) throws IOException, ClassNotFoundException {
//1.创建套接字： 指定服务器的端口号
ServerSocket ss = new ServerSocket(8888);
//2.等着客户端发来的信息：
Socket s = ss.accept();//阻塞方法:等待接收客户端的数据，什么时候接收到数据，什么时候程序继续向下执行。
//accept()返回值为一个Socket，这个Socket其实就是客户端的Socket
//接到这个Socket以后，客户端和服务器才真正产生了连接，才真正可以通信了
//3.感受到的操作流：
InputStream is = s.getInputStream();
ObjectInputStream ois = new ObjectInputStream(is);
//4.读取客户端发来的数据：
User user = (User)(ois.readObject());
//对对象进行验证：
boolean flag = false;
if(user.getName().equals("娜娜")&&user.getPwd().equals("123123")){
flag = true;
}
//向客户端输出结果：---》操作流---》输出流
OutputStream os = s.getOutputStream();
DataOutputStream dos = new DataOutputStream(os);
dos.writeBoolean(flag);
//5.关闭流+关闭网络资源：
dos.close();
os.close();
ois.close();
is.close();
s.close();
ss.close();
}
}
四、加入完整的处理异常方式
服务器端：
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class TestServer {//服务器
//这是一个main方法，是程序的入口：
public static void main(String[] args) {
//1.创建套接字： 指定服务器的端口号
ServerSocket ss = null;
Socket s = null;
InputStream is = null;
ObjectInputStream ois = null;
OutputStream os = null;
DataOutputStream dos = null;
try {
ss = new ServerSocket(8888);
//2.等着客户端发来的信息：
s = ss.accept();//阻塞方法:等待接收客户端的数据，什么时候接收到数据，什么时候程序继续向下执行。
//accept()返回值为一个Socket，这个Socket其实就是客户端的Socket
//接到这个Socket以后，客户端和服务器才真正产生了连接，才真正可以通信了
//3.感受到的操作流：
is = s.getInputStream();
ois = new ObjectInputStream(is);
//4.读取客户端发来的数据：
User user = (User)(ois.readObject());
//对对象进行验证：
boolean flag = false;
if(user.getName().equals("娜娜")&&user.getPwd().equals("123123")){
flag = true;
}
//向客户端输出结果：---》操作流---》输出流
os = s.getOutputStream();
dos = new DataOutputStream(os);
dos.writeBoolean(flag);
} catch (IOException | ClassNotFoundException e) {
e.printStackTrace();
} finally {
//5.关闭流+关闭网络资源：
try {
if(dos!=null){
dos.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(os!=null){
os.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(ois!=null){
ois.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(is!=null){
is.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(s!=null){
s.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(ss!=null){
ss.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
客户端：
import java.io.*;
import java.net.Socket;
import java.util.Scanner;
public class TestClient {//客户端
//这是一个main方法，是程序的入口：
public static void main(String[] args){
//1.创建套接字：指定服务器的ip和端口号：
Socket s = null;
OutputStream os = null;
ObjectOutputStream oos = null;
InputStream is = null;
DataInputStream dis = null;
try {
s = new Socket("192.168.199.217",8888);
//录入用户的账号和密码：
Scanner sc = new Scanner(System.in);
System.out.println("请录入您的账号：");
String name = sc.next();
System.out.println("请录入您的密码：");
String pwd = sc.next();
//将账号和密码封装为一个User的对象：
User user = new User(name,pwd);
//2.对于程序员来说，向外发送数据 感受 --》利用输出流：
os = s.getOutputStream();
oos = new ObjectOutputStream(os);
oos.writeObject(user);
//接收服务器端的回话--》利用输入流：
is = s.getInputStream();
dis = new DataInputStream(is);
boolean b = dis.readBoolean();
if(b){
System.out.println("恭喜，登录成功");
}else{
System.out.println("对不起，登录失败");
}
} catch (IOException e) {
e.printStackTrace();
} finally{
//3.关闭流 + 关闭网络资源：
try {
if(dis!=null){
dis.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(is!=null){
is.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(oos!=null){
oos.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(os!=null){
os.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(s!=null){
s.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
五、多线程接收用户请求
问题：
服务器针对一个请求服务，之后服务器就关闭了（程序自然结束了）
需要解决：
服务器必须一直在监听 ，一直开着，等待客户端的请求
在当前代码中，客户端不用动了
更改服务器代码：
服务器线程：
import java.io.*;
import java.net.Socket;
public class ServerThread extends Thread {//线程：专门处理客户端的请求
InputStream is = null;
ObjectInputStream ois = null;
OutputStream os = null;
DataOutputStream dos = null;
Socket s = null;
public ServerThread(Socket s){
this.s = s;
}
@Override
public void run() {
try{
//2.等着客户端发来的信息：
is = s.getInputStream();
ois = new ObjectInputStream(is);
//4.读取客户端发来的数据：
User user = (User)(ois.readObject());
//对对象进行验证：
boolean flag = false;
if(user.getName().equals("娜娜")&&user.getPwd().equals("123123")){
flag = true;
}
//向客户端输出结果：---》操作流---》输出流
os = s.getOutputStream();
dos = new DataOutputStream(os);
dos.writeBoolean(flag);
}catch (IOException | ClassNotFoundException e) {
e.printStackTrace();
}finally {
try {
if(dos!=null){
dos.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(os!=null){
os.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(ois!=null){
ois.close();
}
} catch (IOException e) {
e.printStackTrace();
}
try {
if(is!=null){
is.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
服务器端：
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class TestServer {//服务器
//这是一个main方法，是程序的入口：
public static void main(String[] args) {
System.out.println("服务器启动了");
//1.创建套接字： 指定服务器的端口号
ServerSocket ss = null;
Socket s = null;
int count = 0;//定义一个计数器，用来计数 客户端的请求
try {
ss = new ServerSocket(8888);
while(true){//加入死循环，服务器一直监听客户端是否发送数据
s = ss.accept();//阻塞方法:等待接收客户端的数据，什么时候接收到数据，什么时候程序继续向下执行。
//每次过来的客户端的请求 靠 线程处理：
new ServerThread(s).start();
count++;
//输入请求的客户端的信息：
System.out.println("当前是第"+count+"个用户访问我们的服务器,对应的用户是："+s.getInetAddress());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
来源：https://blog.csdn.net/qq_31762741/article/details/117138831
0
投稿猜你喜欢
- 一、在学习枚举之前，首先来听听枚举的优点。1、枚举能够使代码更加清晰，它允许使用描述性的名称表示整数值。2、枚举使代码更易于维护，有助于确保
- 在使用手机时，蓝牙通信给我们带来很多方便。那么在Android手机中怎样进行蓝牙开发呢？本文以实例的方式讲解Android蓝牙开发的知识。&
- 一、结论先行ArrayList在JDK1.8与JDK1.7底层区别JDK1.7：ArrayList像饿汉式，直接创建一个初始容量为10的数组
- 抽象类分析Action这一部分主要是数据（索引）的操作和部分集群信息操作。 所有的请求通过client转发到对应的action上然
- java的Console类的使用方法及实例JDK 6中提供了java.io.Console类专用来访问基于字符的控制台设备。如果你的Java
- 本文实例讲述了android中Bitmap用法。分享给大家供大家参考。具体如下：在Android SDK中可以支持的图片格式如下：png ,
背景我们项目一开始的所有提示都是中文，后来要做国际化。发现项目中的带双引号的中文居然有 2.3 w 多条！！！简直让人欲- 以下是代码：package cn.study.concurrency.ch11;/** * 锁分段 * @author xiaof * */
- 上一篇说的CountDownLatch是一个计数器，类似线程的join方法，但是有一个缺陷，就是当计数器的值到达0之后，再调用CountDo
- 简介java中可以被称为Number的有byte，short，int，long，float，double和char，我们在使用这些Nubme
- 本文实例讲述了基于私钥加密公钥解密的RSA算法C#实现方法，是一种应用十分广泛的算法。分享给大家供大家参考之用。具体方法如下：一、概述RSA
- 目录引入依赖Java中使用GraphQL的API无参数简单查询带参数简单查询GraphQL可以通过Java的API来实现数据的查询，通过特定
- 1 简介AOP，即面向切面编程是很常用的技术，特别是在Java Web开发中。而最流行的AOP框架分别是Spring AOP和AspectJ
- 1、什么是Callback,什么时候需要使用Callbackcallback是回调的意思，一般我们需要2个类需要相互掉用，一个类把数据动态传
- AndroidManifest.xml <uses-feature>和<uses-permisstion>分析及比较
- 中国科学院开源协会镜像站地址:IPV4/IPV6: http://mirrors.opencas.cn 端口：80IPV4/IPV6: ht
- 在生产环境中，需要实时或定期监控服务的可用性。spring-boot 的actuator（监控）功能提供了很多监控所需的接口。简单的配置和使
- 在application.properties中填写中文信息，在读取该文件时会出现中文乱码问题。比如：application.propert
- 加载资源文件比较常用的有两种：一、用ClassLoader，说到这里就不得不提一下ClassLoader的分类，java内置的ClassLo
- 先看看效果图：1、XML布局引入<com.net168.lib.SortTabLayout android:id=&quo
