java.net.Socket 解析

Socket构造

  1. public Socket() 构造一个Socket,因为没有指定目标主机和端口,所以不会通过网络进行连接。
  2. public Socket(Proxy proxy) 通过一个代理构建一个未连接的Socket。
  3. public Socket(String host, int port) 通过一个主机和端口构建一个Socket。构造Socket的时候会连接目标主机,如果连接不到目标主机则会抛出IOException或UnknownHostException异常。
  4. public Socket(InetAddress address, int port) 通过一个InetAddress 和端口构建一个Socket,构造的时候也会进行连接目标主机,同3。
  5. public Socket(String host, int port, InetAddress localAddr, int localPort) 通过一个要连接的远程主机和端口,并指定从本地哪个ip和端口连接。
  6. public Socket(InetAddress address, int port, InetAddress localAddr, int localPort) 通过一个要连接的远程主机和端口,并指定从本地哪个ip和端口连接。同5。

获取Socket相关的信息

获取远程主机相关信息

public SocketAddress getRemoteSocketAddress()
public InetAddress getInetAddress()
public int getPort()

获取本地相关信息

public SocketAddress getLocalSocketAddress()
public InetAddress getLocalAddress()
public int getLocalPort()

上面6个方法获取本地和远程主机端口相关的信息。如果socket未连接则返回null,如果socket已经关闭则返回已经连接过的本地和远程主机端口的信息。

connect方法

public void connect(SocketAddress endpoint) 
public void connect(SocketAddress endpoint, int timeout)

connet放提供了两个方法,一个是传入一个SocketAddress 进行连接目标地址 另一个是通过一个SocketAddress 和超时等待时间来连接目标地址。

代码示例:

Socket socket = new Socket();
SocketAddress socketAddr = new InetSocketAddress("www.baidu.com", 80);
socket.connect(socketAddr);
//socket.connect(socketAddr, 2000);

代码中使用了Socket的空构造函数进行构造Socket对象。空构造不会进行连接目标主机(因为没有设置目标地址),需要使用connet方法进行连接目标主机。

代理服务器

//构造代理服务器地址
SocketAddress sa = new InetSocketAddress("192.168.10.130", 808);
//构造Socket代理
Proxy proxy = new Proxy(Proxy.Type.SOCKS, sa);
//使用代理创建socket
Socket socket = new Socket(proxy);
//构造目标地址
SocketAddress socketAddr = new InetSocketAddress("www.baidu.com", 80);
//socket使用代理连接目标地址
socket.connect(socketAddr);

使用public Socket(Proxy proxy)构造方法来构造一个使用proxy的socket。 以后使用该socket的相关的网络操作都会通过代理服务器进行连接。

读取、写入数据

使用下面两个放进行向远程主机读取数据和写入数据进行交互。

public InputStream getInputStream()
public OutputStream getOutputStream()

通过这两个方法我们可以发现,使用socket进行交换操作,其实就是对流的操作。

下面是使用getInputStream和getOutputStream方法对远程主机进行交换的示例。

Socket socket = new Socket("127.0.0.1", 9000);
OutputStream os = socket.getOutputStream();
//通过OutputStream流向远程服务器写如数据
...
InputStream is = socket.getInputStream();
//通过InputStream流读取响应的数据。
...

半关闭连接

如果想关闭socket的输入或输出则可以使用一下两个方法。

public void shutdownInput()
public void shutdownOutput()

当调用shutdownInput()时,则不允许再次从socket中读取数据。 当调用shutdownOutPut()方法后会告诉流已经输入完成,不允许再次输入。对方读取流时,会接受到流结束标志(会返回-1)。

但关闭输入或输出是不会关闭socket的,因为他们不会释放本地端口,还需要调用socket的close()方法来关闭socket。

下面两个方法来判断socket的输入或输出流是否关闭。

public boolean isInputShutdown()
public boolean isOutputShutdown()

如果socket未连接(通过空构造方法构造的socket),也会返回false(未关闭状态)。

判断socket是否关闭

//是否连接过目标地址
public boolean isConnected()
//是否关闭过socket
public boolean isClosed()

isConnected方法并不是连接状态才返回true,而是只要连接过目标地址就返回true,哪怕已经关闭的socket也会返回true的。 isClosed方法是判断socket是否调用close()方法关闭过socket。 如果使用空构造方法构建socket而不连接目标主机,还没调用close方法,该方法会返回true。

所以要判断该socket是否连接目标地址需要这样判断

//打开过连接,但还没有关闭连接
if(socket.isConnected() && !socket.isClosed()){
     System.out.println("连接状态");
}else{
     System.out.println("未打开连接或已经关闭连接");
}

设置Socket选项

java中只支持9个选项。下面简单描述下

  1. TCP_NODELAY 不使用tcp缓冲区,来多少个字节就发送多少个字节。而不用等缓存区达到多少个字节再发送。
public void setTcpNoDelay(boolean on)
public boolean getTcpNoDelay()
  1. SO_REUSEADDR 当socket关闭后,程序不会立刻释放端口,而是等一段时间才释放。如果这时当前socket只是为了重启而无法立刻绑定到该端口上,此时使用该选项就可以立刻绑定到该端口上。
public void setReuseAddress(boolean on)
public boolean getReuseAddress()
InetAddress addr = InetAddress.getByName("192.168.31.186");
System.out.println(addr.getHostAddress());
Socket socket = new Socket("www.baidu.com",80,addr,9999);
//关闭后不会马上是否端口
socket.close();
//如果
socket.setReuseAddress(false);
socket = new Socket("www.baidu.com",80,addr,9000);
socket.close();
  1. SO_TIMEOUT
public synchronized int getSoTimeout()
  1. SO_LINGER
public int getSoLinger()
  1. SO_SNDBUF
  1. SO_RCVBUF
  1. SO_KEEPALIVE
public void setKeepAlive(boolean on)
  1. OOBINLINE
  1. IP_TOSS

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏web编程技术分享

小兔Java教程 - 三分钟学会Java文件上传

42912
来自专栏码匠的流水账

nginx gzip配置参数解读

本文主要解析一下nginx ngx_http_gzip_module以及ngx_http_gzip_static_module中的gzip相关配置参数。

1461
来自专栏前端杂谈

vue使用Axios做ajax请求

47012
来自专栏佳爷的后花媛

php基础(一)

static 是静态变量,在局部函数中存在且只初始化一次,使用过后再次使用会使用上次执行的结果; 作为计数,程序内部缓存,单例模式中都有用到。

2062
来自专栏编程软文

redis的使用和安装,redis基础和高级部分

3237
来自专栏菜鸟计划

跨域请求的常用方式及解释

同源策略 首先基于安全的原因,浏览器是存在同源策略这个机制的,同源策略阻止从一个域加载的脚本去获取另一个域上的文档属性。也就是说,受到请求的 URL 的域必须与...

3519
来自专栏JadePeng的技术博客

axios介绍与使用说明 axios中文文档

本周在做一个使用vuejs的前端项目,访问后端服务使用axios库,这里对照官方文档,简单记录下,也方便大家参考。 Axios 是一个基于 Promise 的 ...

2.2K9
来自专栏后端之路

Mybatis实现指定时间db只读方案

背景 由于定时任务集计要求,在每天凌晨指定时间需要做库表备份 如果用户对于某些数据进行操作可能导致一些数据不平 【库存】凌晨00:00:00-00:10:00之...

2556
来自专栏奔跑的蛙牛技术博客

java获取web数据和发送E-mail

java -classpath .:path/to/mail.jar path/to/message.txt 运行程序

1255
来自专栏前端小吉米

打造多线程 Web

993

扫码关注云+社区