Package org.fisco.bcos.sdk.channel

Class ChannelImp

java.lang.Object

org.fisco.bcos.sdk.channel.ChannelImp

All Implemented Interfaces:

Channel

public class ChannelImp
extends java.lang.Object
implements Channel

An implementation of channel.

Constructor Summary

Constructors

Constructor	Description
ChannelImp(ConfigOption configOption)

Method Summary

Modifier and Type	Method	Description
void	addConnectHandler(MsgHandler handler)	Add a connect handler, when one connect success, call handler.onConnect(ChannleHandlerContext ctx)is called
void	addDisconnectHandler(MsgHandler handler)	Add a disconnect handler, when one connection disconnect, handler.onDisconnect(ChannleHandlerContext ctx) is called
void	addEstablishHandler(MsgHandler handler)	Add a establish handler, when the SDK establishes a connection with the node, call the handler
void	addMessageHandler(MsgType type, MsgHandler handler)	Add a message handler to handle specific type messages.
void	asyncSendToPeer(Message out, java.lang.String peerIpPort, ResponseCallback callback, Options options)	Asynchronous interface, send message to peer
void	asyncSendToPeerByRule(Message out, PeerSelectRule rule, ResponseCallback callback, Options options)	Asynchronous interface, send message to peer select by client`s rule
void	asyncSendToRandom(Message out, ResponseCallback callback, Options options)	Asynchronous interface, send to an random peer
void	broadcast(Message out)	Broadcast to all peer, only send
void	broadcastToGroup(Message out, java.lang.String groupId)	Send a message to the given group, only send
java.util.List<java.lang.String>	getAvailablePeer()	Get available peer information
java.util.List<ConnectionInfo>	getConnectionInfo()	Get connection information
Network	getNetwork()
void	sendHeartbeatMessage(io.netty.channel.ChannelHandlerContext ctx)
Response	sendToPeer(Message out, java.lang.String peerIpPort)	Synchronize interface, send a message to the given peer, and get the response
Response	sendToPeerByRuleWithTimeOut(Message out, PeerSelectRule rule, Options options)	Synchronize interface with timeout, send message to peer select by client`s rule
Response	sendToPeerWithTimeOut(Message out, java.lang.String peerIpPort, Options options)	Synchronize interface with timeout, send a message to the given peer, and get the response
Response	sendToRandomWithTimeOut(Message out, Options options)	Synchronize interface with timeout, randomly select nodes to send messages
void	setGroupId2PeerIpPortList(java.util.Map<java.lang.String,java.util.List<java.lang.String>> groupId2PeerIpPortList)
void	setThreadPool(java.util.concurrent.ExecutorService threadPool)
void	start()
void	stop()
void	waitResponse(org.fisco.bcos.sdk.channel.ChannelImp.Callback callback, Options options)

Methods inherited from class java.lang.Object

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

Constructor Details

ChannelImp

public ChannelImp(ConfigOption configOption) throws ConfigException

Throws:

ConfigException

Method Details

getNetwork

public Network getNetwork()

Specified by:

getNetwork in interface Channel

start

public void start()

Specified by:

start in interface Channel

stop

public void stop()

Specified by:

stop in interface Channel

addConnectHandler

public void addConnectHandler(MsgHandler handler)

Description copied from interface: Channel

Add a connect handler, when one connect success, call handler.onConnect(ChannleHandlerContext ctx)is called

Specified by:

addConnectHandler in interface Channel

Parameters:

handler - the connect handler

addEstablishHandler

public void addEstablishHandler(MsgHandler handler)

Description copied from interface: Channel

Add a establish handler, when the SDK establishes a connection with the node, call the handler

Specified by:

addEstablishHandler in interface Channel

Parameters:

handler - the establish handler

addMessageHandler

public void addMessageHandler(MsgType type, MsgHandler handler)

Description copied from interface: Channel

Add a message handler to handle specific type messages. When one message comes the handler will be notified, handler.onMessage(ChannleHandlerContext ctx, Message msg) called.

Specified by:

addMessageHandler in interface Channel

Parameters:

type - the type of message

handler - the message handler

addDisconnectHandler

public void addDisconnectHandler(MsgHandler handler)

Description copied from interface: Channel

Add a disconnect handler, when one connection disconnect, handler.onDisconnect(ChannleHandlerContext ctx) is called

Specified by:

addDisconnectHandler in interface Channel

Parameters:

handler - disconnect handler

setGroupId2PeerIpPortList

public void setGroupId2PeerIpPortList(java.util.Map<java.lang.String,java.util.List<java.lang.String>> groupId2PeerIpPortList)

broadcastToGroup

public void broadcastToGroup(Message out, java.lang.String groupId)

Description copied from interface: Channel

Send a message to the given group, only send

Specified by:

broadcastToGroup in interface Channel

Parameters:

out - Message to be sent

groupId - ID of the group receiving the message packet

broadcast

public void broadcast(Message out)

Description copied from interface: Channel

Broadcast to all peer, only send

Specified by:

broadcast in interface Channel

Parameters:

out - Message to be sent

sendToPeer

public Response sendToPeer(Message out, java.lang.String peerIpPort)

Description copied from interface: Channel

Synchronize interface, send a message to the given peer, and get the response

Specified by:

sendToPeer in interface Channel

Parameters:

out - Message to be sent

peerIpPort - Remote ip:port information

Returns:

Remote reply

waitResponse

public void waitResponse(org.fisco.bcos.sdk.channel.ChannelImp.Callback callback, Options options)

sendToPeerWithTimeOut

public Response sendToPeerWithTimeOut(Message out, java.lang.String peerIpPort, Options options)

Description copied from interface: Channel

Synchronize interface with timeout, send a message to the given peer, and get the response

Specified by:

sendToPeerWithTimeOut in interface Channel

Parameters:

out - Message to be sent

peerIpPort - Remote ip:port information

options - Include timeout

Returns:

Remote reply

sendToRandomWithTimeOut

public Response sendToRandomWithTimeOut(Message out, Options options)

Description copied from interface: Channel

Synchronize interface with timeout, randomly select nodes to send messages

Specified by:

sendToRandomWithTimeOut in interface Channel

Parameters:

out - Message to be sent

options - Include timeout

Returns:

Remote reply

sendToPeerByRuleWithTimeOut

public Response sendToPeerByRuleWithTimeOut(Message out, PeerSelectRule rule, Options options)

Description copied from interface: Channel

Synchronize interface with timeout, send message to peer select by client`s rule

Specified by:

sendToPeerByRuleWithTimeOut in interface Channel

Parameters:

out - Message to be sent

rule - Rule set by client

options - Include timeout

Returns:

Remote reply

asyncSendToPeer

public void asyncSendToPeer(Message out, java.lang.String peerIpPort, ResponseCallback callback, Options options)

Description copied from interface: Channel

Asynchronous interface, send message to peer

Specified by:

asyncSendToPeer in interface Channel

Parameters:

out - Message to be sent

peerIpPort - Remote ip:port information

callback - Response callback

options - Include timeout

asyncSendToRandom

public void asyncSendToRandom(Message out, ResponseCallback callback, Options options)

Description copied from interface: Channel

Asynchronous interface, send to an random peer

Specified by:

asyncSendToRandom in interface Channel

Parameters:

out - Message to be sent

callback - Response callback

options - Include timeout

asyncSendToPeerByRule

public void asyncSendToPeerByRule(Message out, PeerSelectRule rule, ResponseCallback callback, Options options)

Description copied from interface: Channel

Asynchronous interface, send message to peer select by client`s rule

Specified by:

asyncSendToPeerByRule in interface Channel

Parameters:

out - Message to be sent

rule - Rule set by client

callback - Response callback

options - Include timeout

getConnectionInfo

public java.util.List<ConnectionInfo> getConnectionInfo()

Description copied from interface: Channel

Get connection information

Specified by:

getConnectionInfo in interface Channel

Returns:

List of connection information

getAvailablePeer

public java.util.List<java.lang.String> getAvailablePeer()

Description copied from interface: Channel

Get available peer information

Specified by:

getAvailablePeer in interface Channel

Returns:

List of available peer

sendHeartbeatMessage

public void sendHeartbeatMessage(io.netty.channel.ChannelHandlerContext ctx)

setThreadPool

public void setThreadPool(java.util.concurrent.ExecutorService threadPool)

Specified by:

setThreadPool in interface Channel