739 lines
27 KiB
C#
739 lines
27 KiB
C#
using System;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
using Windows.Networking.Sockets;
|
||
using System.IO;
|
||
using Windows.Storage.Streams;
|
||
using Windows.Networking;
|
||
using System.Runtime.InteropServices.WindowsRuntime;
|
||
using Windows.Security.Cryptography.Core;
|
||
using Windows.Security.Cryptography;
|
||
|
||
namespace PlaneGcsSdk.Contract.EhNetUWP
|
||
{
|
||
public class PLNet
|
||
{
|
||
#region Properties
|
||
public StreamOBJ MyStreamObj;
|
||
/// <summary>
|
||
/// 连接的IP
|
||
/// </summary>
|
||
public string ServerIP { get; protected set; }
|
||
/// <summary>
|
||
/// 连接的端口
|
||
/// </summary>
|
||
public int TCPPort { get; protected set; }
|
||
public bool IsClosing { get; protected set; }
|
||
public bool IsOpen { get; protected set; }
|
||
/// <summary>
|
||
/// 真实名
|
||
/// </summary>
|
||
public string MyNick { get; protected set; }
|
||
/// <summary>
|
||
/// 获取登录随机码
|
||
/// </summary>
|
||
public string MyRND { get { return sMyTempRnd; } }
|
||
/// <summary>
|
||
/// 发送文件列表
|
||
/// </summary>
|
||
public List<FileOBJ> SendFileList { get; protected set; }
|
||
/// <summary>
|
||
/// 接收文件列表
|
||
/// </summary>
|
||
public List<FileOBJ> RevFileList { get; protected set; }
|
||
/// <summary>
|
||
/// 用户列表
|
||
/// </summary>
|
||
public List<UserProperty> FriendList { get; protected set; }
|
||
/// <summary>
|
||
/// 发送流列表
|
||
/// </summary>
|
||
public List<StreamOBJ> SendStreamList { get; protected set; }
|
||
public List<StreamOBJ> RevStreamList { get; protected set; }
|
||
#endregion
|
||
|
||
#region Fields
|
||
string sMyTempRnd; //登录随机数
|
||
bool LoginFlag = false; //登录状态
|
||
string sMyID; //登录用户名
|
||
string sMyPassword; //登录密码
|
||
|
||
string sMyIP; //用户IP
|
||
Encoding _enconding;
|
||
int iStreamID = -1;
|
||
int iFileID = 0;
|
||
|
||
protected StreamSocket _socket; //连接对象
|
||
protected IInputStream _inputStream;
|
||
protected Stream _outputStream;
|
||
protected bool _canFlush = true;
|
||
protected const uint READ_BUFFER_SIZE = 2047;
|
||
#endregion
|
||
|
||
#region Events
|
||
public event EventHandler<LoginEventArgs> Login;
|
||
public event EventHandler<DiscoveredOneUserEventArgs> DiscoveredOneUser;
|
||
public event EventHandler RefreshFriendListCompleted;
|
||
public event EventHandler<UserStateChangeEventArgs> UserStateChange;
|
||
public event EventHandler Disconnect;
|
||
public event EventHandler<CommandArrivalEventArgs> CommandArrival;
|
||
public event EventHandler<ExceptionThrownEventArgs> ExceptionThrown;
|
||
public event EventHandler<StartSendFileEventArgs> StartSendFile;
|
||
#endregion
|
||
|
||
public PLNet()
|
||
{
|
||
FriendList = new List<UserProperty>();
|
||
SendFileList = new List<FileOBJ>();
|
||
RevFileList = new List<FileOBJ>();
|
||
SendStreamList = new List<StreamOBJ>();
|
||
RevStreamList = new List<StreamOBJ>();
|
||
}
|
||
|
||
#region Public Methods
|
||
/// <summary>
|
||
/// 建立连接
|
||
/// </summary>
|
||
/// <param name="sServerIP"></param>
|
||
/// <param name="sUsername"></param>
|
||
/// <param name="sPassword"></param>
|
||
/// <param name="md5Password"></param>
|
||
/// <returns></returns>
|
||
public async Task Start(string sServerIP, string sUsername, string sPassword, string md5Password = null)
|
||
{
|
||
Close();
|
||
IsClosing = false;
|
||
|
||
if (_enconding == null)
|
||
{
|
||
_enconding = await DBCSEncoding.GetDBCSEncoding("GB2312");
|
||
}
|
||
|
||
sMyID = sUsername;
|
||
if (md5Password == null)
|
||
sMyPassword = GetStrMd5Hash(sMyID + sPassword);
|
||
else
|
||
sMyPassword = md5Password;
|
||
|
||
ServerIP = sServerIP; //登录用户的IP地址
|
||
TCPPort = 52510; //登录用户的端口
|
||
|
||
_socket = new StreamSocket(); //创建连接对象
|
||
await _socket.ConnectAsync(new HostName(ServerIP), TCPPort.ToString()).AsTask().ConfigureAwait(false); //执行连接操作
|
||
|
||
IsOpen = true;
|
||
_inputStream = _socket.InputStream;
|
||
_outputStream = _socket.OutputStream.AsStreamForWrite();
|
||
await Task.Run(() => TCPClientThread());
|
||
}
|
||
|
||
/// <summary>
|
||
/// 关闭连接
|
||
/// </summary>
|
||
public void Close()
|
||
{
|
||
IsClosing = true;
|
||
IsOpen = false;
|
||
_inputStream?.Dispose();
|
||
_outputStream?.Dispose();
|
||
_socket?.Dispose();
|
||
if (SendFileList != null)
|
||
SendFileList.Clear();
|
||
if (RevFileList != null)
|
||
RevFileList.Clear();
|
||
Disconnect?.Invoke(this, EventArgs.Empty); //触发事件Disconnect
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送命令
|
||
/// </summary>
|
||
/// <param name="friendIDs"></param>
|
||
/// <param name="msg"></param>
|
||
/// <returns></returns>
|
||
public async Task SendCommand(string friendIDs, string msg)
|
||
{
|
||
string commandtext = "*" + friendIDs + "|" + msg;
|
||
await SendCmd(commandtext);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送数据流，给多个用户同时发送数据
|
||
/// </summary>
|
||
/// <param name="friendIDs"></param>
|
||
/// <param name="myData"></param>
|
||
/// <returns></returns>
|
||
public async Task SendStream(string friendIDs, byte[] myData)
|
||
{
|
||
string[] myFriends = friendIDs.Split(',');
|
||
for (int i = 0; i < myFriends.Length; i++)
|
||
{
|
||
iStreamID += 1;
|
||
MyStreamObj = new StreamOBJ();
|
||
MyStreamObj.StreamID = iStreamID;
|
||
MyStreamObj.StreamData = myData;
|
||
MyStreamObj.RevUserID = myFriends[i];
|
||
SendStreamList.Add(MyStreamObj);
|
||
string streamtext = "*" + myFriends[i] + "|SB|" + MyStreamObj.StreamID.ToString() + "|" + MyStreamObj.StreamData.Length.ToString();
|
||
await SendCmd(streamtext);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送普通文件
|
||
/// </summary>
|
||
/// <param name="friendID"></param>
|
||
/// <param name="sFilenames"></param>
|
||
/// <returns></returns>
|
||
public async Task SendFileCommon(string friendID, string[] sFilenames)
|
||
{
|
||
string filetype = "F";
|
||
await SendFileCommon(friendID, sFilenames, filetype);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送图片文件
|
||
/// </summary>
|
||
/// <param name="friendID"></param>
|
||
/// <param name="sFilenames"></param>
|
||
/// <returns></returns>
|
||
public async Task SendPicture(string friendID, string[] sFilenames)
|
||
{
|
||
string filetype = "P";
|
||
await SendFileCommon(friendID, sFilenames, filetype);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送视频文件
|
||
/// </summary>
|
||
/// <param name="friendID"></param>
|
||
/// <param name="sFilenames"></param>
|
||
/// <returns></returns>
|
||
public async Task SendVideo(string friendID, string[] sFilenames)
|
||
{
|
||
string filetype = "V";
|
||
await SendFileCommon(friendID, sFilenames, filetype);
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送文件公共函数
|
||
/// </summary>
|
||
/// <param name="friendID"></param>
|
||
/// <param name="sFilenames"></param>
|
||
/// <param name="filetype"></param>
|
||
/// <returns></returns>
|
||
public async Task SendFileCommon(string friendID, string[] sFilenames, string filetype)
|
||
{
|
||
for (int i = 0; i < sFilenames.Length; i++)
|
||
{
|
||
FileOBJ tmpFileObj = new FileOBJ();
|
||
tmpFileObj.FileID = iFileID;
|
||
iFileID += 1;
|
||
FileInfo MyFileInfo = new FileInfo(sFilenames[i]);
|
||
tmpFileObj.Filename = MyFileInfo.Name;
|
||
tmpFileObj.FilePath = MyFileInfo.DirectoryName;
|
||
tmpFileObj.FileLength = MyFileInfo.Length;
|
||
tmpFileObj.FileModDate = filetype + MyFileInfo.LastWriteTime.ToString(); //filetype表示发送文件的类型
|
||
tmpFileObj.RevUserID = friendID;
|
||
tmpFileObj.State = FileState.WaitConfim;
|
||
tmpFileObj.tmpFileStream = new FileStream(sFilenames[i], FileMode.Open, FileAccess.Read);
|
||
SendFileList.Add(tmpFileObj);
|
||
StartSendFile?.Invoke(this, new StartSendFileEventArgs(SendFileList.Count - 1));
|
||
string filetext = "FB" + friendID + "|" + tmpFileObj.FileID.ToString() + "|" + tmpFileObj.Filename + "|" + tmpFileObj.FileLength.ToString() + "|" + tmpFileObj.FileModDate;
|
||
await SendCmd(filetext);
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 发送数据公共函数
|
||
/// </summary>
|
||
/// <param name="cmdStr"></param>
|
||
/// <param name="addBytes"></param>
|
||
/// <returns></returns>
|
||
public async Task SendCmd(string cmdStr, byte[] addBytes = null)
|
||
{
|
||
byte[] tmpSendbytes = null;
|
||
tmpSendbytes = _enconding.GetBytes(cmdStr);
|
||
int nret;
|
||
int strLen = LenB(cmdStr);
|
||
if (addBytes == null)
|
||
{
|
||
tmpSendbytes = BitConverter.GetBytes((ushort)strLen);
|
||
Array.Resize(ref tmpSendbytes, strLen + 2);
|
||
nret = _enconding.GetBytes(cmdStr, 0, cmdStr.Length, tmpSendbytes, 2);
|
||
}
|
||
else
|
||
{
|
||
byte[] tmpBytes;
|
||
long allLenth = strLen + addBytes.Length;
|
||
tmpBytes = BitConverter.GetBytes(allLenth);
|
||
Array.Resize(ref tmpBytes, strLen + 2);
|
||
nret = _enconding.GetBytes(cmdStr, 0, cmdStr.Length, tmpBytes, 2);
|
||
tmpSendbytes = AddByte(tmpBytes, addBytes);
|
||
}
|
||
try
|
||
{
|
||
if (tmpSendbytes != null)
|
||
{
|
||
await _outputStream.WriteAsync(tmpSendbytes, 0, tmpSendbytes.Length).ConfigureAwait(false);
|
||
if (_canFlush)
|
||
{
|
||
await _outputStream.FlushAsync().ConfigureAwait(false);
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_canFlush = false;
|
||
Close();
|
||
ExceptionThrown?.Invoke(this, new ExceptionThrownEventArgs(ex));
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
#region Private Methods
|
||
/// <summary>
|
||
/// 启动一个接收数据的线程
|
||
/// </summary>
|
||
private async void TCPClientThread()
|
||
{
|
||
uint i; //接收到的数据的长度
|
||
byte[] byteBuffer = null; //暂存接收到的数据
|
||
int comLength;
|
||
bool ReadFlag = false;
|
||
bool nRet;
|
||
byte[] Tmpbyte;
|
||
|
||
IBuffer tempbuf = new Windows.Storage.Streams.Buffer(READ_BUFFER_SIZE); //建立一个buffer
|
||
await _inputStream.ReadAsync(tempbuf, READ_BUFFER_SIZE, InputStreamOptions.Partial);
|
||
i = tempbuf.Length;
|
||
byteBuffer = new byte[i];
|
||
tempbuf.CopyTo(byteBuffer); //将数据输出
|
||
|
||
while (i != 0)
|
||
{
|
||
if (byteBuffer.Length > 3)
|
||
{
|
||
comLength = BitConverter.ToUInt16(byteBuffer, 0);
|
||
if (LoginFlag == false && comLength > 70)
|
||
{
|
||
#region
|
||
if (byteBuffer.Length >= 2)
|
||
{
|
||
byte[] firstchar = new byte[1];
|
||
firstchar[0] = byteBuffer[1];
|
||
if (_enconding.GetString(firstchar) != "L")
|
||
i = 0;
|
||
}
|
||
else
|
||
{
|
||
ReadFlag = true;
|
||
}
|
||
#endregion
|
||
}
|
||
else
|
||
{
|
||
#region
|
||
if (byteBuffer.Length >= comLength + 1)
|
||
{
|
||
Tmpbyte = MidByte(byteBuffer, 3, comLength); //截取字节
|
||
if (Tmpbyte.Length < 4)
|
||
nRet = false;
|
||
nRet = await ProcessData(Tmpbyte);
|
||
if (nRet == true)
|
||
{
|
||
byteBuffer = RightByte(byteBuffer, byteBuffer.Length - comLength - 2); //截取字节
|
||
if (byteBuffer.Length <= 0)
|
||
ReadFlag = true;
|
||
}
|
||
else
|
||
{
|
||
return;
|
||
}
|
||
}
|
||
else
|
||
{
|
||
ReadFlag = true;
|
||
}
|
||
#endregion
|
||
}
|
||
}
|
||
else
|
||
{
|
||
ReadFlag = true;
|
||
}
|
||
if (ReadFlag == true)
|
||
{
|
||
#region
|
||
ReadFlag = false;
|
||
try
|
||
{
|
||
tempbuf = new Windows.Storage.Streams.Buffer(READ_BUFFER_SIZE); //建立一个buffer
|
||
await _inputStream.ReadAsync(tempbuf, READ_BUFFER_SIZE, InputStreamOptions.Partial);
|
||
i = tempbuf.Length;
|
||
byte[] addbyte = new byte[i];
|
||
tempbuf.CopyTo(addbyte);
|
||
byteBuffer = AddByte(byteBuffer, addbyte);
|
||
}
|
||
catch(Exception ex)
|
||
{
|
||
i = 0;
|
||
}
|
||
#endregion
|
||
}
|
||
}
|
||
}
|
||
|
||
/// <summary>
|
||
/// 处理接收到的数据
|
||
/// </summary>
|
||
/// <param name="tmpbyte"></param>
|
||
/// <returns></returns>
|
||
private async Task<bool> ProcessData(byte[] tmpbyte)
|
||
{
|
||
string recestr = _enconding.GetString(tmpbyte); //这里本应是GBK编码
|
||
UserProperty tmpUserinfo = new UserProperty();
|
||
int tmpIndex;
|
||
|
||
switch (recestr[0])
|
||
{
|
||
case 'R':
|
||
sMyTempRnd = recestr.Substring(1);
|
||
await SendCmd("L" + sMyID + "|" + GetStrMd5Hash(sMyPassword + sMyTempRnd));
|
||
sMyTempRnd = sMyTempRnd.Substring(0, sMyTempRnd.Length - 1);
|
||
break;
|
||
case 'U': //收到用户信息
|
||
string sUserinfo = recestr.Substring(1);
|
||
switch (sUserinfo[0])
|
||
{
|
||
#region
|
||
case 'A': //用户列表
|
||
#region
|
||
sUserinfo = sUserinfo.Substring(1);
|
||
tmpUserinfo.UserID = Fin(1, sUserinfo, "|");
|
||
tmpUserinfo.UserNick = Fin(2, sUserinfo, "|");
|
||
tmpUserinfo.UserIndex = FriendList.Count;
|
||
tmpUserinfo.UserMessage = new List<String>();
|
||
FriendList.Add(tmpUserinfo);
|
||
DiscoveredOneUser?.Invoke(this, new DiscoveredOneUserEventArgs(tmpUserinfo));
|
||
#endregion
|
||
break;
|
||
case 'O': //用户上线
|
||
#region
|
||
sUserinfo = sUserinfo.Substring(1);
|
||
tmpIndex = GetUserIndexByID(Fin(1, sUserinfo, "|"));
|
||
if (tmpIndex >= 0)
|
||
{
|
||
tmpUserinfo = FriendList[tmpIndex]; //修改用户在线状态
|
||
tmpUserinfo.UserOnline = true;
|
||
FriendList[tmpIndex] = tmpUserinfo;
|
||
UserStateChange?.Invoke(this, new UserStateChangeEventArgs(tmpUserinfo));
|
||
}
|
||
#endregion
|
||
break;
|
||
case 'F': //用户下线
|
||
#region
|
||
sUserinfo = sUserinfo.Substring(1);
|
||
string tmpFriendID = Fin(1, sUserinfo, "|");
|
||
tmpIndex = GetUserIndexByID(tmpFriendID);
|
||
if (tmpIndex >= 0)
|
||
{
|
||
tmpUserinfo = FriendList[tmpIndex];
|
||
tmpUserinfo.UserOnline = false;
|
||
FriendList[tmpIndex] = tmpUserinfo;
|
||
//处理发送文件残留
|
||
for (int i = 0; i < SendFileList.Count; i--)
|
||
{
|
||
if (SendFileList[i].RevUserID == tmpFriendID)
|
||
{
|
||
SendFileList[i].tmpFileStream.Dispose();
|
||
SendFileList.RemoveAt(i);
|
||
}
|
||
}
|
||
for (int j = 0; j < RevFileList.Count; j--)
|
||
{
|
||
if (RevFileList[j].RevUserID == tmpFriendID)
|
||
{
|
||
RevFileList[j].tmpFileStream.Dispose();
|
||
RevFileList.RemoveAt(j);
|
||
}
|
||
}
|
||
UserStateChange?.Invoke(this, new UserStateChangeEventArgs(tmpUserinfo));
|
||
}
|
||
#endregion
|
||
break;
|
||
case 'D':
|
||
break;
|
||
case 'C': //被别人添加为好友时会收到
|
||
break;
|
||
case 'E':
|
||
RefreshFriendListCompleted?.Invoke(this, EventArgs.Empty);
|
||
break;
|
||
default:
|
||
break;
|
||
#endregion
|
||
}
|
||
break;
|
||
case 'L': //登陆
|
||
recestr = recestr.Substring(1);
|
||
switch (recestr[0])
|
||
{
|
||
#region
|
||
case 'P':
|
||
Login?.Invoke(this, new LoginEventArgs(LoginState.LoginPwdError));
|
||
break;
|
||
case 'O':
|
||
LoginFlag = true;
|
||
MyNick = recestr.Substring(1).Split('|')[0];
|
||
Login?.Invoke(this, new LoginEventArgs(LoginState.LoginOk));
|
||
await SendCmd("UG");
|
||
break;
|
||
case 'U':
|
||
Login?.Invoke(this, new LoginEventArgs(LoginState.LoginNoUser));
|
||
break;
|
||
case 'E':
|
||
Login?.Invoke(this, new LoginEventArgs(LoginState.LoginOtherError));
|
||
break;
|
||
default:
|
||
break;
|
||
#endregion
|
||
}
|
||
break;
|
||
case '*': //收到命令，格式为: *+FriendID+|+Msg
|
||
string tmpStr = recestr.Substring(1);
|
||
string tmpstr2 = Fin(2, tmpStr, "|");
|
||
switch (tmpstr2[0])
|
||
{
|
||
#region
|
||
case 'S':
|
||
break;
|
||
default:
|
||
string friendid = Fin(1, tmpStr, "|");
|
||
string msgcontent = tmpStr.Substring(tmpStr.IndexOf("|") + 1);
|
||
CommandArrival?.Invoke(this, new CommandArrivalEventArgs(friendid, msgcontent));
|
||
break;
|
||
#endregion
|
||
}
|
||
break;
|
||
default:
|
||
break;
|
||
}
|
||
return true;
|
||
}
|
||
|
||
private int LenB(string str)
|
||
{
|
||
return _enconding.GetBytes(str).Count();
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取一个字节数组中的某些字节，从start个字节开始，获取length个字节,第几个是从1开始的
|
||
/// </summary>
|
||
/// <param name="tbyte"></param>
|
||
/// <param name="start"></param>
|
||
/// <param name="length"></param>
|
||
/// <returns></returns>
|
||
private byte[] MidByte(byte[] tbyte, int start, int length)
|
||
{
|
||
byte[] tmpMidByte = new byte[length];
|
||
//for (int i = 0; i < length; i++)
|
||
//{
|
||
// tmpMidByte[i] = tbyte[i + start - 1];
|
||
//}
|
||
for (int i = start - 1; i <= length - 1 + start - 1; i++)
|
||
{
|
||
tmpMidByte[i - (start - 1)] = tbyte[i];
|
||
}
|
||
return tmpMidByte;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取某个字节数组的后面的字节，获取length个字节
|
||
/// </summary>
|
||
/// <param name="tbyte"></param>
|
||
/// <param name="length"></param>
|
||
/// <returns></returns>
|
||
private byte[] RightByte(byte[] tbyte, int length)
|
||
{
|
||
byte[] temRightByte = new byte[length];
|
||
temRightByte = MidByte(tbyte, tbyte.Length - length + 1, length);
|
||
return temRightByte;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 获取某个字节数组的前面的字节，获取length个字节
|
||
/// </summary>
|
||
/// <param name="tbyte"></param>
|
||
/// <param name="length"></param>
|
||
/// <returns></returns>
|
||
private byte[] LeftByte(byte[] tbyte, int length)
|
||
{
|
||
byte[] temLeftByte = new byte[length];
|
||
temLeftByte = MidByte(tbyte, 1, length);
|
||
return temLeftByte;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 拼接两个字节,将addbyte加在srcbyte后面
|
||
/// </summary>
|
||
/// <param name="srcbyte"></param>
|
||
/// <param name="addbyte"></param>
|
||
/// <returns></returns>
|
||
private byte[] AddByte(byte[] srcbyte, byte[] addbyte)
|
||
{
|
||
byte[] resultbyte = new byte[srcbyte.Length + addbyte.Length];
|
||
for (int i = 0; i < srcbyte.Length; i++)
|
||
{
|
||
resultbyte[i] = srcbyte[i];
|
||
}
|
||
for (int j = 0; j < addbyte.Length; j++)
|
||
{
|
||
resultbyte[j + srcbyte.Length] = addbyte[j];
|
||
}
|
||
return resultbyte;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 根据ID获取列表中序号
|
||
/// </summary>
|
||
/// <param name="tmpUserID"></param>
|
||
/// <returns></returns>
|
||
protected int GetUserIndexByID(string tmpUserID)
|
||
{
|
||
for (int i = 0; i < FriendList.Count; i++)
|
||
{
|
||
if (FriendList.ElementAt(i).UserID == tmpUserID)
|
||
return i;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 分割字符串，第Xnum个字符，字符串为SrcStr，分割特征为SpStr
|
||
/// </summary>
|
||
/// <param name="xnum"></param>
|
||
/// <param name="srcStr"></param>
|
||
/// <param name="spStr"></param>
|
||
/// <returns></returns>
|
||
private string Fin(int xnum, string srcStr, string spStr)
|
||
{
|
||
string[] tmpStr;
|
||
char[] FF = new char[1];
|
||
FF[0] = spStr[0];
|
||
tmpStr = srcStr.Split(FF);
|
||
if ((xnum > 0) && (xnum <= tmpStr.Length))
|
||
return tmpStr[xnum - 1];
|
||
else
|
||
return "";
|
||
}
|
||
|
||
/// <summary>
|
||
/// 计算字符串的MD5哈希值，输入为字符串strtohash，输出为字符串strHash
|
||
/// </summary>
|
||
/// <param name="strtohash"></param>
|
||
/// <returns></returns>
|
||
private string GetStrMd5Hash(string strtohash)
|
||
{
|
||
|
||
byte[] tmpbyte = _enconding.GetBytes(strtohash);
|
||
|
||
IBuffer buffMsg = CryptographicBuffer.CreateFromByteArray(tmpbyte);
|
||
|
||
HashAlgorithmProvider objAlgProv = HashAlgorithmProvider.OpenAlgorithm(HashAlgorithmNames.Md5);
|
||
|
||
IBuffer tmpbuffer = objAlgProv.HashData(buffMsg);
|
||
|
||
uint i = tmpbuffer.Length;
|
||
byte[] mybyte = new byte[i];
|
||
tmpbuffer.CopyTo(mybyte);
|
||
|
||
CryptographicBuffer.CopyToByteArray(tmpbuffer, out mybyte);
|
||
|
||
StringBuilder sBuilder = new StringBuilder();
|
||
for (int k = 0; k < mybyte.Length; k++)
|
||
{
|
||
sBuilder.Append(mybyte[k].ToString("x2"));
|
||
}
|
||
|
||
string strHash = sBuilder.ToString();
|
||
|
||
return strHash;
|
||
}
|
||
|
||
#endregion
|
||
}
|
||
#region Nested Type
|
||
/// <summary>
|
||
/// 用户信息结构体
|
||
/// </summary>
|
||
public struct UserProperty
|
||
{
|
||
public string UserID;
|
||
public string UserNick;
|
||
public string UserIP;
|
||
public int UserIndex;
|
||
public bool UserOnline;
|
||
public List<string> UserMessage;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 文件状态
|
||
/// </summary>
|
||
public enum FileState
|
||
{
|
||
WaitConfim,
|
||
StartSend, //开始发送，等待确认
|
||
Sending, //正在发送中
|
||
reSend, //断点续传中
|
||
SendError, //发送错误
|
||
Completed, //发送完成
|
||
LoginOtherError, //其他错
|
||
StartReveice, //开始接收，等待数据
|
||
Receiving, //接收中
|
||
ReReceiving, //断点续传中
|
||
ReceiveError
|
||
}
|
||
|
||
/// <summary>
|
||
/// 登录状态
|
||
/// </summary>
|
||
public enum LoginState
|
||
{
|
||
LoginPwdError, //密码错
|
||
LoginOk, //登陆成功
|
||
LoginNoUser, //用户不存在
|
||
LoginOtherError, //其他错
|
||
}
|
||
|
||
/// <summary>
|
||
/// 文件结构体
|
||
/// </summary>
|
||
public struct FileOBJ
|
||
{
|
||
public string Filename;
|
||
public string FilePath;
|
||
public long FileLength;
|
||
public string FileModDate;
|
||
public int FileID;
|
||
public string SendUserID;
|
||
public string RevUserID;
|
||
public FileStream tmpFileStream;
|
||
public FileState State;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 数据流结构体
|
||
/// </summary>
|
||
public struct StreamOBJ
|
||
{
|
||
public byte[] StreamData;
|
||
public ulong CurrPos;
|
||
public int StreamID;
|
||
public ulong Length;
|
||
public string SendUserID;
|
||
public string RevUserID;
|
||
}
|
||
#endregion
|
||
}
|