public static class BusClient.XSocket
extends java.lang.Object
限定符和类型 | 字段和说明 |
---|---|
static int |
DEFAULT_BYTE_BUFFER_SIZE |
构造器和说明 |
---|
XSocket(java.lang.String name,
int bufferSize) |
限定符和类型 | 方法和说明 |
---|---|
void |
close() |
void |
connect(java.lang.String addr) |
boolean |
isConnected() |
boolean |
isReadable() |
BusClient.Multipart |
receiveMultipart() |
void |
sendMultipart(BusClient.Multipart multipart) |
boolean |
waitReadable(long timeout) |
boolean |
waitWritable(long timeout) |
void |
wakeup() |
void |
write(byte[] data,
boolean eof) |
public static final int DEFAULT_BYTE_BUFFER_SIZE
public BusClient.Multipart receiveMultipart() throws java.io.IOException
java.io.IOException
public void write(byte[] data, boolean eof) throws java.io.IOException
java.io.IOException
public void sendMultipart(BusClient.Multipart multipart) throws java.io.IOException
java.io.IOException
public void connect(java.lang.String addr) throws java.io.IOException, java.util.concurrent.TimeoutException
java.io.IOException
java.util.concurrent.TimeoutException
public boolean isConnected()
public boolean isReadable() throws java.io.IOException
java.io.IOException
public void wakeup()
public boolean waitReadable(long timeout) throws java.io.IOException
java.io.IOException
public boolean waitWritable(long timeout) throws java.io.IOException
java.io.IOException
public void close()