.net的socket异步通讯示例分享

 这篇文章主要介绍了.net的socket异步通讯示例,操作在下面,需要的朋友可以参考下

1、首先添加两个windows窗体项目,一个作为服务端server,一个作为客户端Client
 
2、然后添加服务端代码,添加命名空间,界面上添加TextBox控件
 
 代码如下:
using System.Net;
using System.Net.Sockets;
 
 
3、FormLoad方法添加代码
 
 代码如下:
private void Form1_Load(object sender, EventArgs e)
        {
            IPEndPoint epServer = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 7878);//IP地址和端口号
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//定义socket
            socket.Bind(epServer);//绑定
            socket.Listen(10);//监听
            socket.BeginAccept(new AsyncCallback(RecVing), socket);//异步接收,回调方法为RecVing
        }
 
 
4、添加回调方法代码
 
 代码如下:
private void RecVing(IAsyncResult rec_socket)
        {
            string cmdstr = "";
            Socket sc = (Socket)rec_socket.AsyncState;
            Socket socket = sc.EndAccept(rec_socket);
            byte[] bytes = new byte[1024];
            int i = socket.Receive(bytes);
            cmdstr = Encoding.UTF8.GetString(bytes, 0, i);
            showstrs(cmdstr);
            sc.BeginAccept(new AsyncCallback(RecVing), sc);
        }
 
 
5、添加showstrs方法,
 
定义委托private delegate void shixudong_invoke(string invokefun);
 
 代码如下:
private void showstrs(string recv_strs)
        {
            if (recv_strs.Length != 0)
            {
                if (this.InvokeRequired)
                {
                    shixudong_invoke invoke = new shixudong_invoke(showstrs);
                    this.Invoke(invoke, (object)recv_strs);
                }
                else
                {
                    textBox1.Text = recv_strs;
 
                }
            }
 
 
6、到此为止,服务端已经添加完毕
 
7,客户端代码,首先跟服务端一样,添加命名空间,在界面上添加button事件
 
 代码如下:
private void button1_Click(object sender, EventArgs e)
        {
            IPEndPoint IPEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), 7878);//IP,端口号
            Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            socket.BeginConnect(IPEndPoint, new AsyncCallback(Sending), socket);//回调方法Sending
        }
 
 
8、添加回调方法,代码如下
 
代码如下:
private void Sending(IAsyncResult rec_socket)
        {
            Socket socket = (Socket)rec_socket.AsyncState;
            try
            {
                if (socket.Connected)
                {
                    byte[] msgBuff = Encoding.UTF8.GetBytes(textBox1.Text);
                    socket.Send(msgBuff);
                    //socket.Accept();
                }
                else
                {
                    Console.WriteLine("Error!", "Error!");
                }
            }
            catch
            {
                Console.WriteLine("Error!", "Error!");
            }
 
 
9、到此为止,客户端代码已经完成,调试的时候先启动服务端,然后启动客户端
 
10、运行截图如下,点击按钮前,在文本框中输入shixudong
 

时间: 2024-08-03 09:03:57

.net的socket异步通讯示例分享的相关文章

.net的socket异步通讯示例分享_实用技巧

1.首先添加两个windows窗体项目,一个作为服务端server,一个作为客户端Client 2.然后添加服务端代码,添加命名空间,界面上添加TextBox控件 复制代码 代码如下: using System.Net;using System.Net.Sockets; 3.FormLoad方法添加代码 复制代码 代码如下: private void Form1_Load(object sender, EventArgs e)        {            IPEndPoint epS

C# Socket 异步通讯疑问

问题描述 本人初学者用异步的方法建了个UDP接收服务器经过压力测试客户端发送10W条数据(10秒左右全部发出)使用异步丢包达到20-30%应该是启动异步的时候有一段真空期没有有效的监听在运行导致数据接收失败请问这个问题如何解决同样的服务器端使用同步接收正常 解决方案 解决方案二:自己做服务器,工作量太大,可以试一下来自英国的开源的networkcomms2.31通信框架下载地址:http://pan.baidu.com/s/1nt84xNr解决方案三:引用楼主qq_25949727的回复: 本人

Socket编程 (异步通讯,解决Tcp粘包) - Part3

原文 http://www.cnblogs.com/zengqinglei/archive/2013/05/14/3078842.html Socket编程 (异步通讯,解决Tcp粘包) 从上一章的通讯中,我们发现如果使用Tcp连续发送消息会出现消息一起发送过来的情况,这样给我们编程造成一定的问题,给我们的信息解析造成一定的问题.那么这篇文章就将针对以上问题给出解决方案......   问题一般会出现的情况如下,假设我们连续发送两条两天记录("我是liger_zql"): 模拟发送示例

Socket编程 (异步通讯,解决Udp丢包) - Part4

原文http://www.cnblogs.com/zengqinglei/archive/2013/05/15/3079007.html Socket编程 (异步通讯,解决Udp丢包) 对于基于socket的udp协议通讯,丢包问题大家应该都见怪不怪了,但我们仍然希望在通讯方面使用Udp协议通讯,因为它即时,消耗资源 少,响应迅速,灵活性强无需向Tcp那样建立连接消耗很长的时间等等很有优势的理由让我们对Udp通讯寄予了厚望.但它也存在一个不好的特点,经常丢包是 时常发生的事.可能各位大侠已经有了

Java socket字节流传输示例解析_java

本文为大家分享了Java socket字节流传输示例,供大家参考,具体内容如下 服务端server端:  package com.yuan.socket; import java.io.*; import java.net.ServerSocket; import java.net.Socket; /** * Created by YUAN on 2016-09-17. */ public class TalkServer4Byte { private ServerSocket server;

PHP+Ajax异步通讯实现用户名邮箱验证是否已注册( 2种方法实现)_php实例

前 言 直接上代码有点不厚道.于是按照天朝传统,整段描述吧....(本人语言表达能力有限,大家忍着看) 功 能 在网站注册用户时使用,主要为了无刷新异步验证用户输入的用户名或者Email是否已注册. 这功能大家肯定见过,大多数网站都有的,我一直对这个功能很感兴趣,所以这几天研究了下 jQuery + Ajax 整了一个功能不算完善,但足以应付普通使用的代码 (更牛的功能大家自己去发掘) 文 件 说 明 reg.php //为注册页面 check_user.php //为用户验证页面 (GET,P

Yii2.0中使用js异步删除示例

整理文档,搜刮出一个Yii2.0中使用js异步删除示例,稍微整理精简一下做下分享. 控制器: public function actionWeixinnotificationdel() { $model = WxDistributorNotification::findOne($_GET['id']); if ($model) { if($model->delete()) { echo 1; Yii::$app->end(); } } echo 0; Yii::$app->end();

javascript请求servlet实现ajax示例(分享)

ajax请求是一种无刷新式的用户体验,可以发送GET和POST两种异步请求,现记录如下: GET请求: function sendRequestByGet(){ //定义异步请求对象 var xmlReq; //检测浏览器是否直接支持ajax if(window.XMLHttpRequest){//直接支持ajax xmlReq=new XMLHttpRequest(); }else{//不直接支持ajax xmlReq=new ActiveObject('Microsoft.XMLHTTP')

php使用socket编程的示例

 这篇文章主要介绍了php使用socket编程的示例,大家参考使用吧 2个php测试文件 server.php     代码如下: <?php //phpinfo(); //确保在连接客户端时不会超时 set_time_limit(0);   $ip = '127.0.0.1'; $port = 1935;   /*  +-------------------------------  *    @socket通信整个过程  +-------------------------------  *