socket通信例子.docx

编号：时间：2021年x月x日书山有路勤为径学海无涯苦作舟页码：socket通信例子publicvoidsend(){while(true){stringsql="selecttop100*fromsend";SqlDataReaderdatareader=sqlserver.ExecuteSqlDataReader(sql);if(datareader.HasRows)//有记录才进行网关联接{stringshow;stringhost;//intport=Convert.ToInt16("8801");//host=Dns.GetHostName();//host="192.168.123.110";sockettemp=newsocket();Socketsend=temp.connectSocket(this.remote_ipthis.remote_port);if(send==null){this.send_listbox("打开远程SMG失败");}else{this.send_listbox("打开远程SMG成功");byte[]bind_content=sgip_test.bind(count);count_step();byte[]receive=newbyte[256];byteflag;send.Send(bind_contentbind_content.Length0);//bindsend.Receive(receive290);//bind_resp读取29位flag=sgip_test.bind_resp_result(receive);if(flag==0)this.send_listbox("成功联接到网关");elsethis.send_listbox("联接网关失败");while(datareader.Read()){stringspnumber=datareader["spnumber"].ToString().Trim();stringchargenumber=datareader["chargenumber"].ToString().Trim();stringusernumber=datareader["usernumber"].ToString().Trim();stringservicetype=datareader["servicetype"].ToString().Trim();bytefeetype=Byte.Parse(datareader["feetype"].ToString().Trim());stringfeevalue="/datareader["feevalue"].ToString().Trim();string"content=datareader["content"].ToString().Trim();byte[]submit=sgip_test.submit(spnumberchargenumberusernumberservicetypefeetypefeevaluecontentCorpIdcount);send.Send(submitsubmit.Length0);//sumbmitcount_step();send.Receive(receive290);//submit_respflag=sgip_test.submit_resp_result(receive);if(flag==0){this.send_listbox("手机号:"+usernumber+"业务代码:"+servicetype+"SP下行号码:"+spnumber);this.send_listbox("消息内容:"+content);this.send_listbox("消息发送成功");string