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 条评论
登录 后参与评论

相关文章

来自专栏非著名程序员

Android Volley核心源码解析

? 闲聊Volley Volley下载 Volley.jar及源码下载:http://download.csdn.net/detail/qq_172500...

21080
来自专栏木宛城主

Unity应用架构设计(13)——日志组件的实施

对于应用程序而言,日志是非常重要的功能,通过日志,我们可以跟踪应用程序的数据状态,记录Crash的日志可以帮助我们分析应用程序崩溃的原因,我们甚至可以通过日志...

21750
来自专栏vue学习

Ajax

1、XMLHttpRequest对象 各浏览器(包括ie7+)都支持原生的XHR对象,在这些浏览器中创建XHR对象可以:

15440
来自专栏更流畅、简洁的软件开发方式

ajax的再次封装!

js的动态加载、缓存、更新以及复用 系列有点卡文,放心会继续的。先来点更基础的,为js的加载做点铺垫。   jQuery的ajax本来就很方便了,为啥还要在进一...

33580
来自专栏前端小吉米

打造多线程 Web

11030
来自专栏黄Java的地盘

如何模拟一个XMLHttpRequest请求用于单元测试——nise源码阅读与分析

在我们进行单元测试的过程中,如果我们需要对一些HTTP接口进行相关的业务测试,那么我们就需要来模拟HTTP请求的发送与响应,否则我们就无法完成测试的闭环。

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

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

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

14750
来自专栏Netkiller

Application Firewall Design

Application Firewall Design Web Application Firewall, 7layer Firewall ---- 目录 1....

30740
来自专栏佳爷的后花媛

php基础(一)

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

28020
来自专栏柠檬先生

jquery 操作ajax 相关方法

jQuery.get()   使用一个HTTP GET 请求从服务器加载数据。   jQuery.get(url [,data] [,success(dat...

328100

扫码关注云+社区

领取腾讯云代金券