bear_0X0000 2018-02-03 10:23 采纳率: 60%
浏览 3903
已采纳

JAVA中Socket对象如何重用多次?

试了一下,目前已知的 让socket发送流中的数据 只有一下三种方式

1.shutDown流
2.close流/close socket
3.sendUrgentData

前两种都会socket对象无法再次使用,如果想多次发送数据,只能用第3种。
有更优雅的方式实现socket重用吗?

  • 写回答

4条回答

  • 坎特 2018-02-03 12:23
    关注

    不是的,你得仔细了解一下socket的读写数据机制。
    关闭writer和关闭socket的时候,**发现buffer有数据没有写出,会写一遍**,但不是必须关闭流和关闭socket**才会写数据**。
    一般是通过输出流的 write()和flush()方法,完成写操作。
    想要多次的输出数据,首要条件就是socket不被close和outputStream没有close...
    顺便给你贴点代码

     public class TestSocket {
    
        public static void main(String[] args) throws IOException {
            int port = 10086;
            ServerSocket server = new ServerSocket(port);
            System.out.println("等待与客户端建立连接...");
            while (true) {
                Socket socket = server.accept();
                new Thread(new Task(socket)).start();
    
            }
            // server.close();
        }
    
        /**
         * 处理Socket请求的线程类
         */
        static class Task implements Runnable {
    
            private Socket socket;
    
            /**
             * 构造函数
             */
            public Task(Socket socket) {
                this.socket = socket;
            }
    
            @Override
            public void run() {
                try {
                    handlerSocket();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
    
            /**
             * 跟客户端Socket进行通信
             * 
             * @throws IOException
             */
            private void handlerSocket() throws Exception {
                for (;;) {
                    StringBuilder sb = new StringBuilder();
                    InputStream inputStream = socket.getInputStream();
                    String temp;
                    int index;
                    sb.append(inputStream.read());
                    System.out.println("Form Cliect[port:" + socket.getPort() + "] 消息内容:" + sb.toString());
                    // 回应客户端
                    Writer writer = new OutputStreamWriter(socket.getOutputStream(), "UTF-8");
                    writer.write(String.format("Hi", socket.getPort()));
                    writer.flush();
    //              writer.close();
    //              socket.close();
                }
            }
        }
    }
    
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)

报告相同问题?

悬赏问题

  • ¥15 如何在scanpy上做差异基因和通路富集?
  • ¥20 关于#硬件工程#的问题,请各位专家解答!
  • ¥15 关于#matlab#的问题:期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707,使系统具有较小的超调量
  • ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
  • ¥30 截图中的mathematics程序转换成matlab
  • ¥15 动力学代码报错,维度不匹配
  • ¥15 Power query添加列问题
  • ¥50 Kubernetes&Fission&Eleasticsearch
  • ¥15 報錯:Person is not mapped,如何解決?
  • ¥15 c++头文件不能识别CDialog