欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java socket通讯实现过程及问题解决

程序员文章站 2022-06-06 15:21:26
这篇文章主要介绍了java socket通讯实现过程及问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 本来是打算验证jav...

这篇文章主要介绍了java socket通讯实现过程及问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

本来是打算验证java socket是不是单线程操作,也就是一次只能处理一个请求,处理完之后才能继续处理下一个请求。但是在其中又发现了许多问题,在编程的时候需要十分注意,今天就拿出来跟大家分享一下。

首先先建立一个服务端代码,运行时也要先启动此程序。

package com.test.some.socket;

import java.io.*;
import java.net.inetaddress;
import java.net.serversocket;
import java.net.socket;
import java.net.unknownhostexception;

/**
* @description: socket服务端代码
* @author:   haoqiangwang3
* @createdate: 2020/1/9
*/
public class mysocketserver1 {
  // 服务器监听端口
  private static int port = 8081;

  public static void main(string[] args) throws interruptedexception {
    try {
      //1.得到一个socket服务端
      serversocket serversocket = new serversocket(port);
      while (true) {

        // 2.等待socket客户端的请求。accept方法在有连接请求时才会返回
        system.out.println("等待客户端请求。。。");
        socket socket = serversocket.accept();
        system.out.println("客户端请求来了。。。");

        // 3.获取socket输入流
        inputstream inputstream = socket.getinputstream();
        /* bufferedreader bufferedreader = new bufferedreader(new inputstreamreader(inputstream));
        system.out.println("接收到的请求数据为:" + bufferedreader.readline());*/
        // 读取请求内容的缓冲区
        byte[] bytes = new byte[1024];
        int length = 0;
        stringbuilder sb = new stringbuilder();
        //获取客户端请求的内容
        while ((length = inputstream.read(bytes)) != -1) {
          sb.append(new string(bytes, 0, length, "utf-8"));
        }
        system.out.println("接收到的请求数据为:" + sb.tostring());          
          //thread.sleep(50000);          // 4.获取socket输出流
        outputstream outputstream = socket.getoutputstream();
        printwriter printwriter = new printwriter(outputstream);
        string backstr = "服务端接收到了请求";
        printwriter.write(new string(backstr.getbytes(), "utf-8"));
        printwriter.flush();

        //5.关闭资源
        //bufferedreader.close();
        inputstream.close();
        printwriter.close();
        outputstream.close();
        socket.close();
      }

    } catch (ioexception e) {
      system.err.println("socket监听失败!" + e);
    }
  }

}

此代码模拟了正常系统成socket服务端的方式,就是一个无限循环监听我们绑定的端口,当有客户端请求来了之后进行处理。

下面就是客户端请求代码

package com.test.some.socket;

import java.io.inputstream;
import java.io.outputstream;
import java.io.printwriter;
import java.net.socket;

/**
* @description: socket客户端代码
* @author:   haoqiangwang3
* @createdate: 2020/1/9
*/
public class mysocketclient1 {
  //socket请求ip地址
  private static string host = "127.0.0.1";

  //socket请求端口
  private static int port = 8081;

  public static void main(string[] args) {
    try {
      //1.建立一个客户端
      socket socket = new socket(host, port);

      //2.得到socket输出流
      outputstream outputstream = socket.getoutputstream();
      printwriter printwriter = new printwriter(outputstream);
      string sendstr = "发送数据1";
      //发送数据
      printwriter.write(sendstr);
      printwriter.flush();
      socket.shutdownoutput();

      //3.得到socket输入流
      inputstream inputstream = socket.getinputstream();
      stringbuilder sb = new stringbuilder();
      byte[] bytes = new byte[1024];
      while (inputstream.read(bytes) != -1) {
        sb.append(new string(bytes, "utf-8"));
      }
      system.out.println("接收到的返回数据为:" + sb);

      //4.关闭资源
      printwriter.close();
      outputstream.close();
      inputstream.close();
      socket.close();
    } catch (exception e) {
      system.err.println("socket请求失败" + e);
    }
  }

}

客户端代码主要就是向服务端发送数据,然后等待服务端的响应,打印出服务端的响应内容。

最终打印结果如下。服务端:

Java socket通讯实现过程及问题解决

客户端:

Java socket通讯实现过程及问题解决

首先明确几个概念,下面将会用到。

flush()方法:用于清空缓冲区的数据流,进行流的操作时,数据先被读到内存缓冲区中,然后再用数据写到文件中。

socket.shutdownoutput()方法:他是一种单向关闭流的方法,即关闭客户端的输出流并不会关闭服务端的输出流。通过shutdownoutput()方法只是关闭了输出流,但socket仍然是连接状态,连接并未关闭。

printwriter.close()方法:如果直接关闭输入或者输出流,即:in.close()或者out.close(),会直接关闭socket。

流中的关闭顺序:一般情况下是:先打开的后关闭,后打开的先关闭。另一种情况:看依赖关系,如果流a依赖流b,应该先关闭流a,再关闭流b,例如处理流a依赖节点流b,应该先关闭处理流a,再关闭节点流b。当然完全可以只关闭处理流,不用关闭节点流。处理流关闭的时候,会调用其处理的节点流的关闭方法。如果将节点流关闭以后再关闭处理流,会抛出io异常。

下面总结下我遇到的问题。

1.客户端发送数据部分的代码,printwriter.flush(); socket.shutdownoutput(); 这两句代码十分的重要,flush()方法如果不添加的话,服务端接收到的数据将为空,shutdownoutput()方法不添加的话,服务端将一直等待读取客户端的数据,不会往下进行,大家可以自测一下。我自己的理解是flush()的作用是为了把数据从内存中刷新到socket流中,shutdownoutput()方法是告诉服务端,我没有东西要传输了,所以服务端也就会停止等待读取客户端发送的内容,程序就可以继续向下走。

2.打开服务端中的sleep方法,在新建一个客户端,同时开启请求服务端,会发现服务端确实是一个连接一个连接的处理,所以这也是socket性能所在的问题。

3.如果不用字符流读取,客户端发送数据直接用outputstream.write(sendstr.getbytes());,可以发现此时不用调用flush()方法,但是socket.shutdownoutput()依然需要。这是因为直接读取到socket的输出流,并没有读到内存中。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。