用Java编写简单的UDP网络通信程序

Java中封装了大量的socket API 为编写网络通信程序提供了极大的方便 在计算机网络的学习中 大家都已熟练掌握了TCP/UDP的基本原理 在此不在赘述 仅给出接收端和发送端的源代码 供大家讨论学习 发送端代码祥闷绝如下:import java io *import java lang *import *public class uclient谨姿{private DatagramSocket cliprivate DatagramPacket pacprivate byte *** []private String senpublic uclient(){Init()}public void Init(){try{//指定端口号 避免与其他应用程序发生冲突cli=new DatagramSocket( )*** =new byte[ ]sen= UDP方式发送数据 *** =sen getBytes()pac=new DatagramPacket( *** *** length InetAddress getByName( localhost ) )cli send(pac)}catch(SocketException se){se printStackTrace()}catch(IOException ie){ie printStackTrace()}}public static void main(String args[]){new uclient()}}接收端数据:import java io *import java lang *import *public class userve{private DatagramSocket serprivate DatagramPacket pacprivate byte rb[]private String revpublic userve(){Init()}public void Init()罩庆{try{ser=new DatagramSocket( )rb=new byte[ ]pac=new DatagramPacket(rb rb length)rev= int i= while(i== )//无数据 则循环{ser receive(pac)i=pac getLength()//接收数据if(i>){//指定接收到数据的长度 可使接收数据正常显示 开始时很容易忽略这一点rev=new String(rb pac getLength())System out println(rev)i= //循环接收}}}catch(Exception e){e printStackTrace()}}public static void main(String args[]){new userve()}} lishixinzhi/Article/program/Java/hx/201311/26023

首先声明下，手皮下面的答案是从博客上粘过来了，因为以前自己写的时候也参考这个写的。

基于UDP的聊天程序服务器端源程序：

#include "winsock2.h"

#include "stdio.h"

void main()

{

//加载套接字（winsock）库，加载这段代码拷贝于MSDN中WSAStartup的介绍

WORD wVersionRequested

WSADATA wsaData

int err

wVersionRequested = MAKEWORD( 1, 1 )//版本号为1.1

err = WSAStartup( wVersionRequested, &wsaData )

if ( err != 0 ) {

return

}

if ( LOBYTE( wsaData.wVersion ) != 1 ||

HIBYTE( wsaData.wVersion ) != 1 ) {

WSACleanup( )

return

}

//创建套接字

//注意第二个参数和TCP设置不同

SOCKET sockServer=socket(AF_INET,SOCK_DGRAM,0)

SOCKADDR_IN addrServer//设置服务器芦链端套接字的地址结构的相关属性

addrServer.sin_addr.S_un.S_addr=htonl(INADDR_ANY)//设置IP

addrServer.sin_family=AF_INET

addrServer.sin_port=htons(6000)//设置端口号

//将套接字和服务器地址结构绑定

bind(sockServer,(SOCKADDR*)&addrServer,sizeof(SOCKADDR))

SOCKADDR_IN addrClient

int len=sizeof(SOCKADDR)

char recvBuf[100]

char tempBuf[100]

char sendBuf[100]

while(1)

{

//从客户陪薯孙端接收数据

int result=recvfrom(sockServer,recvBuf,100,0,(SOCKADDR*)&addrClient,&len)

if(result==SOCKET_ERROR)

{

int errCode=WSAGetLastError()

printf("error:%d",errCode)

break//退出循环

}

else

{

if(recvBuf[0]=='q') //对方请求退出

{

//同样将退出请求发送回去

sendto(sockServer,"q",strlen("q")+1,0,(SOCKADDR*)&addrClient,sizeof(SOCKADDR))

printf("the chat end!")

break

}

else

{

//将对方发送过来的信息前段加上IP地址进行输出

sprintf(tempBuf,"%s said:%s",inet_ntoa(addrClient.sin_addr),recvBuf)

printf("%s\n",tempBuf)

//将用户的键盘输入发送到对方

printf("pleas input the message:\n")

gets(sendBuf)//得到键盘输入内容 sendto(sockServer,sendBuf,strlen(sendBuf)+1,0,(SOCKADDR*)&addrClient,sizeof(SOCKADDR))

}

}

}

closesocket(sockServer)

WSACleanup()

}

基于UDP的聊天程序客户端端源程序：

#include "winsock2.h"

#include "stdio.h"

void main()

{

//加载套接字（winsock）库，加载这段代码拷贝于MSDN中WSAStartup的介绍

WORD wVersionRequested

WSADATA wsaData

int err

wVersionRequested = MAKEWORD( 1, 1 )//版本号为1.1

err = WSAStartup( wVersionRequested, &wsaData )

if ( err != 0 ) {

return

}

if ( LOBYTE( wsaData.wVersion ) != 1 ||

HIBYTE( wsaData.wVersion ) != 1 ) {

WSACleanup( )

return

}

//创建套接字

SOCKET sockClient=socket(AF_INET,SOCK_DGRAM,0)//注意第二个参数和TCP设置不同

SOCKADDR_IN addrServer//服务器地址结构

addrServer.sin_addr.S_un.S_addr=inet_addr("127.0.0.1")//服务器地址

addrServer.sin_family=AF_INET

addrServer.sin_port=htons(6000)//服务器端口号

char tempBuf[100]

char recvBuf[100]

char sendBuf[100]

int len=sizeof(SOCKADDR)

while(1)

{

printf("plese input the message:\n")

gets(sendBuf)//得到用户的键盘输入

sendto(sockClient,sendBuf,strlen(sendBuf)+1,0,(SOCKADDR*)&addrServer,sizeof(SOCKADDR))

int result=recvfrom(sockClient,recvBuf,100,0,(SOCKADDR*)&addrServer,&len)

if(result==SOCKET_ERROR)

{

int errCode=WSAGetLastError()

printf("error:%d",errCode)

break//退出循环

}

else

{

if(recvBuf[0]=='q') //对方请求退出

{

//同样将退出请求发送回去

sendto(sockClient,"q",strlen("q")+1,0,(SOCKADDR*)&addrServer,sizeof(SOCKADDR))

printf("the chat end!")

break

}

else

{

//将对方发送过来的信息前段加上IP地址进行输出

sprintf(tempBuf,"%s said:%s",inet_ntoa(addrServer.sin_addr),recvBuf)

printf("%s\n",tempBuf)

}

}

}

closesocket(sockClient)

WSACleanup()

}

---