基本已完成!!!

GWSocketClient/Form1.Designer.cs

             this.btnPressureTest.TabIndex = 10;
             this.btnPressureTest.Text = "压力测试";
             this.btnPressureTest.UseVisualStyleBackColor = true;
+            this.btnPressureTest.Visible = false;
             this.btnPressureTest.Click += new System.EventHandler(this.btnPressureTest_Click);
             // 
             // label4
             this.label4.Size = new System.Drawing.Size(56, 17);
             this.label4.TabIndex = 9;
             this.label4.Text = "压力测试";
+            this.label4.Visible = false;
             // 
             // tbPresureTestCount
             // 
             this.tbPresureTestCount.Size = new System.Drawing.Size(65, 23);
             this.tbPresureTestCount.TabIndex = 8;
             this.tbPresureTestCount.Text = "100";
+            this.tbPresureTestCount.Visible = false;
             // 
             // btnSendData
             // 
+            this.btnSendData.Enabled = false;
             this.btnSendData.Location = new System.Drawing.Point(422, 61);
             this.btnSendData.Margin = new System.Windows.Forms.Padding(3, 4, 3, 4);
             this.btnSendData.Name = "btnSendData";
             // 
             // btnQuickLogout
             // 
+            this.btnQuickLogout.Enabled = false;
             this.btnQuickLogout.Location = new System.Drawing.Point(103, 61);
             this.btnQuickLogout.Margin = new System.Windows.Forms.Padding(3, 4, 3, 4);
             this.btnQuickLogout.Name = "btnQuickLogout";
             this.tbIpaddress.Name = "tbIpaddress";
             this.tbIpaddress.Size = new System.Drawing.Size(252, 23);
             this.tbIpaddress.TabIndex = 1;
-            this.tbIpaddress.Text = "127.0.0.1";
+            this.tbIpaddress.Text = "120.77.50.131";
             // 
             // label1
             // 
             // 
             // ToolStripMenuItemHbStart
             // 
-            this.ToolStripMenuItemHbStart.Checked = true;
-            this.ToolStripMenuItemHbStart.CheckState = System.Windows.Forms.CheckState.Checked;
             this.ToolStripMenuItemHbStart.Name = "ToolStripMenuItemHbStart";
             this.ToolStripMenuItemHbStart.Size = new System.Drawing.Size(172, 22);
             this.ToolStripMenuItemHbStart.Text = "登录成功就开启";
-            this.ToolStripMenuItemHbStart.Click += new System.EventHandler(this.ToolStripMenuItemHbStart_Click);
             // 
             // toolStripSeparator1
             // 

GWSocketClient/Form1.cs

 
 namespace GWSocketClient
 {
+    delegate void ThreadFormDelegate(object msg);
+
     public partial class Form1 : Form
     {
         public Form1()
         private string port;
         private SocketHelper.TcpClients sockeTcpClients;
         private VcarecityPD vcarecityProtocolBean = null;
+        private volatile bool hbRunFlag = false; //心跳线程标志
+        private ThreadFormDelegate uiDelegate;
 
-        private int heartBeatInterval = 5; //Default 心跳间隔
-        private bool isStartHeartbeat = true;
 
         private void Form1_Load(object sender, EventArgs e)
         {
             sockeTcpClients = new SocketHelper.TcpClients();
             ip = tbIpaddress.Text.Trim();
             port = tbPort.Text.Trim();
-            isStartHeartbeat = ToolStripMenuItemHbStart.Checked;
+
+            uiDelegate = addToListboxItem;
         }
 
 
         #region 处理心跳相关的
 
-        private void startHeartBeat()
+        //开启心跳连接
+        private void startHeartBeatThread()
         {
             Thread thread = new Thread(heartBeatThread);
-            thread.Start();
-            
+            thread.Start(this);
         }
 
-        private void heartBeatThread()
+        private void heartBeatThread(object o)
         {
-            while (isStartHeartbeat)
+            while (hbRunFlag)
             {
-                int interval = int.Parse(toolStripTextBoxHbtime.Text.Trim());
+            
+                int interval = 5;
+                if (!toolStripTextBoxHbtime.Text.Trim().Equals(""))
+                {
+                    interval = int.Parse(toolStripTextBoxHbtime.Text.Trim());
+                }
                 Thread.Sleep(interval * 1000);
-                string hbCmd = vcarecityProtocolBean.ProtocolStartSymbol;
-                hbCmd += tbEquipmentAddress.Text.Trim() + "840000";
-                hbCmd = Utils.calcCrcCode(hbCmd);
-                byte[] ts = HexUtil.hexToBytes(hbCmd);
-                sockeTcpClients.SendData(ts);
 
-                if (ToolStripMenuItemLogHb.Checked)
+          
+                if (hbRunFlag)
                 {
-                    Console.WriteLine("发送到服务端-心跳:[{0}]", hbCmd);
-                    addToListboxItem(string.Format("发送到服务端-心跳:[{0}]", hbCmd));
+                    string hbCmd = vcarecityProtocolBean.ProtocolStartSymbol;
+                    hbCmd += tbEquipmentAddress.Text.Trim() + "840000";
+                    hbCmd = Utils.calcCrcCode(hbCmd);
+                    byte[] ts = HexUtil.hexToBytes(hbCmd);
+
+                    sockeTcpClients.SendData(ts);
+
+                    if (ToolStripMenuItemLogHb.Checked)
+                    {
+                        this.Invoke(this.uiDelegate, new object[] {string.Format("发送到服务端-心跳:[{0}]", hbCmd)});
+                    }
                 }
             }
-            addToListboxItem("心跳线程结束!");
+            this.Invoke(this.uiDelegate, new object[] {"心跳线程结束!"});
         }
 
         #endregion
                     switch (sks.ErrorCode)
                     {
                         case SocketHelper.Sockets.ErrorCodes.objectNull:
+                            addToListboxItem("状态信息:服务器连接已断开");
+                            hbRunFlag = false;
+                            checkLogin(false);
                             break;
                         case SocketHelper.Sockets.ErrorCodes.ConnectError:
+                            //连接不成功
+                            addToListboxItem("状态信息:连接服务器失败,可能是服务器未开启!");
                             break;
                         case SocketHelper.Sockets.ErrorCodes.ConnectSuccess:
-                            addToListboxItem("状态信息:连接成功.!");
+                            //连接成功
+                            addToListboxItem("状态信息:与服务器连接成功");
+                            addToListboxItem(string.Format("客户端信息{0}", sks.ex));
+                            checkLogin(true);
+                            sendLoginCmd();
+                            hbRunFlag = true;
+                            startHeartBeatThread();
                             break;
                         case SocketHelper.Sockets.ErrorCodes.TrySendData:
+                            addToListboxItem("状态信息:ErrorCodes");
                             break;
                         default:
+                            addToListboxItem(string.Format("客户端信息{0}", sks.ex));
                             break;
                     }
-                    addToListboxItem(string.Format("客户端信息{0}", sks.ex));
-                    //连接成功,启动心跳线程
-                    //startHeartBeat();
                 }
                 else
                 {
                     byte[] buffer = new byte[sks.Offset];
                     Array.Copy(sks.RecBuffer, buffer, sks.Offset);
                     string byteToHexStr = HexUtil.byteToHexStr(buffer);
-                    if (byteToHexStr.Equals("ServerOff"))
+
+                    if (!byteToHexStr.Equals(""))
                     {
-                        addToListboxItem("状态信息:服务端主动关闭!");
+                        handleResponse(sks, byteToHexStr);
                     }
                     else
                     {
-                        if (!byteToHexStr.Equals(""))
-                        {
-                            addToListboxItem(string.Format("收到服务端{0}发来消息：[{1}]", sks.Ip, byteToHexStr));
-                            handleResponse(sks, byteToHexStr);
-                        }
-                        else
-                        {
-                            isStartHeartbeat = false;
-                            addToListboxItem("状态信息:服务端主动关闭!");
-                            sockeTcpClients.Stop();
-                        }
-                        //                    listBoxShow.Text += "\r\n";
-                        //                    listBoxShow.Text += string.Format("服务端{0}发来消息：{1}", sks.Ip, byteToHexStr);
+                        addToListboxItem("状态信息:服务端主动关闭! position");
+                        sockeTcpClients.Stop();
                     }
+                    //                    listBoxShow.Text += "\r\n";
+                    //                    listBoxShow.Text += string.Format("服务端{0}发来消息：{1}", sks.Ip, byteToHexStr);
                 }
             }));
         }
 
-        //处理回复信息
+        /// <summary>
+        /// 处理回复信息
+        /// </summary>
+        /// <param name="sks">Socket对象</param>
+        /// <param name="reqData">服务器发过来的信息</param>
         private void handleResponse(SocketHelper.Sockets sks, string reqData)
         {
             //取出原数据功能码
             string functionWord = reqData.Substring(18, 2);
             int funcode = Utils.hexToTen(functionWord);
 
+
+            //处理心跳的回复
+            if (funcode == 4)
+            {
+                string hbLen = reqData.Substring(20, 4);
+
+                if (ToolStripMenuItemLogHb.Checked && hbLen.Equals("0000"))
+                {
+                    addToListboxItem(string.Format("收到服务端{0}发来心跳：[{1}]", sks.Ip, reqData));
+                }
+            }
+            else
+            {
+                addToListboxItem(string.Format("收到服务端{0}发来消息：[{1}]", sks.Ip, reqData));
+            }
+
             if (!(funcode == 16 || funcode == 32))
             {
                 Console.WriteLine("功能码10进制=" + funcode + ",所以不用回复!");
             tsslEquipmentAddress.Text = equipmentAddress.Length / 2.0 + "";
         }
 
+
+        private void sendLoginCmd()
+        {
+            //                string loginCmd = "7e7e7e4442832e833c8200143839383630324231313931353530343739383737f7";
+            string loginCmd = vcarecityProtocolBean.ProtocolStartSymbol;
+            loginCmd += tbEquipmentAddress.Text.Trim() + "82" +
+                        Utils.stringWith0(Utils.tenToHex(tbCCID.Text.Trim().Length / 2), 4);
+            loginCmd += tbCCID.Text.Trim();
+            loginCmd = Utils.calcCrcCode(loginCmd);
+            //发送登录命令
+            byte[] ts = HexUtil.hexToBytes(loginCmd);
+
+            addToListboxItem(string.Format("发送到服务端:[{0}]", loginCmd));
+
+            sockeTcpClients.SendData(ts);
+        }
+
         private void btnLogin_Click(object sender, EventArgs e)
         {
             try
 
                 sockeTcpClients.InitSocket(ip, int.Parse(port));
                 sockeTcpClients.Start();
-
-                //                string loginCmd = "7e7e7e4442832e833c8200143839383630324231313931353530343739383737f7";
-                string loginCmd = vcarecityProtocolBean.ProtocolStartSymbol;
-                loginCmd += tbEquipmentAddress.Text.Trim() + "82" +
-                            Utils.stringWith0(Utils.tenToHex(tbCCID.Text.Trim().Length / 2), 4);
-                loginCmd += tbCCID.Text.Trim();
-                loginCmd = Utils.calcCrcCode(loginCmd);
-                //发送登录命令
-                byte[] ts = HexUtil.hexToBytes(loginCmd);
-
-                addToListboxItem(string.Format("发送到服务端:[{0}]", loginCmd));
-
-                sockeTcpClients.SendData(ts);
             }
             catch (Exception ex)
             {
 
         private void btnQuickLogout_Click(object sender, EventArgs e)
         {
-            isStartHeartbeat = false;
             try
             {
                 sockeTcpClients.Stop();
             ToolStripMenuItemLogHb.Checked = !ToolStripMenuItemLogHb.Checked;
         }
 
-        private void ToolStripMenuItemHbStart_Click(object sender, EventArgs e)
+
+        private void checkLogin(bool isLogin)
         {
-            ToolStripMenuItemHbStart.Checked = !ToolStripMenuItemHbStart.Checked;
+            if (isLogin)
+            {
+                btnLogin.Enabled = false;
+                btnQuickLogout.Enabled = true;
+                btnSendData.Enabled = true;
+            }
+            else
+            {
+                btnLogin.Enabled = true;
+                btnQuickLogout.Enabled = false;
+                btnSendData.Enabled = false;
+            }
         }
-
-       
     }
 }

GWSocketClient/InfoEditor.Designer.cs

             this.btnLoadFromExcel = new System.Windows.Forms.Button();
             this.InfoEditorTip = new System.Windows.Forms.RichTextBox();
             this.btnClearAll = new System.Windows.Forms.Button();
+            this.cbItemType = new System.Windows.Forms.ComboBox();
+            this.tbInputData = new System.Windows.Forms.TextBox();
+            this.btnQueryItem = new System.Windows.Forms.Button();
             ((System.ComponentModel.ISupportInitialize)(this.dataGridView1)).BeginInit();
             this.contextMenuStrip1.SuspendLayout();
             this.SuspendLayout();
             this.btnClearAll.UseVisualStyleBackColor = true;
             this.btnClearAll.Click += new System.EventHandler(this.btnClearAll_Click);
             // 
+            // cbItemType
+            // 
+            this.cbItemType.DropDownStyle = System.Windows.Forms.ComboBoxStyle.DropDownList;
+            this.cbItemType.Font = new System.Drawing.Font("宋体", 9.75F, System.Drawing.FontStyle.Regular, System.Drawing.GraphicsUnit.Point, ((byte)(134)));
+            this.cbItemType.FormattingEnabled = true;
+            this.cbItemType.ItemHeight = 13;
+            this.cbItemType.Items.AddRange(new object[] {
+            "ID-10进制",
+            "ID-16进制",
+            "名字-IDInfo",
+            "描述-Desp"});
+            this.cbItemType.Location = new System.Drawing.Point(657, 39);
+            this.cbItemType.Name = "cbItemType";
+            this.cbItemType.Size = new System.Drawing.Size(92, 21);
+            this.cbItemType.TabIndex = 12;
+            // 
+            // tbInputData
+            // 
+            this.tbInputData.Font = new System.Drawing.Font("宋体", 9.75F, System.Drawing.FontStyle.Regular, System.Drawing.GraphicsUnit.Point, ((byte)(134)));
+            this.tbInputData.Location = new System.Drawing.Point(755, 38);
+            this.tbInputData.Name = "tbInputData";
+            this.tbInputData.Size = new System.Drawing.Size(100, 22);
+            this.tbInputData.TabIndex = 13;
+            // 
+            // btnQueryItem
+            // 
+            this.btnQueryItem.DialogResult = System.Windows.Forms.DialogResult.Cancel;
+            this.btnQueryItem.Font = new System.Drawing.Font("微软雅黑", 9.75F, System.Drawing.FontStyle.Regular, System.Drawing.GraphicsUnit.Point, ((byte)(134)));
+            this.btnQueryItem.Location = new System.Drawing.Point(861, 34);
+            this.btnQueryItem.Name = "btnQueryItem";
+            this.btnQueryItem.Size = new System.Drawing.Size(75, 30);
+            this.btnQueryItem.TabIndex = 14;
+            this.btnQueryItem.Text = "查找数据";
+            this.btnQueryItem.UseVisualStyleBackColor = true;
+            this.btnQueryItem.Click += new System.EventHandler(this.btnQueryItem_Click);
+            // 
             // InfoEditor
             // 
             this.AutoScaleDimensions = new System.Drawing.SizeF(6F, 12F);
             this.AutoScaleMode = System.Windows.Forms.AutoScaleMode.Font;
             this.CancelButton = this.btnClosedThis;
             this.ClientSize = new System.Drawing.Size(1241, 761);
+            this.Controls.Add(this.btnQueryItem);
+            this.Controls.Add(this.tbInputData);
+            this.Controls.Add(this.cbItemType);
             this.Controls.Add(this.btnClearAll);
             this.Controls.Add(this.InfoEditorTip);
             this.Controls.Add(this.btnLoadFromExcel);
             ((System.ComponentModel.ISupportInitialize)(this.dataGridView1)).EndInit();
             this.contextMenuStrip1.ResumeLayout(false);
             this.ResumeLayout(false);
+            this.PerformLayout();
 
         }
 
         private System.Windows.Forms.Button btnLoadFromExcel;
         private System.Windows.Forms.RichTextBox InfoEditorTip;
         private System.Windows.Forms.Button btnClearAll;
+        private System.Windows.Forms.ComboBox cbItemType;
+        private System.Windows.Forms.TextBox tbInputData;
+        private System.Windows.Forms.Button btnQueryItem;
     }
 }

GWSocketClient/InfoEditor.cs

         private void InfoEditor_Load(object sender, EventArgs e)
         {
             dataGridView1.DataSource = AccsessDbLoader.getInstance().getDataTable();
+            cbItemType.SelectedIndex = 0;
         }
 
 
             }
             this.DialogResult = DialogResult.None;
         }
+
+        private void btnQueryItem_Click(object sender, EventArgs e)
+        {
+            int mType = cbItemType.SelectedIndex;
+            dataGridView1.DataSource = AccsessDbLoader.getInstance().findDataByType(mType, tbInputData.Text.Trim())
+                .getDataTable();
+
+            this.DialogResult = DialogResult.None;
+        }
     }
 }

GWSocketClient/db/AccsessDbLoader.cs

             objConnection.Close();
         }
 
-        public AccsessDbLoader reloadAccessDb()
+        public AccsessDbLoader reloadAccessDb(string sql = @"select * from fw")
         {
+            Console.WriteLine(sql);
             try
             {
-                OleDbCommand sqlcmd = new OleDbCommand(@"select * from fw", objConnection);
+//                OleDbCommand sqlcmd = new OleDbCommand(@"select * from fw", objConnection);
+                OleDbCommand sqlcmd = new OleDbCommand(sql, objConnection);
 
                 dataAdapter = new OleDbDataAdapter(sqlcmd);
                 dataTable.Clear();
 //                wvBeans.Clear();
                 dataAdapter.Fill(dataTable);
 
-                using (OleDbDataReader reader = sqlcmd.ExecuteReader())
-                {
-                    while (reader.Read()) //这个read调用很重要！不写的话运行时将提示找不到数据  
-                    {
-                        WvBean wb = new WvBean();
-                        int id = 0;
-                        int index = 0;
-                        string myId = "";
-                        string idInfo = "";
-                        string len = "";
-                        string mode = "";
-                        string desp = "";
-                        string defalutValue = "";
-                        string userValue = "";
-                        string remark = "";
-                        /*try
-                        {*/
-                        id = reader.GetInt32(0);
-                        index = reader.GetInt32(1);
-                        myId = reader.GetString(2);
-                        idInfo = calcNull(reader.GetString(3));
-                        len = calcNull(reader.GetString(4));
-                        mode = calcNull(reader.GetString(5));
-                        desp = calcNull(reader.GetString(6));
-                        defalutValue = calcNull(reader.GetString(7));
-                        userValue = calcNull(reader.GetString(8));
-                        remark = calcNull(reader.GetString(9));
-                        /* }
-                         catch (Exception exception)
-                         {
-                         }*/
-
-                        wb.id = id;
-                        wb.index = index;
-                        wb.myId = myId;
-                        wb.idInfo = idInfo;
-                        wb.len = len;
-                        wb.mode = mode;
-                        wb.desp = desp;
-                        wb.defalutValue = defalutValue;
-                        wb.userValue = userValue;
-                        wb.remark = remark;
-
-                        ID_INFO.Add(myId, userValue);
-
-//                        wvBeans.Add(wb);
-                    }
-                }
+                fillData(sqlcmd);
             }
             catch (OleDbException oe)
             {
             return this;
         }
 
+        public AccsessDbLoader findDataByType(int mType, string query)
+        {
+            /*
+            ID - 10进制
+           ID - 16进制
+           名字 - IDInfo
+           描述 - Desp
+           */
+            string sql = "select * from fw ";
+
+            switch (mType)
+            {
+                case 0:
+                    sql += " where my_index = " + query;
+                    break;
+                case 1:
+                    sql += " where MY_ID = '" + query + "'";
+                    break;
+                case 2:
+                    sql += " where idInfo like '%" + query + "%'";
+                    break;
+                case 3:
+                    sql += " where desp like '%" + query + "%'";
+                    break;
+                default:
+                    return reloadAccessDb();
+            }
+            return reloadAccessDb(sql);
+        }
+
+        private void fillData(OleDbCommand sqlcmd)
+        {
+            using (OleDbDataReader reader = sqlcmd.ExecuteReader())
+            {
+                while (reader.Read()) //这个read调用很重要！不写的话运行时将提示找不到数据  
+                {
+                    WvBean wb = new WvBean();
+                    int id = 0;
+                    int index = 0;
+                    string myId = "";
+                    string idInfo = "";
+                    string len = "";
+                    string mode = "";
+                    string desp = "";
+                    string defalutValue = "";
+                    string userValue = "";
+                    string remark = "";
+                    /*try
+                    {*/
+                    id = reader.GetInt32(0);
+                    index = reader.GetInt32(1);
+                    myId = reader.GetString(2);
+                    idInfo = calcNull(reader.GetString(3));
+                    len = calcNull(reader.GetString(4));
+                    mode = calcNull(reader.GetString(5));
+                    desp = calcNull(reader.GetString(6));
+                    defalutValue = calcNull(reader.GetString(7));
+                    userValue = calcNull(reader.GetString(8));
+                    remark = calcNull(reader.GetString(9));
+                    /* }
+                     catch (Exception exception)
+                     {
+                     }*/
+
+                    wb.id = id;
+                    wb.index = index;
+                    wb.myId = myId;
+                    wb.idInfo = idInfo;
+                    wb.len = len;
+                    wb.mode = mode;
+                    wb.desp = desp;
+                    wb.defalutValue = defalutValue;
+                    wb.userValue = userValue;
+                    wb.remark = remark;
+
+                    ID_INFO.Add(myId, userValue);
+
+                    //                        wvBeans.Add(wb);
+                }
+            }
+        }
+
 
         public int insert2Db(WvBean wb)
         {
             }
             catch (Exception e)
             {
-                
                 Console.WriteLine(e);
             }
             Console.WriteLine(wb.ToString());
             return inst.ExecuteNonQuery();
         }
 
+
         private string calcNull(string ojb)
         {
             if (ojb.Trim().Equals("") || ojb == null)

README.md

 
 # CSharp
 >git remote add origin http://gitea.vcarecity.com/kerryzhang/GWSocketClient.git
->git push -u origin master
+>git push -u origin master
+
+
+
+
+
+## 要解决问题
+
+1. 服务器没开
+2. 超时
+3. 连接成功了,但服务器主动断开
+
+