基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 1 元　

支付宝支付

微信支付

   源码介绍

---

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
}