HslCommunication Library Document
HslCommunication.Enthernet.Redis
RedisClient 类
RedisClient 方法
AppendKey 方法
AppendKeyAsync 方法
ChangePassword 方法
ChangePasswordAsync 方法
DBSize 方法
DBSizeAsync 方法
DecrementKey 方法
DecrementKeyAsync 方法
DeleteHashKey 方法
DeleteHashKeyAsync 方法
DeleteKey 方法
DeleteKeyAsync 方法
ExistsHashKey 方法
ExistsHashKeyAsync 方法
ExistsKey 方法
ExistsKeyAsync 方法
ExpireKey 方法
ExpireKeyAsync 方法
ExtraOnDisconnect 方法
ExtraOnDisconnectAsync 方法
FlushDB 方法
FlushDBAsync 方法
GetListLength 方法
GetListLengthAsync 方法
IncrementHashKey 方法
IncrementHashKeyAsync 方法
IncrementKey 方法
IncrementKeyAsync 方法
InitializationOnConnect 方法
InitializationOnConnectAsync 方法
ListInsertAfter 方法
ListInsertAfterAsync 方法
ListInsertBefore 方法
ListInsertBeforeAsync 方法
ListLeftPop 方法
ListLeftPopAsync 方法
ListLeftPush 方法
ListLeftPushAsync 方法
ListLeftPushX 方法
ListLeftPushXAsync 方法
ListRange 方法
ListRangeAsync 方法
ListRemoveElementMatch 方法
ListRemoveElementMatchAsync 方法
ListRightPop 方法
ListRightPopAsync 方法
ListRightPopLeftPush 方法
ListRightPopLeftPushAsync 方法
ListRightPush 方法
ListRightPushAsync 方法
ListRightPushX 方法
ListRightPushXAsync 方法
ListSet 方法
ListSetAsync 方法
ListTrim 方法
ListTrimAsync 方法
MoveKey 方法
MoveKeyAsync 方法
OperateLongNumberFromServer 方法
OperateLongNumberFromServerAsync 方法
OperateNumberFromServer 方法
OperateNumberFromServerAsync 方法
OperateStatusFromServer 方法
OperateStatusFromServerAsync 方法
OperateStringFromServer 方法
OperateStringFromServerAsync 方法
OperateStringsFromServer 方法
OperateStringsFromServerAsync 方法
PersistKey 方法
PersistKeyAsync 方法
Ping 方法
PingAsync 方法
Publish 方法
PublishAsync 方法
Read(T) 方法
ReadAllKeys 方法
ReadAllKeysAsync 方法
ReadAndWriteKey 方法
ReadAndWriteKeyAsync 方法
ReadAsync(T) 方法
ReadCustomer 方法
ReadCustomerAsync 方法
ReadFromCoreServer 方法
ReadFromCoreServerAsync 方法
ReadHashKey 方法
ReadHashKeyAll 方法
ReadHashKeyAllAsync 方法
ReadHashKeyAsync 方法
ReadHashKeyLength 方法
ReadHashKeyLengthAsync 方法
ReadHashKeys 方法
ReadHashKeysAsync 方法
ReadHashValues 方法
ReadHashValuesAsync 方法
ReadKey 方法
ReadKeyAsync 方法
ReadKeyLength 方法
ReadKeyLengthAsync 方法
ReadKeyRange 方法
ReadKeyRangeAsync 方法
ReadKeyTTL 方法
ReadKeyTTLAsync 方法
ReadKeyType 方法
ReadKeyTypeAsync 方法
ReadListByIndex 方法
ReadListByIndexAsync 方法
ReadRandomKey 方法
ReadRandomKeyAsync 方法
ReadServerTime 方法
ReadServerTimeAsync 方法
RenameKey 方法
RenameKeyAsync 方法
Save 方法
SaveAsync 方法
SelectDB 方法
SelectDBAsync 方法
SetAdd 方法
SetAddAsync 方法
SetCard 方法
SetCardAsync 方法
SetDiff 方法
SetDiffAsync 方法
SetDiffStore 方法
SetDiffStoreAsync 方法
SetInter 方法
SetInterAsync 方法
SetInterStore 方法
SetInterStoreAsync 方法
SetIsMember 方法
SetIsMemberAsync 方法
SetMembers 方法
SetMembersAsync 方法
SetMove 方法
SetMoveAsync 方法
SetPop 方法
SetPopAsync 方法
SetRandomMember 方法
SetRandomMemberAsync 方法
SetRemove 方法
SetRemoveAsync 方法
SetUnion 方法
SetUnionAsync 方法
SetUnionStore 方法
SetUnionStoreAsync 方法
SubscribeMessage 方法
ToString 方法
UnSubscribeMessage 方法
Write(T) 方法
WriteAndPublishKey 方法
WriteAndPublishKeyAsync 方法
WriteAsync(T) 方法
WriteExpireKey 方法
WriteExpireKeyAsync 方法
WriteHashKey 方法
WriteHashKeyAsync 方法
WriteHashKeyNx 方法
WriteHashKeyNxAsync 方法
WriteKey 方法
WriteKeyAsync 方法
WriteKeyIfNotExists 方法
WriteKeyIfNotExistsAsync 方法
WriteKeyRange 方法
WriteKeyRangeAsync 方法
ZSetAdd 方法
ZSetAddAsync 方法
ZSetCard 方法
ZSetCardAsync 方法
ZSetCount 方法
ZSetCountAsync 方法
ZSetIncreaseBy 方法
ZSetIncreaseByAsync 方法
ZSetRange 方法
ZSetRangeAsync 方法
ZSetRangeByScore 方法
ZSetRangeByScoreAsync 方法
ZSetRank 方法
ZSetRankAsync 方法
ZSetRemove 方法
ZSetRemoveAsync 方法
ZSetRemoveRangeByRank 方法
ZSetRemoveRangeByRankAsync 方法
ZSetRemoveRangeByScore 方法
ZSetRemoveRangeByScoreAsync 方法
ZSetReverseRange 方法
ZSetReverseRangeAsync 方法
ZSetReverseRangeByScore 方法
ZSetReverseRangeByScoreAsync 方法
ZSetReverseRank 方法
ZSetReverseRankAsync 方法
ZSetScore 方法
ZSetScoreAsync 方法
点击或拖拽改变大小

RedisClientInitializationOnConnect 方法

根据实际的协议选择是否重写本方法，有些协议在创建连接之后，需要进行一些初始化的信号握手，才能最终建立网络通道。
Whether to rewrite this method is based on the actual protocol. Some protocols require some initial signal handshake to establish a network channel after the connection is created.

命名空间：  HslCommunication.Enthernet.Redis
程序集：  HslCommunication (在 HslCommunication.dll 中) 版本：12.1.2.0 (12.1.2.0)
语法
复制
protected override OperateResult InitializationOnConnect(
	Socket socket
)

参数

socket
类型：System.Net.SocketsSocket
网络套接字

返回值

类型：OperateResult
是否初始化成功，依据具体的协议进行重写
示例
有些协议不需要握手信号，比如三菱的MC协议，Modbus协议，西门子和欧姆龙就存在握手信息，此处的例子是继承本类后重写的西门子的协议示例
西门子重连示例
复制
        /// <inheritdoc/>
        public override OperateResult<byte[]> ReadFromCoreServer( CommunicationPipe pipe, byte[] send, bool hasResponseData, bool usePackAndUnpack )
        {
            while (true)
            {
                OperateResult<byte[]> read = base.ReadFromCoreServer( pipe, send, hasResponseData, usePackAndUnpack );
                if (!read.IsSuccess) return read;

                if (read.Content?.Length >= 4)
                {
                    if ((read.Content[2] * 256 + read.Content[3]) != 0x07) return read;
                }
            }
        }

        /// <inheritdoc/>
        protected override OperateResult InitializationOnConnect( )
        {
            // 第一次握手 -> First handshake
            OperateResult<byte[]> read_first = ReadFromCoreServer( this.CommunicationPipe, plcHead1, hasResponseData: true, usePackAndUnpack: true );
            if (!read_first.IsSuccess) return read_first;

            // 第二次握手 -> Second handshake
            OperateResult<byte[]> read_second = ReadFromCoreServer( this.CommunicationPipe, plcHead2, hasResponseData: true, usePackAndUnpack: true );
            if (!read_second.IsSuccess) return read_second;

            // 调整单次接收的pdu长度信息
            pdu_length = ByteTransform.TransUInt16( read_second.Content.SelectLast( 2 ), 0 ) - 28;
            if (pdu_length < 200) pdu_length = 200;

            incrementCount = new SoftIncrementCount( ushort.MaxValue, 1 );
            // 返回成功的信号 -> Return a successful signal
            return OperateResult.CreateSuccessResult( );
        }

#if !NET35 && !NET20
        /// <inheritdoc/>
        public async override Task<OperateResult<byte[]>> ReadFromCoreServerAsync( CommunicationPipe pipe, byte[] send, bool hasResponseData, bool usePackAndUnpack )
        {
            while (true)
            {
                OperateResult<byte[]> read = await base.ReadFromCoreServerAsync( pipe, send, hasResponseData, usePackAndUnpack );
                if (!read.IsSuccess) return read;

                if (read.Content?.Length >= 4)
                {
                    if ((read.Content[2] * 256 + read.Content[3]) != 0x07) return read;
                }
            }
        }

        /// <inheritdoc/>
        protected override async Task<OperateResult> InitializationOnConnectAsync( )
        {
            // 第一次握手 -> First handshake
            OperateResult<byte[]> read_first = await ReadFromCoreServerAsync( this.CommunicationPipe, plcHead1, hasResponseData: true, usePackAndUnpack: true );
            if (!read_first.IsSuccess) return read_first;

            // 第二次握手 -> Second handshake
            OperateResult<byte[]> read_second = await ReadFromCoreServerAsync( this.CommunicationPipe, plcHead2, hasResponseData: true, usePackAndUnpack: true );
            if (!read_second.IsSuccess) return read_second;

            // 调整单次接收的pdu长度信息
            pdu_length = ByteTransform.TransUInt16( read_second.Content.SelectLast( 2 ), 0 ) - 28;
            if (pdu_length < 200) pdu_length = 200;

            incrementCount = new SoftIncrementCount( ushort.MaxValue, 1 );
            // 返回成功的信号 -> Return a successful signal
            return OperateResult.CreateSuccessResult( );
        }
#endif
参见