一款简单易用的基础网络通讯组件库。

DmtpActor 类

提供Dmtp协议的最基础功能件

Definition

命名空间: TouchSocket.Dmtp
程序集: TouchSocket.Dmtp (在 TouchSocket.Dmtp.dll 中) 版本:4.0.0-beta.143+5fcca7a4e70968794985dc3793adc50531308be6
C#
public abstract class DmtpActor : DisposableObject, 
	IDmtpActor, IDisposableObject, IDisposable, IOnlineClient, IClosableClient, 
	IIdClient
Inheritance
Object    DisposableObject    DmtpActor
Implements
IDisposable, IDisposableObject, IDmtpActor, IClosableClient, IIdClient, IOnlineClient

构造函数

DmtpActor(Boolean) 创建一个可靠协议的Dmtp协议的最基础功能件
DmtpActor(Boolean, Boolean) 创建一个Dmtp协议的最基础功能件

属性

AllowRoute 是否允许支持路由数据。
Client 包含当前功能件的宿主通讯端。
ClosedToken 获取一个 CancellationToken,用于指示客户端是否已关闭。
Closing 请求关闭
Connected 在完成握手连接时
Connecting 握手
CreatedChannel 当创建通道时
DisposedValue 标识该对象是否已被释放
(继承自 DisposableObject。)
FindDmtpActor 查找其他IDmtpActor
Id 用于索引的Id
IdChanged 重设Id
IsReliable 是否基于可靠协议构建。例如:基于Tcp则为,基于Udp则为
LastActiveTime 最后一次活动时间。
Logger 日志
Online 判断是否在线
OutputSendAsync 异步发送数据接口
Routing 当需要路由的时候
TransportWriter 
WaitHandlePool 等待返回池

方法

AddActorTActor 添加一个实现了 IActor 接口的 Actor 实例。
ChannelExisted 判断指定Id的通道是否已经存在
CloseAsync 关闭客户端。
ConnectAsync 建立对点
CreateChannelAsync(Metadata, CancellationToken) 在当前对点创建一个随机Id的通道
CreateChannelAsync(Int32, Metadata, CancellationToken) 在当前对点创建一个指定Id的通道
CreateChannelAsync(String, Metadata, CancellationToken) 在指定路由点创建一个随机Id的通道
CreateChannelAsync(String, Int32, Metadata, CancellationToken) 在指定路由点创建一个指定Id的通道
Dispose 释放资源。内部已经处理了SuppressFinalize(Object)
(继承自 DisposableObject。)
Dispose(Boolean) 处置资源
(重写 DisposableObjectDispose(Boolean))
EqualsDetermines whether the specified object is equal to the current object.
(继承自 Object。)
FinalizeAllows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(继承自 Object。)
GetActorTActor 获取指定类型的 Actor 实例。
GetHashCodeServes as the default hash function.
(继承自 Object。)
GetTypeGets the Type of the current instance.
(继承自 Object。)
InputReceivedData 处理接收数据.

MemberwiseCloneCreates a shallow copy of the current Object.
(继承自 Object。)
OnClosed 当关闭后
OnConnected 握手连接完成
OnConnecting 正在握手连接
OnCreatedChannel 当完成创建通道时
OnIdChanged 当Id修改时
PingAsync(CancellationToken) 向当前对点发送一个Ping报文,并且等待回应。
PingAsync(String, CancellationToken) 向指定路由点发送一个Ping报文,并且等待回应。
ResetIdAsync 重新设置Id
SendAsync(UInt16, ReadOnlyMemoryByte, CancellationToken) 异步发送数据。
SendAsync(UInt16, String, CancellationToken) 
SendAsyncTPackage(UInt16, TPackage, CancellationToken) 
SendCloseAsync 异步发送关闭消息
ThrowIfDisposed 判断当前对象是否已经被释放。 如果已经被释放,则抛出ObjectDisposedException异常。
(继承自 DisposableObject。)
ToStringReturns a string that represents the current object.
(继承自 Object。)
TryAddActorTActor 尝试添加一个实现了 IActor 接口的 Actor 实例。
TryFindDmtpActor 尝试获取指定Id的DmtpActor。一般此方法仅在Service下有效。
TryRouteAsync 尝试请求路由,触发路由相关插件。并在路由失败时向Message中传递消息。
TrySubscribeChannel 尝试订阅已存在的通道。

字段

P0_Close Close
P1_Handshake_Request Handshake_Request
P2_Handshake_Response Handshake_Response
P3_ResetId_Request ResetId_Request
P4_ResetId_Response ResetId_Response
P5_Ping_Request Ping_Request
P6_Ping_Response Ping_Response
P7_CreateChannel_Request CreateChannel_Request
P8_CreateChannel_Response CreateChannel_Response
P9_ChannelPackage ChannelPackage

扩展方法

GetDmtpFileTransferActorDmtpActor中获取IDmtpFileTransferActor
(由 DmtpFileTransferActorExtension 定义。)
GetDmtpRedisActorDmtpActor中获得IDmtpRedisActor
(由 DmtpRedisActorExtensions 定义。)
GetDmtpRouterPackageActorIDmtpActor中获取IDmtpRouterPackageActor
(由 DmtpRouterPackageExtension 定义。)
GetDmtpRpcActorDmtpActor中获取IDmtpRpcActor
(由 DmtpRpcActorExtension 定义。)
GetRemoteAccessActor 从DmtpActor中获取DmtpRemoteAccessActor
(由 DmtpRemoteAccessExtension 定义。)
GetRemoteStreamActorIDmtpActor中获取IDmtpRemoteStreamActor
(由 DmtpRemoteStreamExtension 定义。)
Map 将源对象的属性映射到目标对象的属性中。
(由 Mapper 定义。)
Map 将源对象映射到目标类型的实例。
(由 Mapper 定义。)
MapTTarget 将源对象映射到指定目标类型的新实例。
(由 Mapper 定义。)
SafeDispose 安全性释放(不用判断对象是否为空)。不会抛出任何异常。

内部会判断DisposedValue的值,如果为,则不会再执行Dispose


(由 SystemExtension 定义。)
SafeDispose 安全性释放(不用判断对象是否为空)。不会抛出任何异常。
(由 SystemExtension 定义。)
ToJsonString 转换为Json
(由 SerializeConvert 定义。)

参见