Package xyz.cofe.trambda.tcp

Class TcpProtocol

java.lang.Object

xyz.cofe.trambda.tcp.TcpProtocol

public class TcpProtocol
extends Object

Поддержка TCP протокола

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<String,Set<Consumer<ServerEvent>>>	serverEventListeners

Constructor Summary

Constructors

Constructor	Description
TcpProtocol(OutputStream outputStream, InputStream inputStream, org.slf4j.Logger logger)	Конструктор
TcpProtocol(Socket socket)	Конструктор
TcpProtocol(Socket socket, org.slf4j.Logger logger)	Конструктор

Method Summary

Modifier and Type	Method	Description
ResultConsumer<Compile,CompileResult>	compile(LambdaDump methodDef)
ResultConsumer<Execute,ExecuteResult>	execute(CompileResult cres)
Map<Integer,Consumer<ErrMessage>>	getErrorConsumers()
Map<Integer,Consumer<? extends Message>>	getResponseConsumers()
AutoCloseable	listenServerEvent(String publisher, Consumer<ServerEvent> listener)
int	ping(Consumer<Pong> consumer)
protected void	process(Message msg, TcpHeader header)
protected void	process(Ping ping, TcpHeader header)
protected void	process(Pong pong, TcpHeader header)
protected void	process(ServerEvent sevent, TcpHeader header)
boolean	readNow()
Optional<xyz.cofe.fn.Tuple2<RawPack,Optional<BuffInputStream>>>	receiveRaw(Optional<BuffInputStream> prevStream)	Получение сообщения из сети
void	removeServerEventListener(Consumer<ServerEvent> listener)
int	send(Message message, Consumer<Integer> sid, HeaderValue<? extends Object>... headerValues)	Отправка сообщения
int	send(Message message, HeaderValue<? extends Object>... headerValues)	Отправка сообщения
int	sendRaw(String method, byte[] payload, Consumer<Integer> sendId, HeaderValue<? extends Object>... headerValues)	Отправка сообщения
ResultConsumer<Subscribe,SubscribeResult>	subscribe(Subscribe subscribe)
BiConsumer<ErrMessage,TcpHeader>	unbindedError()
TcpProtocol	unbindedError(BiConsumer<ErrMessage,TcpHeader> cons)
BiConsumer<Message,TcpHeader>	unbindedMessage()
TcpProtocol	unbindedMessage(BiConsumer<Message,TcpHeader> cons)
ResultConsumer<UnSubscribe,UnSubscribeResult>	unsubscribe(UnSubscribe subscribe)

Methods inherited from class java.lang.Object

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

Field Detail

serverEventListeners

protected final Map<String,Set<Consumer<ServerEvent>>> serverEventListeners

Constructor Detail

TcpProtocol

public TcpProtocol(Socket socket)

Конструктор

Parameters:

socket - сокет

TcpProtocol

public TcpProtocol(Socket socket,
                   org.slf4j.Logger logger)

Конструктор

Parameters:

socket - сокет

logger - логгер

TcpProtocol

public TcpProtocol(OutputStream outputStream,
                   InputStream inputStream,
                   org.slf4j.Logger logger)

Конструктор

Parameters:

outputStream - исходящий поток данных

inputStream - входящий поток данных

logger - логгер

Method Detail

sendRaw

@SafeVarargs
public final int sendRaw(String method,
                         byte[] payload,
                         Consumer<Integer> sendId,
                         HeaderValue<? extends Object>... headerValues)
                  throws IOException

Отправка сообщения

Parameters:

method - метод

payload - полезная нагрузка

sendId - идентификатор сообщения

headerValues - дополнительные заголовки сообщения

Returns:

идентификатор сообщения

Throws:

IOException - ошибка сети

send

@SafeVarargs
public final int send(Message message,
                      HeaderValue<? extends Object>... headerValues)
               throws IOException

Отправка сообщения

Parameters:

message - сообщение

headerValues - дополнительные заголовки сообщения

Returns:

идентификатор сообщения

Throws:

IOException - ошибка сети

send

@SafeVarargs
public final int send(Message message,
                      Consumer<Integer> sid,
                      HeaderValue<? extends Object>... headerValues)
               throws IOException

Отправка сообщения

Parameters:

message - сообщение

sid - идентификатор сообщения

headerValues - дополнительные заголовки сообщения

Returns:

идентификатор сообщения

Throws:

IOException - ошибка сети

receiveRaw

public Optional<xyz.cofe.fn.Tuple2<RawPack,Optional<BuffInputStream>>> receiveRaw(Optional<BuffInputStream> prevStream)
                                                                                 throws IOException

Получение сообщения из сети

Parameters:

prevStream - предыдущая часть сообщения

Returns:

сообщение или входящий поток закрыт

Throws:

IOException - ошибка сети

getErrorConsumers

public Map<Integer,Consumer<ErrMessage>> getErrorConsumers()

getResponseConsumers

public Map<Integer,Consumer<? extends Message>> getResponseConsumers()

unbindedError

public BiConsumer<ErrMessage,TcpHeader> unbindedError()

unbindedError

public TcpProtocol unbindedError(BiConsumer<ErrMessage,TcpHeader> cons)

unbindedMessage

public BiConsumer<Message,TcpHeader> unbindedMessage()

unbindedMessage

public TcpProtocol unbindedMessage(BiConsumer<Message,TcpHeader> cons)

readNow

public boolean readNow()
                throws IOException

Throws:

IOException

process

protected void process(Message msg,
                       TcpHeader header)

process

protected void process(Pong pong,
                       TcpHeader header)

process

protected void process(Ping ping,
                       TcpHeader header)

listenServerEvent

public AutoCloseable listenServerEvent(String publisher,
                                       Consumer<ServerEvent> listener)

removeServerEventListener

public void removeServerEventListener(Consumer<ServerEvent> listener)

process

protected void process(ServerEvent sevent,
                       TcpHeader header)

ping

public int ping(Consumer<Pong> consumer)

compile

public ResultConsumer<Compile,CompileResult> compile(LambdaDump methodDef)

execute

public ResultConsumer<Execute,ExecuteResult> execute(CompileResult cres)

subscribe

public ResultConsumer<Subscribe,SubscribeResult> subscribe(Subscribe subscribe)

unsubscribe

public ResultConsumer<UnSubscribe,UnSubscribeResult> unsubscribe(UnSubscribe subscribe)