using System;
|
using System.Collections.Generic;
|
using System.ComponentModel;
|
using System.Data;
|
using System.Drawing;
|
using System.Linq;
|
using System.Net.Sockets;
|
using System.Net;
|
using System.Text;
|
using System.Threading.Tasks;
|
using System.Windows.Forms;
|
using static System.Windows.Forms.VisualStyles.VisualStyleElement;
|
using System.Threading;
|
using DataCapture_MA.log4Net;
|
using DataCapture_MA.Entity;
|
using DataCapture_MA.DataHnadle;
|
using DataCapture_MA.AutoMapperConfig;
|
|
namespace DataCapture_MA
|
{
|
public partial class CaptrueForm : Form
|
{
|
bool RunningFlag = false;
|
Socket skt = WZ.Useful.Commons.NetworkUtil.CreateUdpSocket();
|
EndPoint RemotePoint = null;
|
public delegate void MyInvoke(string strRecv);
|
public CaptrueForm()
|
{
|
InitializeComponent();
|
var hostName = Dns.GetHostName();
|
var ips = Dns.GetHostAddresses(hostName);
|
foreach (var ip in ips)
|
{
|
if (ip.AddressFamily == AddressFamily.InterNetwork) // 只显示IPv4地址
|
{
|
ipSelect.Items.Add(ip);
|
}
|
}
|
ipSelect.SelectedIndex = 0;
|
to_ipTxt.Text = ipSelect.SelectedItem.ToString();
|
AutoMapper.Mapper.Initialize((cfg) => {
|
cfg.AddProfile<MapperConfiguration>();
|
});
|
}
|
|
private void ReceiveHandle()
|
{
|
//接收数据处理线程
|
string msg;
|
byte[] data = new byte[204800];
|
MyInvoke myI = new MyInvoke(UpdateRcvTextBox);
|
while (RunningFlag)
|
{
|
|
if (skt == null || !RunningFlag || skt.Available < 1)
|
{
|
Thread.Sleep(200);
|
continue;
|
}
|
//跨线程调用控件
|
//接收UDP数据报，引用参数RemotePoint获得源地址
|
int rlen = skt.ReceiveFrom(data, ref RemotePoint);
|
msg = Encoding.Default.GetString(data, 0, rlen);
|
r_showBox.BeginInvoke(myI, new object[] { "From " + RemotePoint.ToString() + " << " + msg });
|
|
}
|
}
|
|
//处理接收到的UDP
|
private void UpdateRcvTextBox(string msg)
|
{
|
//接收数据显示
|
this.r_showBox.Text += (msg) + "\n\n";
|
Log4NetHelper.WriteInfoLog(LogType.Receive, msg);
|
ReceiveDataHandle.AnalysisMeassage(msg);
|
}
|
|
private void start_connect_Click(object sender, EventArgs e)
|
{
|
try
|
{
|
if (skt != null)
|
{
|
skt.Close();
|
skt.Dispose();
|
}
|
|
// 创建新的 UDP 套接字
|
skt = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
|
|
// 设置允许重用地址和端口
|
skt.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true);
|
|
//得到本机IP，设置UDP端口号
|
IPAddress ip = IPAddress.Parse(ipSelect.SelectedItem.ToString());//本机IP
|
int port = int.Parse(local_port.Text.Trim());//端口号
|
IPEndPoint iPEndPoint = new IPEndPoint(ip, port);
|
skt.Bind(iPEndPoint);
|
|
//得到客户机IP
|
IPAddress ip2 = IPAddress.Parse(to_ipTxt.Text.Trim());//客户机IP
|
int port2 = int.Parse(to_portTxt.Text.Trim());//端口号
|
IPEndPoint iPEndPoint2 = new IPEndPoint(ip2, port2);
|
RemotePoint = (EndPoint)(iPEndPoint2);
|
|
RunningFlag = true;
|
|
Thread thread = new Thread(new ThreadStart(ReceiveHandle));
|
thread.Start();
|
|
|
|
Log4NetHelper.WriteInfoLog(LogType.Receive, "开启UDP通信成功" + iPEndPoint.ToString());
|
ipSelect.Enabled = false;
|
local_port.Enabled = false;
|
to_ipTxt.Enabled = false;
|
to_portTxt.Enabled = false;
|
start_connect.BackColor = Color.DarkRed;
|
start_connect.Enabled = false;
|
colse_connect.BackColor = Color.DarkGreen;
|
colse_connect.Enabled = true;
|
r_showBox.Text += "数据接收已启动\n";
|
}
|
catch(Exception ex)
|
{
|
Log4NetHelper.WriteInfoLog(LogType.Receive, "开启UDP通信失败" + ex);
|
MessageBox.Show(ex.Message);
|
}
|
}
|
|
private void CreateDatabase()
|
{
|
try
|
{
|
using (var context = new DbModel())
|
{
|
// 确保数据库和表存在，如果不存在则创建
|
context.Database.EnsureCreated();
|
|
// 添加一些数据
|
context.RobotInfo.Add(new RobotInfo
|
{
|
WarnningNum = 0,
|
//RobotStatus = "Normal",
|
RobotModel = "Model X",
|
RobotSerialNo = "123456",
|
WarnningContent = "清除富文本框数据",
|
CreateTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
|
CreateStamp = DateTimeOffset.Now.ToUnixTimeSeconds(),
|
IsDelete = false
|
});
|
|
// 保存更改
|
context.SaveChanges();
|
|
var xx = context.RobotInfo.ToList();
|
}
|
}
|
catch (Exception ex)
|
{
|
r_showBox.Text = "数据库初始化异常"+ ex.Message;
|
}
|
}
|
|
private void colse_connect_Click(object sender, EventArgs e)
|
{
|
try
|
{
|
RunningFlag = false; // 停止接收线程
|
|
if (skt != null)
|
{
|
skt.Close(); // 关闭套接字
|
}
|
|
ipSelect.Enabled = true;
|
local_port.Enabled = true;
|
to_ipTxt.Enabled = true;
|
to_portTxt.Enabled = true;
|
colse_connect.Enabled = false;
|
start_connect.Enabled = true;
|
colse_connect.BackColor = Color.DarkRed;
|
start_connect.BackColor = Color.DarkGreen;
|
r_showBox.Text += "已关闭数据接收\n";
|
}
|
catch (Exception ex)
|
{
|
MessageBox.Show(ex.Message);
|
}
|
}
|
|
private void sendbtn_Click(object sender, EventArgs e)
|
{
|
try
|
{
|
string sendStr = richSendTxt.Text;
|
IPAddress ip2 = IPAddress.Parse(to_ipTxt.Text.Trim());//客户机IP
|
int port2 = int.Parse(to_portTxt.Text.Trim());//端口号
|
IPEndPoint iPEndPoint2 = new IPEndPoint(ip2, port2);
|
RemotePoint = (EndPoint)(iPEndPoint2);
|
skt.Connect(RemotePoint);
|
skt.Send(WZ.Useful.Commons.ConvertHelper.StringToBytes(sendStr));
|
|
r_showBox.Text += "To " + RemotePoint.ToString() +">> " + (sendStr) + "\n";
|
}
|
catch( Exception ex)
|
{
|
MessageBox.Show(ex.Message);
|
}
|
}
|
|
private void clearBtn_Click(object sender, EventArgs e)
|
{
|
CreateDatabase();
|
richSendTxt.Text = string.Empty;
|
r_showBox.Text = string.Empty;
|
}
|
|
private void ipSelect_SelectedIndexChanged(object sender, EventArgs e)
|
{
|
|
}
|
}
|
}
|
