在做网络通讯方面的程序时，必不可少的是Socket通讯。
那么我们需要有一套既定的，简易的通讯流程。
如下：
<pre name="code" class="csharp">public class PublicSocket
{
public const string DOWNLOAD_STATUS_WAIT = "1";
public const string DOWNLOAD_STATUS_PAUSE = "2";
public const string DOWNLOAD_STATUS_DOWNLOADING = "3";
public const string DOWNLOAD_STATUS_DOWNLOADED = "4";
public const string DOWNLOAD_STATUS_ERROR = "5";
//private XmlHelper xmlhelper = new XmlHelper();
private TcpClient tcpMethod = new TcpClient();
public static string LoginUserName = "";
public static Socket HeadClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
private static string iAddress = "192.168.1.1";
private static int iPort = 7888;
private static IPEndPoint endpoint = new IPEndPoint(IPAddress.Parse(iAddress), iPort);
public const int LOGIN_NAMEERROR = 100000;
public const int LOGIN_CODEERROR = 100001;
public const int LOGIN_ERROR = 100002;
public const int LOGIN_OK = 100003;
public static bool AllowUpdate = true;
public static void SocketConnect()
{
try
{
if (!HeadClient.Connected)
{
HeadClient.Connect(endpoint);
}
}
catch (Exception ex)
{ }
}
public static void SocketClose()
{
if (HeadClient.Connected)
{
HeadClient.Close();
}
}
public static void ThreadGetSingleDownloadedFile(object data) //object参数可以实现界面传入数据进行使用
{
string retMD5 = string.Empty;
try
{
HanleListItemClass formInter = data as HanleListItemClass;
XmlDocument aa = XmlHelper.BuildXmlDoc("CMD", "1", "1",
new List<HollXmlNode> { new HollXmlNode("ID","2",null),
new HollXmlNode("STATE","127",null) });
//主要为了构建XML文件进行Socket的send操作
//构造后如下 <?xml version=‘1.0‘ encoding=‘utf-8‘?><CMD code=‘1‘ index=‘1‘>
// <ID>2</ID>
// <STATE>127</STATE></CMD>
byte[] sendaskbyte = Encoding.UTF8.GetBytes(aa.InnerXml.ToString());
int sendcount = 0;
try
{
sendcount = HeadClient.Send(sendaskbyte, sendaskbyte.Length, 0);
}
catch (Exception ex)
{
// return LOGIN_ERROR;
}
if (sendcount == 0)
{
//return LOGIN_ERROR;
}
int ret = SingleDownloadedFileWaitBack(formInter);
}
catch
{
//return LOGIN_ERROR;
}
}
public static int SingleDownloadedFileWaitBack(HanleListItemClass tItemclass)
{
byte[] RetData = new byte[36 * 1024];
Array.Clear(RetData, 0, RetData.Length);
int datalen = 0;
try
{
datalen = HeadClient.Receive(RetData);
if (datalen == 0)
{
return -1;
}
//接收到服务器返回的信息
string tcpdatastring = Encoding.UTF8.GetString(RetData).Replace("\0", " "); ;
//此处可以根据自己需求处理返回的信息 http://www.cnblogs.com/sosoft/
return 0;
}
catch (Exception ex)
{
return 0;
}
}
}
然后再界面调用的时候，我们只需要在事件中这么使用即可
private void button1_Click(object sender, EventArgs e)
{ PublicSocket.SocketConnect();
ThreadPool.QueueUserWorkItem(new WaitCallback(SocketMethod.ThreadGetTotalState), this);
}
同时也把构建XML的类分享出来，使得编码更加简便
1 public class XmlHelper
2 {
3 private static string xmlinit = "<?xml version=‘1.0‘ encoding=‘utf-8‘?><{0} code=‘{1}‘ index=‘{2}‘></{0}>";
4
5 public static XmlDocument BuildXmlDoc(string xmltype, string code, string index, List<HollXmlNode> xmlnodes)
6 {
7 XmlDocument root = new XmlDocument();
8 root.LoadXml(string.Format(xmlinit, xmltype, code, index));
9
10 if (xmlnodes != null)
11 {
12 for (int i = 0; i < xmlnodes.Count; i++)
13 {
14 XmlElement parentNode = root.CreateElement(xmlnodes[i].NodeName);
15
16 XmlText descText = root.CreateTextNode(xmlnodes[i].NodeValue);
17 parentNode.AppendChild(descText);
18
19
20 if (xmlnodes[i].NodeAtt != null)
21 {
22 if (xmlnodes[i].NodeAtt.Count > 0)
23 {
24 for (int j = 0; j < xmlnodes[i].NodeAtt.Count; j++)
25 {
26 parentNode.SetAttribute(xmlnodes[i].NodeAtt[j].AttName, xmlnodes[i].NodeAtt[j].AttValue);
27 }
28 }
29 }
30
31 root.LastChild.AppendChild(parentNode);
32 }
33 }
34
35
36 return root;
37 }
38
39
40 }
1 public class HollXmlNode
2 {
3 private string _nodename;
4 private string _nodevalue;
5 private List<HollXmlAttribute> _nodeatt;
6
7
8 public HollXmlNode(string tnodename, string tnodevalue, List<HollXmlAttribute> tnodeatt)
9 {
10 _nodename = tnodename;
11 _nodevalue = tnodevalue;
12 _nodeatt = tnodeatt;
13 }
14
15
16 public string NodeName
17 {
18 get { return _nodename; }
19 set { _nodename = value; }
20 }
21
22
23
24
25 public string NodeValue
26 {
27 get { return _nodevalue; }
28 set { _nodevalue = value; }
29 }
30
31
32 public List<HollXmlAttribute> NodeAtt
33 {
34 get { return _nodeatt; }
35 set { _nodeatt = value; }
36 }
37 }
38
39
40 public class HollXmlAttribute
41 {
42 private string _attname;
43 private string _attvalue;
44
45
46 public HollXmlAttribute(string tname, string tvalue)
47 {
48 _attname = tname;
49 _attvalue = tvalue;
50 }
51
52
53 public string AttName
54 {
55 get { return _attname; }
56 set { _attname = value; }
57 }
58
59
60 public string AttValue
61 {
62 get { return _attvalue; }
63 set { _attvalue = value; }
64 }
65 }
c# TCP Socket通讯基础,布布扣,bubuko.com
时间： 2024-08-05 07:09:16