实例介绍
【实例简介】
【实例截图】
【核心代码】
using CCWin;
using CCWin.SkinControl;
using System;
using System.Windows.Forms;
using SocketServerCommonLib;
using System.Threading;
using System.Drawing;
using System.IO;
namespace SocketServer
{
public partial class TCPUDPServer : CCSkinMain
{
AsyncSocketServer TcpServer;
AsyncUDPServer UdpServer;
/// <summary>
/// 用户连接多少次
/// </summary>
int TCPUserCount = 0;
int TCPDeviceCount = 0;
public TCPUDPServer()
{
InitializeComponent();
DelegateState.ServerStateInfo = ServerShowStateInfo;
DelegateState.TeartbeatServerStateInfo = TeartbeatShowStateInfo;
DelegateState.AddTCPuserStateInfo = AddTCPuser;
DelegateState.AddTCPdeviceStateInfo = AddTCPdevice;
DelegateState.ReomveTCPStateInfo = ReomveTCP;
DelegateState.ServerConnStateInfo = ConnStateInfo;
}
#region AmosLi produce <启动服务模块>
/// <summary>
/// 启动TCP服务
/// </summary>
private void btnTCP_Click(object sender, EventArgs e)
{
btnTCP.Enabled = false;
if (TcpServer == null)
TcpServer = new AsyncSocketServer();
if (!TcpServer.IsStartListening)
{
TcpServer.Start();
txtMsg.AppendText(DateTime.Now Environment.NewLine "TCP服务器启动" Environment.NewLine);
lblTCP.Text = "TCP服务器地址:" TcpServer.serverconfig.ListenIp ":" TcpServer.serverconfig.ListenPort;
PicBoxTCP.BackgroundImage = Properties.Resources._07822_48x48x8BPP_;
btnTCP.Text = "TCP停止服务";
}
else
{
TcpServer.Stop();
PicBoxTCP.BackgroundImage = Properties.Resources._07821_48x48x8BPP_;
txtMsg.AppendText(DateTime.Now Environment.NewLine "TCP服务器停止" Environment.NewLine);
}
btnTCP.Enabled = true;
}
/// <summary>
/// UDP服务
/// </summary>
private void btnUDP_Click(object sender, EventArgs e)
{
btnUDP.Enabled = false;
if (UdpServer == null)
UdpServer = new AsyncUDPServer();
if (!UdpServer.IsStartListening)
{
UdpServer.Start();
txtMsg.AppendText(DateTime.Now Environment.NewLine "UDP服务器启动" Environment.NewLine);
lblUDP.Text = "UDP服务器地址:" HelpCommonLib.NetworkAddress.GetIPAddress() ":" UdpServer.ListenProt;
PicBoxUDP.BackgroundImage = Properties.Resources._07822_48x48x8BPP_;
btnUDP.Text = "UDP停止服务";
btnUDP.Enabled = true;
}
else
{
txtMsg.AppendText(DateTime.Now Environment.NewLine "UDP服务器停止" Environment.NewLine);
UdpServer.Close();
PicBoxUDP.BackgroundImage = Properties.Resources._07821_48x48x8BPP_;
btnUDP.Text = "UDP端口错误";
}
}
#region
#region TCP回调函数操作
void AddTCPuser(SocketUserToken userToken)
{
this.Invoke(new ThreadStart(delegate
{
TCPUserCount ;
ListViewItem lvi = new ListViewItem();
lvi.Text = TCPUserCount.ToString();
lvi.SubItems.Add(userToken.ConnectSocket.RemoteEndPoint.ToString());
lvi.SubItems.Add(userToken.UserName);
lvi.SubItems.Add(userToken.ConnectDateTime.ToString());
lvi.SubItems.Add("TCP");
tpe3list1.Items.Add(lvi);
}));
}
/// <summary>
/// 删除用户或者设备
/// </summary>
/// <param name="userToken"></param>
void ReomveTCP(SocketUserToken userToken)
{
this.Invoke(new ThreadStart(delegate
{
if (userToken.isDevice)
{
for (int i = 0; i < tpe2list1.Items.Count; i )
{
if (userToken.UserName == tpe2list1.Items[i].SubItems[2].Text)
{
tpe2list1.Items.Remove(tpe2list1.Items[i]);
}
}
}
else
{
for (int i = 0; i < tpe3list1.Items.Count; i )
{
if (userToken.UserName == tpe3list1.Items[i].SubItems[2].Text)
{
tpe3list1.Items.Remove(tpe3list1.Items[i]);
}
}
}
}));
}
void AddTCPdevice(SocketUserToken userToken)
{
this.Invoke(new ThreadStart(delegate
{
TCPDeviceCount ;
ListViewItem lvi = new ListViewItem();
lvi.Text = TCPDeviceCount.ToString();
lvi.SubItems.Add(userToken.ConnectSocket.RemoteEndPoint.ToString());
lvi.SubItems.Add(userToken.UserName);
lvi.SubItems.Add(userToken.ConnectDateTime.ToString());
lvi.SubItems.Add("TCP");
tpe2list1.Items.Add(lvi);
}));
}
#endregion
void ConnStateInfo(string RemoteIp, string TCPUDP)
{
this.Invoke(new ThreadStart(delegate
{
ListViewItem lvi = new ListViewItem();
lvi.Text = listAllView.Items.Count.ToString();
lvi.SubItems.Add(RemoteIp);
lvi.SubItems.Add(DateTime.Now.ToString());
lvi.SubItems.Add(TCPUDP);
listAllView.Items.Add(lvi);
}));
}
/// <summary>
/// 信息添加
/// </summary>
/// <param name="msg"></param>
void ServerShowStateInfo(string msg)
{
this.Invoke(new ThreadStart(delegate
{
tpe2txtMsg.AppendText(DateTime.Now ":" msg Environment.NewLine);
}));
}
/// <summary>
/// 心跳时间
/// </summary>
void TeartbeatShowStateInfo(int num)
{
this.Invoke(new ThreadStart(delegate
{
txtMsg.AppendText(DateTime.Now ":" num "连接检测");
lblNum1.NormlBack = ImageListAllUpdate(num / 10 % 10);
lblNum2.NormlBack = ImageListAllUpdate(num % 10);
}));
}
#endregion
/// <summary>
/// 图片更换
/// </summary>
Image ImageListAllUpdate(int Num)
{
switch (Num)
{
case 0:
return Properties.Resources._00034_17x25x8BPP_;
case 1:
return Properties.Resources._00035_17x25x8BPP_;
case 2:
return Properties.Resources._00036_17x25x8BPP_;
case 3:
return Properties.Resources._00037_17x25x8BPP_;
case 4:
return Properties.Resources._00038_17x25x8BPP_;
case 5:
return Properties.Resources._00039_17x25x8BPP_;
case 6:
return Properties.Resources._00040_17x25x8BPP_;
case 7:
return Properties.Resources._00041_17x25x8BPP_;
case 8:
return Properties.Resources._00042_17x25x8BPP_;
case 9:
return Properties.Resources._00043_17x25x8BPP_;
default:
return null;
}
}
#endregion
/// <summary>
/// 刷新设备列表
/// </summary>
/// <param name="sender"></param>
/// <param name="e"></param>
private void linkdeviceRefresh_LinkClicked(object sender, LinkLabelLinkClickedEventArgs e)
{
if (TcpServer == null)
return;
linkdeviceRefresh.Enabled = false;
tpe2list1.Items.Clear();
SocketUserToken[] userTokenArray = null;
TcpServer.AsyncSocketDeviceList.CopyList(ref userTokenArray);
int num = 0;
for (int i = 0; i < userTokenArray.Length; i )
{
if (userTokenArray[i].LoginFlag)
{
AddTCPdevice(userTokenArray[i]);
}
num ;
}
lbldevice.Text = "上次刷新是在 " DateTime.Now.Hour " 点，共连接 " userTokenArray.Length " 个客户。";
linkdeviceRefresh.Enabled = true;
}
private void linkuserRefresh_LinkClicked(object sender, LinkLabelLinkClickedEventArgs e)
{
if (TcpServer == null)
return;
linkuserRefresh.Enabled = false;
tpe3list1.Items.Clear();
SocketUserToken[] userTokenArray = null;
TcpServer.AsyncSocketUserList.CopyList(ref userTokenArray);
int num = 0;
for (int i = 0; i < userTokenArray.Length; i )
{
if (userTokenArray[i].LoginFlag)
{
AddTCPuser(userTokenArray[i]);
num ;
}
}
lbluser.Text = "上次刷新是在 " DateTime.Now.Hour " 点，共连接 " num " 个客户。";
linkuserRefresh.Enabled = true;
}
/// <summary>
/// 保存信息
/// </summary>
private void linkSaveMsg_LinkClicked(object sender, LinkLabelLinkClickedEventArgs e)
{
if (saveFileDialog1.ShowDialog() == DialogResult.OK)
{
using (StreamWriter write = new StreamWriter(saveFileDialog1.FileName))
{
write.WriteLine(tpe2txtMsg.Text);
}
}
}
}
}
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论