4 changed files with 227 additions and 20 deletions
@ -0,0 +1,225 @@ |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Linq; |
|||
using System.Text; |
|||
using System.Threading.Tasks; |
|||
using Newtonsoft.Json; |
|||
using System.IO; |
|||
using System.Net; |
|||
using System.Net.Sockets; |
|||
using System.Windows.Forms; |
|||
using System.ComponentModel; |
|||
using System.Data; |
|||
using System.Drawing; |
|||
|
|||
namespace formula_manage.UserClass |
|||
{ |
|||
public class TCPServer |
|||
{ |
|||
|
|||
//第一步：调用socket()函数创建一个用于通信的套接字
|
|||
public static Socket listenSocket; |
|||
|
|||
//字典集合：存储IP和Socket的集合
|
|||
public static Dictionary<string, Socket> OnLineList = new Dictionary<string, Socket>(); |
|||
|
|||
//当前时间
|
|||
private string CurrentTime |
|||
{ |
|||
get { return DateTime.Now.ToString("HH:mm:ss") + Environment.NewLine; } |
|||
} |
|||
|
|||
//编码格式
|
|||
Encoding econding = Encoding.Default; |
|||
|
|||
|
|||
public static void Start() |
|||
{ |
|||
//第一步：调用socket()函数创建一个用于通信的套接字
|
|||
listenSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); |
|||
|
|||
//第二步：给已经创建的套接字绑定一个端口号，这一般通过设置网络套接口地址和调用Bind()函数来实现
|
|||
IPEndPoint endPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), int.Parse("11080")); |
|||
|
|||
try |
|||
{ |
|||
listenSocket.Bind(endPoint); |
|||
} |
|||
catch (Exception ex) |
|||
{ |
|||
MessageBox.Show("服务器开启失败：" + ex.Message, "开启服务器"); |
|||
return; |
|||
} |
|||
|
|||
//第三步：调用listen()函数使套接字成为一个监听套接字
|
|||
listenSocket.Listen(10); |
|||
|
|||
//ShowMessage("服务器开启成功");
|
|||
MessageBox.Show("服务器开启成功"); |
|||
//开启一个线程监听
|
|||
Task.Run(new Action(() => |
|||
{ |
|||
ListenConnection(); |
|||
} |
|||
)); |
|||
|
|||
} |
|||
|
|||
public static void ListenConnection() |
|||
{ |
|||
while (true) |
|||
{ |
|||
Socket clientSocket = listenSocket.Accept(); |
|||
|
|||
string ip = clientSocket.RemoteEndPoint.ToString(); |
|||
|
|||
//更新在线列表
|
|||
// AddOnLine(ip, true);
|
|||
//更新在线列表集合
|
|||
OnLineList.Add(ip, clientSocket); |
|||
|
|||
// ShowMessage(ip + "上线了");
|
|||
|
|||
Task.Run(() => ReceiveMsg(clientSocket)); |
|||
|
|||
} |
|||
|
|||
} |
|||
|
|||
|
|||
/// <summary>
|
|||
/// 接收方法
|
|||
/// </summary>
|
|||
/// <param name="clientSocket"></param>
|
|||
public static void ReceiveMsg(Socket clientSocket) |
|||
{ |
|||
while (true) |
|||
{ |
|||
//定义一个2M的缓冲区
|
|||
byte[] buffer = new byte[1024 * 1024 * 2]; |
|||
|
|||
int length = -1; |
|||
try |
|||
{ |
|||
length = clientSocket.Receive(buffer); |
|||
} |
|||
catch (Exception) |
|||
{ |
|||
|
|||
//客户端下线了
|
|||
|
|||
//更新在线列表
|
|||
string ip = clientSocket.RemoteEndPoint.ToString(); |
|||
|
|||
// AddOnLine(ip, false);
|
|||
|
|||
OnLineList.Remove(ip); |
|||
|
|||
break; |
|||
} |
|||
|
|||
if (length == 0) |
|||
{ |
|||
//客户端下线了
|
|||
|
|||
//更新在线列表
|
|||
string ip = clientSocket.RemoteEndPoint.ToString(); |
|||
|
|||
// AddOnLine(ip, false);
|
|||
|
|||
OnLineList.Remove(ip); |
|||
|
|||
break; |
|||
} |
|||
|
|||
|
|||
// if (length > 0)
|
|||
// {
|
|||
// string info = econding.GetString(buffer, 0, length);
|
|||
// ShowMessage(info);
|
|||
// }
|
|||
} |
|||
} |
|||
/* |
|||
/// <summary>
|
|||
/// 在线列表更新
|
|||
/// </summary>
|
|||
/// <param name="clientIp"></param>
|
|||
/// <param name="value"></param>
|
|||
private void AddOnLine(string clientIp, bool value) |
|||
{ |
|||
Invoke(new Action(() => |
|||
{ |
|||
if (value) |
|||
{ |
|||
this.lst_Online.Items.Add(clientIp); |
|||
} |
|||
else |
|||
{ |
|||
this.lst_Online.Items.Remove(clientIp); |
|||
} |
|||
|
|||
})); |
|||
|
|||
} |
|||
|
|||
|
|||
/// <summary>
|
|||
/// 更新接收区
|
|||
/// </summary>
|
|||
/// <param name="info"></param>
|
|||
private void ShowMessage(string info) |
|||
{ |
|||
Invoke(new Action(() => |
|||
{ |
|||
this.txt_Rcv.AppendText(CurrentTime + info + Environment.NewLine); |
|||
})); |
|||
|
|||
} |
|||
*/ |
|||
/* |
|||
/// <summary>
|
|||
/// 消息发送
|
|||
/// </summary>
|
|||
/// <param name="sender"></param>
|
|||
/// <param name="e"></param>
|
|||
private void btn_Send_Click(object sender, EventArgs e) |
|||
{ |
|||
if (this.lst_Online.SelectedItem != null) |
|||
{ |
|||
foreach (string item in this.lst_Online.SelectedItems) |
|||
{ |
|||
if (OnLineList.ContainsKey(item)) |
|||
{ |
|||
OnLineList[item].Send(econding.GetBytes(this.txt_Send.Text.Trim())); |
|||
} |
|||
} |
|||
} |
|||
else |
|||
{ |
|||
MessageBox.Show("请先选择要发送的对象", "发送消息"); |
|||
} |
|||
|
|||
} |
|||
|
|||
/// <summary>
|
|||
/// 群发功能
|
|||
/// </summary>
|
|||
/// <param name="sender"></param>
|
|||
/// <param name="e"></param>
|
|||
private void btn_SendAll_Click(object sender, EventArgs e) |
|||
{ |
|||
foreach (string item in this.lst_Online.Items) |
|||
{ |
|||
if (OnLineList.ContainsKey(item)) |
|||
{ |
|||
OnLineList[item].Send(econding.GetBytes(this.txt_Send.Text.Trim())); |
|||
} |
|||
} |
|||
}*/ |
|||
|
|||
} |
|||
} |
|||
|
|||
|
|||
|
|||
@ -1,18 +0,0 @@ |
|||
using System; |
|||
using System.Collections.Generic; |
|||
using System.Linq; |
|||
using System.Text; |
|||
using System.Threading.Tasks; |
|||
using Newtonsoft.Json; |
|||
using System.IO; |
|||
using System.Net; |
|||
|
|||
namespace formula_manage.UserClass |
|||
{ |
|||
public class TCPUDPServer |
|||
{ |
|||
|
|||
} |
|||
|
|||
|
|||
} |
|||
Loading…
Reference in new issue