`
foryougeljh
  • 浏览: 113500 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论

socket

阅读更多
socket
socket构造方法有几种重载形式,除了不带参数的构造方法外,其它构造方式都试图与服务器建立连接,连接成功,就返回socket对象,连接失败,就会抛出异常。

如果需要设置等待超时时间,此时需要使用不带参数的构造方法
Socket socket = new Socket();
SocketAddress address = new InetSocketAddress("localhost",8000);
socket.connect(address, 60000);//等待建立连接的超时时间为1分钟
//如果1分钟内连接成功,则返回socket,否则抛出SocketTimeoutException

设置服务器地址
Socket(InetAddress address, int port) 创建一个流套接字并将其连接到指定IP地址的指定端口号
Socket(String host, int port) 创建一个流套接字并将其连接到指定主机上的指定端口号
InetAddress类代表服务器的IP地址,InetAddress提供一系列的静态工厂方法用于构造自身的实例
InetAddress address = InetAddress.getLocalHost() //返回本地主机
address = InetAddress.getByName("10.2.17.28") //在给定主机名的情况下确定主机的 IP 地址

设置客户端地址
默认情况下,客户端地址来自于客户端所在的主机,客户端的端口由操作系统随机分配,但socket类也提供2个构造方式用于显示的设置客户端的IP地址和端口
Socket(InetAddress address, int port, InetAddress localAddr, int localPort)
Socket(String host, int port, InetAddress localAddr, int localPort)
如果一个主机同时属于多个网络,它就可能有多个IP地址。
例如:一个主机在internet网络中的IP地址为"222.67.1.34",在一个局域网中的IP地址为"112.5.4.3".如果这个主机的客户端程序希望和同一局域网的一个服务器程序进行通信,客户端可以通过显示的申明IP地址和端口

客户端连接服务器可能抛出的异常
UnknownHostException:无法识别主机的名字和IP地址
ConnectException:没有服务器监听指定的端口或服务器进程拒绝连接(如超过服务端设置的请求队列长度)
SocketTimeoutException:连接超时
BindException:无法把socket与指定的本地IP地址或端口绑定
以上4个异常都直接或间接的继承IOException

服务器进程拒绝连接示例
服务端
public class SimpleServer {
public static void main(String[] args) throws Exception {
ServerSocket server = new ServerSocket(4001,2);//请求队列长度为2
Thread.sleep(60000);
}
}
客户端
public class SimpleClient {
private static Integer port = 4001;
public static void main(String[] args) throws Exception{
Socket socket = new Socket();
SocketAddress address = new InetSocketAddress("localhost",port);
socket.connect(address, port);//等待建立连接的超时时间为1分钟
System.out.println("第一次连接成功");

Socket socket1 = new Socket();
socket1.connect(address, port);
System.out.println("第二次连接成功");

Socket socket2 = new Socket();
socket2.connect(address, port);
System.out.println("第三次连接成功");
}
}
从打印接口可以看出,由于服务端已经有2个客户端连接请求,队列已满,SimpleClient第三次连接被拒绝

获取socket信息
getInetAddress() 获取服务器地址 getPort() 获取服务器端口
getLocalAddress() 获取本地地址 getLocalPort()获取本地端口
getInputStream() 获取输入流 getOutputStream() 获取输出流

关闭socket
当客户端与服务器通讯结束后应关闭socket,以释放socket占用的包括端口在内的资源
socket类提供了3个状态测试方法
isBound()
isClosed()
isConnected()

半关闭
进程A与进程B通过socket通讯,假定进程A输出数据,进程B读入数据,进程A如何告诉进程B所有数据已经输出完毕。
(一)当进程A与进程B交换的是字节流,并且都是一行一行读写数据,可以事先约定以一个特殊标志作为结束标志。
如以字符串"bye"作为结束标志,当进程A向进程B发送一行字符串"bye",进程B读到这行数据后就停止读取数据。
(二)进程A先发送一个消息,告诉线程B所发送的正文长度,然后在发送正文。进程B先获知进程A将发送的正文长度,接下来只需要读完改长度的字符串就停止读取数据。
(三)进程A发送完数据后,关闭socket
(四)进程A发送完数据后,关闭socket输出流
socket提供关闭输入输出流的方法(shutdownInput() ,shutdownOutput() )
socket也提供了2个状态测试方法用于判断输入输出流是否关闭(isInputShutdown(),isOutputShutdown())

socket选项设置
TCP_NODELAY 表示立即发送数据
setTcpNoDelay(boolean on)
getTcpNoDelay()
默认情况下,发送数据采用Negale算法,Negale算法是值发送方发送数据不会立刻发出,而是先放在缓存里,等缓冲区满了再发出。Negale算法适用于发送方需要发送大批数据,并且接收方会及时作出回应的场合,这种算法通过减少传输数据的次数来提高通信效率。
如果发送小批量数据,并且接收方不一定会立即发送响应数据,那么Negale算法反而会使发送方运行慢,对于GUI程序,如网络游戏(服务端需要实时跟踪客户端鼠标的移动),客户端鼠标位置移动信息需要实时发送到服务端,由Negale采用缓存,大大降低实时响应速度,导致客户端程序运行很慢。
TCP_NODELAY的默认值为false,表示采用Negale算法,调用setTcpNoDelay(true)方法,会关闭socket的缓存,确保数据及时发送,如果socket底层不支持TCP_NODELAY选项,调用方法是回抛出SocketException


SO_REUSEADDR 是否允许重用socket所绑定的本地地址
当接收方通过socket close方法关闭socket时,如果网络上还有发送到这个socket数据,底层socket不会立即释放本地端口,而是等待一段时间,确保接收到了网络上发送过来的延迟数据,然后在释放端口。socket接收到延迟数据后,不会对这些数据作任何处理。socket接收延迟数据目的是确保这些数据不会被其他碰巧绑定到同样的端口的新进程收到。
客户端一般采用随机端口,因此出现两个客户端绑定到同样的端口可能性不大,而服务器端都是使用固定端口,当服务器端程序关闭后,有可能他的端口还会被占用一段时间,如果此时立刻在此主机上重启服务器程序,由于服务器端口被占用,使得服务器程序无法绑定改端口,启动失败。
为了确保一个进程关闭socket后,即使它还没释放端口,同一主机上的其他进程可以立刻重用该端口,可以调用socket的setReuseAddress(true)
需要注意的是setReuseAddress(boolean on)方法必须在socket还未绑定到一个本地端口之前调用,否则无效


SO_TIMEOUT 表示接收数据时的等待超时时间,以毫秒为单位,默认值为0,表示无限等待
当通过socket的输入流读数据时,如果还没有数据,就会等待,
如byte [] buffer = new byte[1024];
InputStream is = socket.getInputStream();
is.read(buffer);
如果输入流中没有数据,is.read(buffer)会等待发送方发送数据,直到满足以下情况才结束
(一)输入流中已有1024字节
(二)......................
(三)已经读到流的末尾,返回-1
(四)连接已断,抛出IOExcepton
(五)超过了socket设置setsoTimeout()方法设置了等待超时时间,setsoTimeout()方法必须在读取数据之前才有效
当输入流的read方法抛出socketTimeoutExcepton后,如果socket任然是连接的,可以再次读取数据

SO_LINGER 表示当执行socket的close方法时,是否立即关闭底层的socket
用来控制socket关闭时的行为,默认情况下,执行socket close方法,该方法立即换回,但底层的socket并不立即关闭,直到发送完所有剩余数据,才会真正关闭socket,断开连接。
socket.setSoLinger(true,0),执行socket close方法后,该方法立即换回,但底层的socket也立即关闭,未发完的数据将被丢弃。
socket.setSoLinger(true,3600)执行socket close方法后,该方法不会立即换回,而是进入阻塞状态,同时底socket会尝试发送完剩余的数据,只有当数据发送完毕或时间超时时,才会关闭socket,单位为秒
(程序发送数据到网络时,由网络发送数据到接收方,当程序关闭socket时,数据可能还在网络上传输)

SO_RCVBUF 表示接收数据的缓冲区大小
一般来说,传输较大的连续输入快可以使用较大的缓冲区,这可以减少传输数据的次数,提高传输效率,而对于交互频繁且单次传送数据量较小的通信方式(Telnet和网络游戏),则应该采用小的缓冲区,确保小批量的数据能及时发送给对方,如果底层socket不支持SO_RCVBUF,调用方法会抛出SocketException

SO_SNDBUF 表示发送数据的缓冲区大小

分享到:
评论

相关推荐

    socket概念socket概念socket概念

    socket概念socket概念socket概念

    SocketTool(很好用的socket测试工具)

    SocketTool调试软件是一款网络TCP/UDP通信调试工具,本工具集功能强大与简单易用为一体,是无需安装的免费绿色软件。 它可以帮助网络编程人员、网络维护人员检查所开发的网络应用软硬件的通信状况。 是一款非常好用...

    TCP/UDP socket 调试工具

    TCP/UDP socket 调试工具 TCP/UDP socket 调试工具 SocketTool调试软件是一款网络TCP/UDP通信调试工具,本工具集功能强大与简单易用为一体,是无需安装的免费绿色软件。她可以帮助网络编程人员、网络维护人员检查所...

    HP-Socket5.3.2

    HP-Socket是一套通用的高性能TCP/UDP/HTTP 通信框架,包含服务端...HP-Socket对通信层完全封装,应用程序不必关注通信层的任何细节;HP-Socket提供基于事件通知模型的API接口,能非常简单高效地整合到新旧应用程序中

    HPSocket C++控制台版DEMO.rar

    一个开源的高性能IOCP(完成端口)网络通信封装框架《HP-Socket》的使用实例,官方的DEMO只有MFC对话框的版本,对于刚接触这个框架的新手不太容易把代码移植到自己的项目。 此DEMO使用标准C++控制台来实现,对于刚...

    SuperSocket Socket C# 通讯详细介绍

    SuperSocket Socket C# 通讯详细介绍,不错的 Socket,学习很有用处SuperSocket Socket 技能

    基于vue3+socket.io的聊天应用,比较完整,略好看.zip

    基于vue3+socket.io的聊天应用,比较完整,略好看 基于vue3+socket.io的聊天应用,比较完整,略好看 基于vue3+socket.io的聊天应用,比较完整,略好看 基于vue3+socket.io的聊天应用,比较完整,略好看 基于vue3...

    c#超级Socket库SuperSocket,SOCKET多线程编程

    c#超级Socket库SuperSocket,SOCKET多线程编程

    SpringBoot实现Socket.io消息推送(java+html)

    因为项目中需要实现后端推荐消息到前端,经过研究和讨论,最终决定用Socket.io实现消息的推送,而在SpringBoot用Socket.io实现消息推送在网上的例子太少了,本人研究了一天的Socket.io,终于对Socket.io的应用比较...

    Android TCP Socket通信实例Demo源码Apk下载

    最近有个项目模块需要用到TCP Socket通讯,遇到了一个大坑,所以做了这个Demo。 本Demo主要实现了安卓(Android)TCP 客户端(Client)和服务器(Server)Demo的Socket通讯。以及对接硬件的项目数据在十六进制&&byte&&int...

    socket调试工具 socketTool

    sokit socket调试 tcp udp for mac

    使用socket和DTU通信.doc

    为了方便网络编程,90年代初,由microsoft联合了...socket实际在计算机中提供了一个通信端口,可以通过这个端口与任何一个具有socket接口的计算机通信。应用程序在网络上传输,接收的信息都通过这个socket接口来实现。

    SuperSocket-master_Socket基于TCP、UDP

    SuperSocket-master_Socket 、Socket、SuperSocket、TCP、UDP

    HPSocket.Net-develop_hpsocket.net_HPSocket_.net_socket_tcp_

    C# 版socket 收发TCP协议有模版样例

    9772.zip_mql_mql4 socket_socket

    socket功能,在mql中是用socket套接字

    C++用win socket api实现的简单的聊天室程序

    为实现多用户聊天,采用了服务器端分发线程处理,主线程阻塞接受客户端socket, 每接收一个socket连接就分发一个线程处理,通过全局变量保存所有客户socket 连接,在每个处理线程中通过客户socket 连接池中每个客户...

    目前.NET最强SOCKET框架组“北风之神”(ZYSOCKET) 3.0 源代码

    传统的SOCKET? 我告诉你 你OUT了 因为现在开始你要使用 “北风之神”了 你还在为组合数据包 头痛吗? 你还在为性能不达标 烦恼吗? 现在不必了,因为 使用我的 吹着北风 而构思出来 的SOCKET框架 一切问题映刃...

    C Socket通信多线程数据双向收发实例VS2010(全部源码)

    最新的C C++Socket技术总结! 开发环境:VS2010 实现功能: 1、运用多线程和Socket技术实现Socket Server端侦听多个客户端请求; 2、实现服务器端循环处理客户端不同请求从而实现不同测试要求,并向客户端循环发送...

    基于QT - SOCKET 的 C++ 实现矩阵压力数据采集及压力云图现实。.zip

    基于QT - SOCKET 的 C++ 实现矩阵压力数据采集及压力云图现实。 基于QT - SOCKET 的 C++ 实现矩阵压力数据采集及压力云图现实。 基于QT - SOCKET 的 C++ 实现矩阵压力数据采集及压力云图现实。 基于QT - SOCKET 的 ...

Global site tag (gtag.js) - Google Analytics