年底了,人浮躁多了,沉不下去心研究技术了,不过昨天终于抢到了回家的票,很开心。
言归正卷,在WCF出来之后,可能我们玩这些原始的TCP越来越少了,我们知道WCF对TCP进行了再一次的包装,第一反应给我们的或许是
同构系统用TCP,异构系统用HTTP,那么问题来了,异构系统到底可不可以用TCP呢?至少WCF是玩不了的,因为其他语言没有针对.net的“服务
引用”,也没有什么ChannelFactory给你去玩,如果你是一定要追求性能的话,原始的TCP会助你一臂之力的。
我们知道最最原始的是玩Socket,由于Socket比较复杂,但是最灵活,C#里面提供了两个简化的包装类:TcpListener和TcpClient。
一:TcpListener
这个是作为服务器端程序而存在的,我们来看看如何使用这服务端。
1: 开启监听地址
1 TcpListener listener = new TcpListener(new Sy@R_404[email protected](new byte[] { 127,0,1)">1 }),1)">2222); 2 3 listener.Start();
2:好了,已经开启了,服务端程序开始监听该端口的客户端请求了,那么如何获取该请求呢?简单,listener的AcceptTcpClient属性搞定。
1 var myclient = listener.AcceptTcpClient();
3:我们知道TCP传的是字节流,通过myclient.GetStream()就可以获取一个NetworkStream,利用这个Stream就可以进行收发信息了。
<1> 收操作:
1 BinaryReader sr = new BinaryReader(client.GetStream()); 3 //客户端数据 4 var data = sr.ReadString();
<2>发操作:也就是所谓的返回值
处理完了之后要返回数据给客户端 2 BinaryWriter sw = BinaryWriter(client.GetStream()); 3 4 sw.Write(string.Format("当前时间:{0},服务端已经处理完毕!",DateTime.Now));
这里要注意的地方就是AcceptTcpClient是阻塞线程的,直到收到客户端请求才算建立了一个TCP连接,在服务端处理的过程中,后续的客户端的请求将
会处理等待直到前一个请求处理完,说了这么多,就是每一个请求我们都建议开一个线程专门为其服务,类似这样。
1 接受客户端的连接请求 2 var myclient = listener.AcceptTcpClient(); 3 4 用工作线程执行用户的请求 5 Task.Factory.StartNew((obj) => 6 { 7 var client = obj as TcpClient; 8 9 client.Close(); 10 11 },myclient);
好了,服务器端大概就是这个样子,再有的就是一些相关属性配置了,像wcf那样什么opentime,sendtime啥的。
二:TcpClient
客户端也很简单,只要我们Connect一下端口,然后通过NetworkStream再Send一些数据就OK了。
1 TcpClient client = TcpClient(); 3 client.Connect(4 5 BinaryWriter bw = 6 7 bw.Write(你好,我来请求你! {0},当前线程:{1}一个大家都懂的道理就是线程多了不是好事情。服务端:
View Code
using Sy@R_404_6063@; Sy@R_404[email protected]; 3 Sy@R_404[email protected]; Sy@R_404[email protected]; 5 Sy@R_404[email protected].sockets; Sy@R_404[email protected]; 7 Sy@R_404[email protected]; 8 Sy@R_404[email protected]; Sy@R_404[email protected]; 11 namespace ConsoleApplication1 12 13 class Program 14 { 15 static void Main(string[] args) 16 { 17 TcpListener listener = 18 19 listener.Start(); 20 21 用专门的线程来接受请求 22 Task.Factory.StartNew(() => 23 { 24 不间断的接受客户端请求 25 while (true) 26 { 27 28 29 30 31 Task.Factory.StartNew((obj) => 32 { 33 34 35 BinaryReader sr = 36 37 38 var data = sr.ReadString(); 39 40 客户端ip 41 var ip = (IPEndPoint)client.Client.RemoteEndPoint; 42 43 Console.WriteLine(",DateTime.Now,44 ip.Address,ip.Port,data); 45 46 Thread.Sleep(1000 * 547 48 49 BinaryWriter sw = 50 51 sw.Write(Now)); 52 53 client.Close(); 54 55 },myclient); 56 } 57 }); 58 59 Console.WriteLine(服务端已经启动...60 61 Console.Read(); 62 } 63 } 64 }
客户端:
View Code
9 10 ConsoleApplication2 12 13 14 15 16 for (int i = 0; i < 100; i++17 18 Task.Factory.StartNew(() => 20 int j = 0; j < 100; j++21 22 TcpClient client = 23 24 client.Connect(25 26 BinaryWriter bw = 27 28 bw.Write(30 BinaryReader sr = 31 32 var s =33 34 Console.WriteLine(接受到数据:{0}35 } 36 }); 37 } 38 39 40 41 42 }
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。