webservice双工通讯代码,CSharp代码库,德仔网

代码语言

代码分类

【CSharp】 webservice双工通讯

作者:Ben / 发布于2015/7/15/ 1051

自己做webservice时。需要服务器主动通知客户端


	[WebMethod]
	 public bool game(string userName, int id)
	 {
	 try
	 {
	 DataTable dt = SqlHelper.ExecuteDataTable("SELECT Zt1,Zt2 FROM T_fangjian WHERE Id=@id",
	 new SqlParameter("@id", id));
	 string name = dt.Rows[0][0].ToString().Trim();
	 string name2 = dt.Rows[0][1].ToString().Trim();
	 if (string.IsNullOrEmpty(name))
	 {
	 //两方都未准备
	 SqlHelper.ExecuteNonQuery("UPDATE T_fangjian SET Zt1=@zt WHERE Id=@id",
	 new SqlParameter("@zt", userName + "准备"),
	 new SqlParameter("@id", id));
	 return true;
	 }
	 else if ((userName + "准备") == name)
	 {
	 return true;
	 }
	 else if ((userName + "准备") == name2)
	 { return true; }
	 else
	 {//一方已经准备好了
	 SqlHelper.ExecuteNonQuery("UPDATE T_fangjian SET Zt2=@zt WHERE Id=@id",
	 new SqlParameter("@zt", userName + "准备"),
	 new SqlParameter("@id", id));
	 DataTable dt2 = SqlHelper.ExecuteDataTable("SELECT fangzhu,player2 FROM T_fangjian WHERE Id=@id",
	 new SqlParameter("@id", id));
	 string fanghzhu = dt2.Rows[0][0].ToString().Trim();
	 string pName = dt2.Rows[0][1].ToString().Trim();
	
	 string ipend = netWork.ipGet(fanghzhu);
	 object ob = ",start" + '%' + ipend + '%' + '1';
	 Thread th = new Thread(new ParameterizedThreadStart(netWork.BeginSend));
	 th.Start(ob);
	
	 ipend = netWork.ipGet(pName);
	 ob = ",start" + '%' + ipend + '%' + '1';
	 Thread th2 = new Thread(new ParameterizedThreadStart(netWork.BeginSend));
	 th2.Start(ob);
	
	 }
	 return true;
	 }
	 catch
	 {
	 return false;
	 }
	
	 }

	

	

	public static void BeginSend(object ob)
	 {
	 string s=ob as string;
	 string message = s.Split('%')[0].Trim();
	 string ipendpoint = s.Split('%')[1].Trim();
	 string flag = s.Split('%')[2].Trim();
	
	 IPAddress serverIp = IPAddress.Parse(ipendpoint.Split(':')[0]);
	 IPEndPoint iep = new IPEndPoint(serverIp, Convert.ToInt32(ipendpoint.Split(':')[1]));
	 byte[] byteMessage;
	 Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //创建socked
	 socket.Connect(iep);
	 int leng = message.Length;
	 string S = leng + "&" + message;
	 if (flag == "0")
	 {
	 S = "&" + S;
	 }
	 else if (flag == "1")
	 {
	 S = "*" + S;
	 }
	 byteMessage = Encoding.Unicode.GetBytes(S); //讲textbox中的字符串转换成成byte流
	
	 socket.Send(byteMessage);
	
	 socket.Shutdown(SocketShutdown.Both); //发送完毕后关闭
	 socket.Close();
	 }

试试其它关键字

　webservice　　双工通讯　

同语言下

可能有用的

Ben贡献的其它代码(12)