Java使用Socket简单通讯详解
更新时间：2021年08月11日 15:18:03 作者：Aputonos
这篇文章主要介绍了Java使用Socket简单通讯详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
Java实现基于Socket的简单通信
一.ServerSocket
1.使用JavaFX写的小界面，方便观察客户端连接情况
TextArea ta = new TextArea();
Scene scene = new Scene(new javafx.scene.control.ScrollPane(ta), 450, 200);
primaryStage.setTitle("Server");
primaryStage.setScene(scene);
primaryStage.show();
2.创建ServerSocket并处理客户端连接并显示客户端基本信息
两个客户端连接后进行通信，未能实现动态处理。
new Thread(() -> {
try {
ServerSocket serverSocket = new ServerSocket(8000);
Platform.runLater(() -> {
ta.appendText(new Date() + " : Server started at " + "\n");
ta.appendText(new Date() + " : wait to persons to join the chat" + "\n");
});
while (true){
Socket person1 = serverSocket.accept();
number++;
InetAddress inetAddress1 = person1.getInetAddress();
Platform.runLater(() -> {
ta.appendText(new Date() + ": Person" + number + "joined the chat" + "\n");
ta.appendText(new Date() + ": Person" + number + "'s host name is " + inetAddress1.getHostName() + "\n");
ta.appendText(new Date() + ": Person" + number + "'s host address is " + inetAddress1.getHostAddress() + "\n");
ta.appendText(new Date() + ": wait for Person2 " + "\n");
});
Socket person2 = serverSocket.accept();
number++;
InetAddress inetAddress2 = person2.getInetAddress();
Platform.runLater(() -> {
ta.appendText(new Date() + ": Person" + number + "joined the chat" + "\n");
ta.appendText(new Date() + ": Person" + number + "'s host name is " + inetAddress2.getHostName() + "\n");
ta.appendText(new Date() + ": Person" + number + "'s host address is " + inetAddress2.getHostAddress() + "\n");
ta.appendText(new Date() + ": Start the chat " + "\n");
});
new Thread(new HandleChat(person1,person2)).start();
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
} catch (IOException e) {
e.printStackTrace();
}
}).start();
3.新建Handle类处理接收发送两个客户端的消息
只实现了一人一句的效果，没有实现一人连续发送消息对方也能正确接收。
class HandleChat implements Runnable{
Socket person1;
Socket person2;
public HandleChat(Socket person1,Socket person2){
this.person1 = person1;
this.person2 = person2;
}
@Override
public void run() {
try {
DataInputStream fromPerson1 = new DataInputStream(person1.getInputStream());
DataOutputStream toPerson1 = new DataOutputStream(person1.getOutputStream());
DataInputStream fromPerson2 = new DataInputStream(person2.getInputStream());
DataOutputStream toPerson2 = new DataOutputStream(person2.getOutputStream());
while (true){
String passage1 = fromPerson1.readUTF();
toPerson2.writeUTF(passage1);
String passage2 = fromPerson2.readUTF();
toPerson1.writeUTF(passage2);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
思考后将HandleChat类中对两个客户端的接收发送消息处理放在两个线程中，就可以实现两个客户端自由通信。
new Thread(() -> {
while (true) {
try {
String passage2 = fromPerson2.readUTF();
toPerson1.writeUTF(passage2);
} catch (IOException e) {
e.printStackTrace();
}
}
}).start();
new Thread(() -> {
while (true) {
try {
String passage1 = fromPerson1.readUTF();
toPerson2.writeUTF(passage1);
} catch (IOException e) {
e.printStackTrace();
}
}
}).start();
二.Socket
1.同样的编写一个客户端界面
BorderPane pane = new BorderPane();
pane.setPadding(new Insets(5));
pane.setStyle("-fx-border-color: green");
pane.setLeft(new Label("Enter a radius: "));
TextField tf = new TextField();
tf.setAlignment(Pos.BASELINE_RIGHT);
pane.setCenter(tf);
BorderPane mainPane = new BorderPane();
TextArea ta = new TextArea();
mainPane.setCenter(new ScrollPane(ta));
mainPane.setTop(pane);
Scene scene = new Scene(mainPane,450,200);
primaryStage.setTitle("Client");
primaryStage.setScene(scene);
primaryStage.show();
2.创建Socket连接客户端并获取输入输出流
try {
// 创建一个连接服务器端的Socket
Socket socket = new Socket("localhost",8000);
// 获得输入输出流
toServer = new DataOutputStream(socket.getOutputStream());
fromServer = new DataInputStream(socket.getInputStream());
} catch (IOException e) {
e.printStackTrace();
}
3.添加编辑框监听处理消息发送
// 编辑框事件监听
tf.setOnAction(e ->{
String passage = tf.getText().trim();
tf.clear();
try {
toServer.writeUTF(passage);
toServer.flush();
ta.appendText("Me " + ": " + passage + "\n");
} catch (IOException e1) {
e1.printStackTrace();
}
});
4.创建新线程从服务器上接收消息
// 新线程从服务器读取信息
new Thread(() -> {
while (true) {
try {
String passage = fromServer.readUTF();
ta.appendText("He : " + passage + "\n");
} catch (IOException e) {
e.printStackTrace();
}
}
}).start();
三.测试
四.总结
1.原理流程
2.不足之处
只是简单实现了静态两客户端聊天的功能，并且只能够第一个链接上的用户先发送消息，且一人发送消息后只能等待接收另一个人的消息后才能再次发送消息。之后的时间希望能加以改进。
到此这篇关于Java使用Socket简单通讯详解的文章就介绍到这了,更多相关Java使用Socket简单通讯内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
装饰模式是指在不改变现有对象结构的情况下，动态地给该对象增加一些职责（即增加其额外功能）的模式，它属于对象结构型模式。本文将为大家详细介绍一下装饰模式，感兴趣的可以了解一下2021-12-12
SpringBoot使用WebJars统一管理静态资源的方法
这篇文章主要介绍了SpringBoot使用WebJars统一管理静态资源的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-12-12
下面小编就为大家带来一篇完美解决在Servlet中出现一个输出中文乱码的问题。小编觉得挺不错的现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-01-01
Java 字节码指令是 JVM 体系中非常难啃的一块硬骨头，我估计有些读者会有这样的疑惑，“Java 字节码难学吗？我能不能学会啊？”本文带领大家一探究竟，帮助大家搞懂java底层代码如何执行2021-08-08
SpringCloud之服务注册与发现Spring Cloud Eureka实例代码
这篇文章主要介绍了SpringCloud之服务注册与发现Spring Cloud Eureka实例代码，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2018-04-04
这篇文章主要介绍了关于Mybatis中foreach遍历Map的实现示例,MyBatis 是一款优秀的半自动的ORM持久层框架，它支持自定义 SQL、存储过程以及高级映射,需要的朋友可以参考下2023-05-05
希尔排序是希尔(Donald Shell)于1959年提出的一种排序算法，其也是一种特殊的插入排序，即将简单的插入排序进行改进后的一个更加高效的版本，也称缩小增量排序。本文通过图片和示例讲解了希尔排序的实现，需要的可以了解一下2022-11-11
这篇文章主要介绍了SpringBoot框架整合Mybatis的简单攻略，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2021-10-10
下面小编就为大家带来一篇java object 之clone方法全面解析。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧2016-06-06
springboot简单快捷方便的优点深受用户喜爱，springboot开发环境搭建过程是每个开发者必须要做的工作，今天小编写的一篇教程关于Spring Boot项目搭建方法，通过两种方式给大家介绍的非常详细，需要的朋友参考下吧2021-06-06
最新评论