服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|VB|R语言|JavaScript|易语言|vb.net|

服务器之家 - 编程语言 - Java教程 - Java使用Socket简单通讯详解

Java使用Socket简单通讯详解

2021-11-15 10:58Aputonos Java教程

这篇文章主要介绍了Java使用Socket简单通讯详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下

 

Java实现基于Socket的简单通信 

 

一.ServerSocket

 

1.使用JavaFX写的小界面,方便观察客户端连接情况

Java使用Socket简单通讯详解

    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 "  + "
");
                    ta.appendText(new Date() + " : wait to persons to join the chat" + "
");
                });

                while (true){
                    Socket person1 = serverSocket.accept();
                    number++;
                    InetAddress inetAddress1 = person1.getInetAddress();
                    Platform.runLater(() -> {
                        ta.appendText(new Date() + ": Person"  + number + "joined the chat" + "
");
                        ta.appendText(new Date() + ": Person"  + number + ""s host name is " + inetAddress1.getHostName() + "
");
                        ta.appendText(new Date() + ": Person"  + number + ""s host address is " + inetAddress1.getHostAddress() + "
");
                        ta.appendText(new Date() + ": wait for Person2 " + "
");
                    });

                    Socket person2 = serverSocket.accept();
                    number++;
                    InetAddress inetAddress2 = person2.getInetAddress();
                    Platform.runLater(() -> {
                        ta.appendText(new Date() + ": Person"  + number + "joined the chat" + "
");
                        ta.appendText(new Date() + ": Person"  + number + ""s host name is " + inetAddress2.getHostName() + "
");
                        ta.appendText(new Date() + ": Person"  + number + ""s host address is " + inetAddress2.getHostAddress() + "
");
                        ta.appendText(new Date() + ": Start the chat " + "
");
                    });

                    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.同样的编写一个客户端界面

Java使用Socket简单通讯详解

        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 + "
");
            } catch (IOException e1) {
                e1.printStackTrace();
            }
        });

 

4.创建新线程从服务器上接收消息

//        新线程从服务器读取信息
        new Thread(() -> {
            while (true) {
                try {
                    String passage = fromServer.readUTF();
                    ta.appendText("He : " + passage + "
");
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }).start();

 

三.测试

Java使用Socket简单通讯详解

 

四.总结

 

1.原理流程

Java使用Socket简单通讯详解

 

2.不足之处

只是简单实现了静态两客户端聊天的功能,并且只能够第一个链接上的用户先发送消息,且一人发送消息后只能等待接收另一个人的消息后才能再次发送消息。之后的时间希望能加以改进。

到此这篇关于Java使用Socket简单通讯详解的文章就介绍到这了,更多相关Java使用Socket简单通讯内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家!

原文链接:https://blog.csdn.net/qq_43463475/article/details/85039512

延伸 · 阅读

精彩推荐
  • Java教程Java实现Json字符串与Object对象相互转换的方式总结

    Java实现Json字符串与Object对象相互转换的方式总结

    这篇文章主要介绍了Java实现Json字符串与Object对象相互转换的方式,结合实例形式总结分析了java基于Json-Lib、Org.Json、Jackson、Gson、FastJson五种方式转换json类型...

    时间在这里停顿4892021-07-19
  • Java教程java遍历读取整个redis数据库实例

    java遍历读取整个redis数据库实例

    这篇文章主要介绍了java遍历读取整个redis数据库实例,使用支持正则表达式的key搜索方法jedis.keys(“*”)实现,需要的朋友可以参考下 ...

    Java教程网3762019-11-23
  • Java教程Java根据Request获取客户端IP

    Java根据Request获取客户端IP

    这篇文章主要介绍了Java根据Request获取客户端IP的方法,非常不错,具有参考借鉴价值,需要的朋友可以参考下...

    xjh1010104652020-10-29
  • Java教程idea2020.3.3集成maven及遇到的坑(推荐)

    idea2020.3.3集成maven及遇到的坑(推荐)

    这篇文章主要介绍了idea2020.3.3集成maven的相关知识,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...

    小乌龟学后端5692021-08-27
  • Java教程java实用验证码的实现代码

    java实用验证码的实现代码

    这篇文章主要为大家介绍了java实用验证码的实现代码,验证码实际上就是随机选择一些字符以图片的形式展现在页面上,感兴趣的小伙伴们可以参考一下...

    小南风5362020-04-12
  • Java教程Java 实现定时任务的三种方法

    Java 实现定时任务的三种方法

    这篇文章主要介绍了Java 实现定时任务的三种方法,帮助大家更好的理解和学习使用Java,感兴趣的朋友可以了解下...

    Java技术栈8952021-08-23
  • Java教程Java中的final关键字详细介绍

    Java中的final关键字详细介绍

    这篇文章主要介绍了Java中的final关键字,有需要的朋友可以参考一下 ...

    java技术网3172019-10-29
  • Java教程JAVA线程用法详解

    JAVA线程用法详解

    这篇文章主要介绍了JAVA线程用法,配合实例针对Java中线程的开启、sleep、合并与让出等进行了较为深入的分析,需要的朋友可以参考下 ...

    shichen20141972019-11-27