[深入浅出WP8.1(Runtime)]Socket编程之UDP协议

13.3 Socket编程之UDP协议

UDP协议和TCP协议都是Socket编程的协议,但是与TCP协议不同,UDP协议并不提供超时重传,出错重传等功能,也就是说其是不可靠的协议。UDP适用于一次只传送少量数据、对可靠性要求不高的应用环境。既然 UDP 是一种不可靠的网络协议,那么还有什么使用价值或必要呢?其实不然,在有些情况下UDP协议可能会变得非常有用。因为UDP具有TCP所望尘莫及的速度优势。虽然TCP协议中植入了各种安全保障功能,但是在实际执行的过程中会占用大量的系统开销,无疑使速度受到严重的影响。反观UDP由于排除了信息可靠传递机制,将安全和排序等功能移交给上层应用来完成,极大降低了执行时间,使速度得到了保证。那么在Windows Phone里面的UDP协议的通讯是通过DatagramSocket类来实现消息的发送,接受和监听等功能的,下面我们来看一下如何在Windows Phone中实现UDP协议的通信。

13.3.1 发送和接收消息

使用UDP协议进行消息的发送和接收和TCP协议是有区别的,UDP协议并不一定要进行连接的操作,它可以直接通过主机地址进行消息的发送和接收。使用UDP协议进行消息的发送和接收也一样是要依赖DataWriter类和DataReader类来进行分别进行数据的发送和接收。下面我们来看一下在Windows Phone中使用UDP协议进行发送和接收消息的两种方式。

(1)使用主机名和端口号直接发送和接收消息

创建一个DatagramSocket类对象,调用GetOutputStreamAsync方法获取输出流IOutputStream对象,再使用IOutputStream对象创建DataWriter对象进行消息的发送。接收消息直接订阅DatagramSocket对象的MessageReceived事件接收消息,使用DataReader对象获取消息的内容。示例代码如下所示:

    // 主机名

    HostName hostName = new HostName("localhost");

    DatagramSocket datagramSocket = new DatagramSocket();

    // 订阅接收消息的事件

    datagramSocket.MessageReceived += datagramSocket_MessageReceived;

    // 获取输出流

    IOutputStream outputStream = await datagramSocket.GetOutputStreamAsync(hostName, "22112");

    // 创建DataWriter对象发送消息

    DataWriter writer = new DataWriter(datagramSocket.OutputStream);

    writer.WriteString("test");

    await writer.StoreAsync();

    // 接收消息的事件处理程序

    async void datagramSocket_MessageReceived(DatagramSocket sender, DatagramSocketMessageReceivedEventArgs args)

    {

        // 获取DataReader对象,读取消息内容

        DataReader dataReader = args.GetDataReader();

        uint length = dataReader.UnconsumedBufferLength;

        string content = dataReader.ReadString(length);

    }

(2)先连接Socket再发送接收消息

DatagramSocket类也提供了ConnectAsync方法来负责Socket的连接,连接成功之后就可以使用该DatagramSocket对象来进行消息的发送,消息的接收和第一种方式的实现是一样的。示例代码如下所示:

    // 创建DatagramSocket

    DatagramSocket datagramSocket = new DatagramSocket();

    datagramSocket.MessageReceived += datagramSocket_MessageReceived;

    // 连接服务器

    await datagramSocket.ConnectAsync(new HostName("localhost"), "22112");

    // 发送消息

    DataWriter writer = new DataWriter(datagramSocket.OutputStream);

    writer.WriteString("test");

    await writer.StoreAsync();

13.3.2 UDP协议服务器端监听消息

UDP协议在实现服务器端监听消息的功能也是使用DatagramSocket类去实现的,实现的步骤如下所示:

(1)注册DatagramSocket对象的MessageReceived事件接收消息(注意和TCP的ConnectionReceived事件的区别);

(2)使用BindServiceNameAsync方法建立起本地服务器的监听;

(3)使用GetOutputStreamAsync方法传入服务器地址和端口号,获取IOutputStream对象,从而创建DataWriter对象向客户端发送消息。

UDP协议服务器端监听消息的代码示例如下所示:

    // 创建DatagramSocket对象,调用BindServiceNameAsync方法绑定服务

    DatagramSocket datagramSocket = new DatagramSocket();

    // 订阅MessageReceived事件监听客户端发送过来的消息

    datagramSocket.MessageReceived += datagramSocket_MessageReceived;

    await datagramSocket.BindServiceNameAsync("22112");

    // MessageReceived事件的处理程序,获取到客户端的地址后可以向客户端发送消息

    async void datagramSocket_MessageReceived(DatagramSocket sender, DatagramSocketMessageReceivedEventArgs args)

    {

        // 读取客户端发送过来的消息

        DataReader dataReader = args.GetDataReader();

        uint length = dataReader.UnconsumedBufferLength;

        string content = dataReader.ReadString(length);

        IOutputStream outputStream = await sender.GetOutputStreamAsync(

                args.RemoteAddress,

                args.RemotePort);

        DataWriter writer = new DataWriter(outputStream);

        writer.WriteString(content + "(服务器发送)" );

        await writer.StoreAsync();

    }

本文来源于《深入浅出Windows Phone 8.1 应用开发》

WP8.1 Runtime文章列表:http://www.cnblogs.com/linzheng/p/3998037.html

源代码下载:http://vdisk.weibo.com/s/zt_pyrfNHb99O

欢迎关注我的微博@WP林政   微信公众号:wp开发(号:wpkaifa)

WP8.1技术交流群:372552293

时间: 2024-12-16 06:43:27

[深入浅出WP8.1(Runtime)]Socket编程之UDP协议的相关文章

[深入浅出WP8.1(Runtime)]网络编程之HttpClient类

12.2 网络编程之HttpClient类 除了可以使用HttpWebRequest类来实现HTTP网络请求之外,我们还可以使用HttpClient类来实现.对于基本的请求操作,HttpClient类提供了一个简单的接口来处理最常见的任务,并为身份验证提供了适用于大多数方案的合理的默认设置.对于较为复杂的 HTTP 操作,更多的功能包括:执行常见操作(DELETE.GET.PUT 和 POST)的方法:获取.设置和删除 Cookie 的功能:支持常见的身份验证设置和模式:异步方法上提供的 HTT

计算机网络socket编程之UDP

>UDP是一种不面向连接的不可靠的网络传输协议 UDP协议前面大部分和TCP协议差不多,只是他的客户程序不需要连接,而是直接发送数据. >sendto() 和recvfrom() 函数 使用这两个函数,则数据会在没有建立过任何连接的网络上传输.正好可以在进行无连接的UDP 通讯时使用的.因为数据报套接字无法对远程主机进行连接,想想我们在发送数据前需要知道些什么呢?是远程主机的IP 地址和端口! 下面是sendto()函数和recvfrom()函数的声明: #include <sys/ty

【Linux】Linux C socket 编程之UDP

发送方: /* * File: main.c * Author: tianshuai * * Created on 2011年11月29日, 下午10:34 * * 主要实现:发送20个文本消息,然后再发送一个终止消息 */ #include <stdio.h> #include <stdlib.h> #include <string.h> #include <sys/socket.h> #include <netinet/in.h> #incl

java 25 - 4 网络编程之 UDP协议传输的代码优化

UDP协议的输出端: 1 /* 2 UDP发送数据: 3 A:创建Socket发送端对象 4 B:创建数据报包(把数据打包) 5 C:调用Socket对象发送数据报包 6 D:释放资源(底层是IO流) 7 */ 8 public class NewSend { 9 10 public static void main(String[] args) throws IOException { 11 12 // A:创建Socket发送端对象 13 DatagramSocket ds = new Da

java 25 - 4 网络编程之 UDP协议传输思路

UDP传输 两个类:DatagramSocket与DatagramPacket(具体看API) A:建立发送端,接收端. B:建立数据包. C:调用Socket的发送接收方法. D:关闭Socket. E:发送端与接收端是两个独立的运行程序. UDP传输-发送端思路 UDP发送数据: A:创建Socket发送端对象 B:创建数据报包(把数据打包) C:调用Socket对象发送数据报包 D:释放资源(底层是IO流) UDP传输-发送端代码 1 public static void main(Str

计算机网络Socket编程之TCP协议

>TCP协议位于传输层,是一种面向连接的可靠的传输协议 >socket(套接字):是IP地址与端口号的统称 >套接字的基本结构 struct sockaddr   这个结构用来存储套接字地址 结构体的定义 struct sockaddr { unsigned short sa_family; /* address族, AF_xxx */ har sa_data[14]; /* 14 bytes的协议地址 */ }; sa_family    一般来说,都是"AFINET&quo

黑马程序员【网络编程之UDP协议】

UDP协议 UDP(User Datagram Protocol)也就是用户数据报协议,是一种无连接的传输层协议,提供面向事务的简单不可靠信息传送服务,IETF RFC 768是UDP的正式规范. 提到无连接数据传输,那我们首先想到的就是不可靠,数据丢失等等,那么在我们的日常软件中,UDP协议到底都应用在什么场景上呢?举一个大家比较熟悉的例子,就是我们平时所用的聊天软件,因为我们的聊天软件所传输的数据并非是重要数据. 通过ip和端口号,我们可以实现一个小的聊天软件,有兴趣的朋友可以在局域网内通过

Java Socket编程之UDP

UDP编程: 将要传输的数据定义成数据包(Datagram),在数据报中指明所要到达的Socket(主机地址和端口号),然后再将数据报发送出去. 相关操作类:     DatagramPacket   数据报包 DatagramSocket   进行端到端通信的类 服务器端实现步骤: 创建DatagramSocket,指定端口号 创建DatagramPacket 接收客户端发送的数据信息 读取数据 客户端实现步骤: 定义发送信息 创建DatagramPacket,包含将要发送的信息 创建Data

java网络编程之UDP实例

package Socket; import java.net.DatagramPacket; import java.net.InetAddress; public class Dgram { public static DatagramPacket toDatagram(String s, InetAddress destIA, int destPort) { byte[] buf = new byte[s.length() + 1]; s.getBytes(0, s.length(), b