实例介绍
【实例简介】
【实例截图】
【核心代码】
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Threading.Tasks;
using System.Data.SqlClient;
using System.IO;
using System.Xml;
using System.Text.RegularExpressions;
using System.Runtime.InteropServices;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Diagnostics;
namespace TCPdemo
{
public partial class Form1 : Form
{
SocketTCP _SocketTCP = new SocketTCP();
public Form1()
{
InitializeComponent();
_SocketTCP.InitSocket("232", 1000);
}
private void Form1_Load(object sender, EventArgs e)
{
SendRequire();
}
private void btnAdd_Click(object sender, EventArgs e)
{
SendRequireAdd();
}
#region 发送目标数 目标数 1
public void SendRequire()
{
MessageInfovalue.head = "A0";
//string strInfo = (Convert.ToDouble((txtNum.Text).ToString()) -
// Convert.ToDouble((txt_pckedNum.Text).ToString())).ToString();
string strInfo = "100";
MessageInfovalue.info = strInfo;
byte[] text = new byte[256];
StructureToByte(MessageInfovalue, text);
_SocketTCP.SendCommand(text);
}
public void SendRequireAdd()
{
MessageInfovalue.head = "C0";
string strInfo = "1";
MessageInfovalue.info = strInfo;
byte[] text = new byte[256];
StructureToByte(MessageInfovalue, text);
_SocketTCP.SendCommand(text);
}
#endregion
#region TCP
public MessageInfo MessageInfovalue = new MessageInfo();
//结构体转byte数组
public static void StructureToByte(object structObj, byte[] targetData)
{
IntPtr tmptr = IntPtr.Zero;
try
{
int size = Marshal.SizeOf(structObj); // 获取结构体在内存中的大小
tmptr = Marshal.AllocHGlobal(size); // 为缓冲区分配内存空间
Marshal.StructureToPtr(structObj, tmptr, false); //Copy到分配的非托管内存中
Marshal.Copy(tmptr, targetData, 0, size);
Marshal.FreeHGlobal(tmptr);
}
catch (Exception ex)
{
if (tmptr != IntPtr.Zero)
Marshal.FreeHGlobal(tmptr);
throw new Exception("内存操作失败：" ex.ToString());
}
}
/// <summary>
/// byte数组转结构体
/// </summary>
/// <param name="bytes">byte数组</param>
/// <param name="type">结构体类型</param>
/// <returns>转换后的结构体</returns>
public static object BytesToStuct(byte[] bytes, MessageInfo type)
{
//得到结构体的大小
int size = Marshal.SizeOf(type);
//byte数组长度小于结构体的大小
if (size > bytes.Length)
{
//返回空
return null;
}
//分配结构体大小的内存空间
IntPtr structPtr = Marshal.AllocHGlobal(size);
//将byte数组拷到分配好的内存空间
Marshal.Copy(bytes, 0, structPtr, size);
//将内存空间转换为目标结构体
object obj = Marshal.PtrToStructure(structPtr, typeof(MessageInfo));
//释放内存空间
Marshal.FreeHGlobal(structPtr);
//返回结构体
return obj;
}
[StructLayoutAttribute(LayoutKind.Sequential, CharSet = CharSet.Ansi, Pack = 1)]
public struct MessageInfo
{
//字符串，SizeConst为字符串的最大长度
[MarshalAs(UnmanagedType.ByValTStr, SizeConst = 3)]
public string head;
//字符串，SizeConst为字符串的最大长度
[MarshalAs(UnmanagedType.ByValTStr, SizeConst = 5)]
public string info;
}
public class SocketTCP
{
static readonly object padlock = new object();
byte[] data = new byte[1024];
IPAddress _IP;
static IPEndPoint _ipEnd;
static Socket socket;
private static Object thisLock = new Object();
public SocketTCP()
{ }
public SocketTCP(string IP, int Port)
{
InitSocket(IP, Port);
}
public bool InitSocket(string IP, int Port)
{
try
{
// _IP = IPAddress.Parse("100.168.0.6");
_IP = IPAddress.Parse("127.0.0.1");
_ipEnd = new IPEndPoint(_IP, 8000);
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
if (ConnectServer())
{
Thread reset_thread = new Thread(reset_connect); //重新连接线程
reset_thread.Start();
Thread socket_thread = new Thread(recv_thread);
socket_thread.Start();
return true;
}
else
return false;
}
catch
{
return false;
}
}
public bool Connected
{
get
{
if (socket == null)
return false;
return socket.Connected;
}
}
public bool ConnectServer()
{
try
{
socket.Connect(_ipEnd);
recv_flag = true;
return true;
}
catch (Exception)
{
return false;
}
}
public bool Close()
{
try
{
// if (socket.Connected)
socket.Shutdown(SocketShutdown.Both);
socket.Close();
return true;
}
catch
{
return false;
}
}
public int StatusCode
{ get; set; }
public static bool recv_flag = false;
public static bool error_thread_flat = false;
public static void reset_connect()
{
while (true)
{
try
{
if (error_thread_flat) //此处可以用信号量处理让线程休眠，降低CPU
{
if (!socket.Connected)
{
socket.Close();
socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.Connect(_ipEnd);
}
error_thread_flat = true;
}
}
catch (Exception EX)
{
MessageBox.Show(EX.Message);
Thread.Sleep(5000);
continue;
}
}
}
public static void recv_thread()
{
MessageInfo obj = new MessageInfo();
MessageInfo obj1 = new MessageInfo();
byte[] data = new byte[256];
while (true)
{
if (recv_flag)
{
try
{
if (socket.Connected)
{
error_thread_flat = false;
int count = socket.Receive(data);
BytesToStuct(data, obj);
object info = BytesToStuct(data, obj);
obj1 = (MessageInfo)info;
string head = obj1.head.ToString();
string strInfo = obj1.info.ToString();
switch (head)
{
case "B1":
MessageBox.Show("打标已到目标数.");
break;
case "A1":
if (strInfo == "1")
{
MessageBox.Show("发送目标打码数成功.");
}
break;
case "C1":
if (strInfo == "1")
{
MessageBox.Show("目标数加一成功.");
}
break;
}
}
else
{
error_thread_flat = true;
}
}
catch (Exception ex)
{
error_thread_flat = true;
MessageBox.Show(ex.Message);
}
}
}
}
public void SendCommand(byte[] cmd)
{
byte[] value = null;
lock (thisLock)
{
if (socket != null)
{
if (socket.Connected)
{
socket.Send(cmd);
}
}
}
}
}
}
#endregion
}
好例子网口号：伸出你的我的手 — 分享！
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论