cn.orionsec.kit.net.socket

Class TcpReceive

java.lang.Object

cn.orionsec.kit.net.socket.TcpReceive

All Implemented Interfaces:

AutoCloseable

public class TcpReceive
extends Object
implements AutoCloseable

TCP Server 接收

Since:

2020/6/5 16:35

Version:

1.0.0

Author:

Jiahang Li

Constructor Summary

Constructors

Constructor and Description
TcpReceive(int port)

Method Summary

Modifier and Type	Method and Description
TcpReceive	accept(int count) 接收几个连接
TcpReceive	acceptThreadPool(ExecutorService acceptThreadPool)
TcpReceive	bufferSize(int bufferSize)
void	close()
TcpReceive	closePool() 关闭线程池
List<Socket>	findSocket(String host) 寻找客户端 socket
Socket	findSocket(String host, int port) 寻找客户端 socket
int	getPort()
List<Socket>	getReceiveSocketList()
ServerSocket	getServerSocket()
TcpReceive	sendAll(byte b)
TcpReceive	sendAll(byte[] bs) 批量发送数据
TcpReceive	sendAll(byte[] bs, int off, int len) 批量发送数据
TcpReceive	timeout(int timeOut)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TcpReceive

public TcpReceive(int port)
           throws IOException

Throws:

IOException

Method Detail

bufferSize

public TcpReceive bufferSize(int bufferSize)
                      throws SocketException

Throws:

SocketException

timeout

public TcpReceive timeout(int timeOut)
                   throws SocketException

Throws:

SocketException

acceptThreadPool

public TcpReceive acceptThreadPool(ExecutorService acceptThreadPool)

accept

public TcpReceive accept(int count)

接收几个连接

Parameters:

count - count

Returns:

this

sendAll

public TcpReceive sendAll(byte b)
                   throws IOException

Throws:

IOException

sendAll

public TcpReceive sendAll(byte[] bs)
                   throws IOException

批量发送数据

Parameters:

bs - bs

Returns:

this

Throws:

IOException - IOException

sendAll

public TcpReceive sendAll(byte[] bs,
                          int off,
                          int len)
                   throws IOException

批量发送数据

Parameters:

bs - bytes

off - offset

len - length

Returns:

this

Throws:

IOException - IOException

findSocket

public Socket findSocket(String host,
                         int port)

寻找客户端 socket

Parameters:

host - host

port - port

Returns:

socket

findSocket

public List<Socket> findSocket(String host)

寻找客户端 socket

Parameters:

host - host

Returns:

socket

closePool

public TcpReceive closePool()

关闭线程池

Returns:

this

close

public void close()

Specified by:

close in interface AutoCloseable

getPort

public int getPort()

getServerSocket

public ServerSocket getServerSocket()

getReceiveSocketList

public List<Socket> getReceiveSocketList()