程序包 com.alibaba.dubbo.remoting.p2p.exchange.support

类 ExchangeServerPeer

java.lang.Object

com.alibaba.dubbo.remoting.exchange.support.ExchangeServerDelegate

com.alibaba.dubbo.remoting.p2p.exchange.support.ExchangeServerPeer

所有已实现的接口:

Resetable, Endpoint, ExchangeServer, ExchangePeer, Peer, Server

public class ExchangeServerPeer
extends ExchangeServerDelegate
implements ExchangePeer

ServerPeer

构造器概要

构造器

构造器	说明
ExchangeServerPeer(ExchangeServer server, Map<URL,ExchangeClient> clients, ExchangeGroup group)

方法概要

修饰符和类型	方法	说明
void	close()	close the channel.
Channel	getChannel(InetSocketAddress remoteAddress)	get channel.
Collection<Channel>	getChannels()	get channels.
ExchangeChannel	getExchangeChannel(InetSocketAddress remoteAddress)	get channel.
Collection<ExchangeChannel>	getExchangeChannels()	get channels.
void	leave()	leave.
void	send(Object message)	send message.
void	send(Object message, boolean sent)	send message.

从类继承的方法 com.alibaba.dubbo.remoting.exchange.support.ExchangeServerDelegate

close, getChannelHandler, getLocalAddress, getServer, getUrl, isBound, isClosed, reset, reset, setServer, startClose

从类继承的方法 java.lang.Object

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

从接口继承的方法 com.alibaba.dubbo.remoting.Endpoint

close, getChannelHandler, getLocalAddress, getUrl, isClosed, startClose

从接口继承的方法 com.alibaba.dubbo.common.Resetable

reset

从接口继承的方法 com.alibaba.dubbo.remoting.Server

isBound, reset

构造器详细资料

ExchangeServerPeer

public ExchangeServerPeer(ExchangeServer server,
                          Map<URL,ExchangeClient> clients,
                          ExchangeGroup group)

方法详细资料

leave

public void leave()
           throws RemotingException

从接口复制的说明: Peer

leave.

指定者:

leave 在接口中 Peer

抛出:

RemotingException

close

public void close()

从接口复制的说明: Endpoint

close the channel.

指定者:

close 在接口中 Endpoint

覆盖:

close 在类中 ExchangeServerDelegate

getChannels

public Collection<Channel> getChannels()

从接口复制的说明: Server

get channels.

指定者:

getChannels 在接口中 Server

覆盖:

getChannels 在类中 ExchangeServerDelegate

返回:

channels

getChannel

public Channel getChannel(InetSocketAddress remoteAddress)

从接口复制的说明: Server

get channel.

指定者:

getChannel 在接口中 Server

覆盖:

getChannel 在类中 ExchangeServerDelegate

返回:

channel

getExchangeChannels

public Collection<ExchangeChannel> getExchangeChannels()

从接口复制的说明: ExchangeServer

get channels.

指定者:

getExchangeChannels 在接口中 ExchangeServer

覆盖:

getExchangeChannels 在类中 ExchangeServerDelegate

返回:

channels

getExchangeChannel

public ExchangeChannel getExchangeChannel(InetSocketAddress remoteAddress)

从接口复制的说明: ExchangeServer

get channel.

指定者:

getExchangeChannel 在接口中 ExchangeServer

覆盖:

getExchangeChannel 在类中 ExchangeServerDelegate

返回:

channel

send

public void send(Object message)
          throws RemotingException

从接口复制的说明: Endpoint

send message.

指定者:

send 在接口中 Endpoint

覆盖:

send 在类中 ExchangeServerDelegate

抛出:

RemotingException

send

public void send(Object message,
                 boolean sent)
          throws RemotingException

从接口复制的说明: Endpoint

send message.

指定者:

send 在接口中 Endpoint

覆盖:

send 在类中 ExchangeServerDelegate

sent - already sent to socket?

抛出:

RemotingException