udp通信java代码,udp通信程序

java程序怎么实现UDP多线程通信 用split方法分不开两段啊 以下程序有错的地方希望纠错 谢谢！！

a=new byte[8192];

创新互联专注于喀什企业网站建设,响应式网站,商城网站建设。喀什网站建设公司,为喀什等地区提供建站服务。全流程按需定制，专业设计，全程项目跟踪，创新互联专业和态度为您提供的服务

a="没有该用户".getBytes();

首先这句的写法就有大问题了……

你把a先指向了一个8192长度的byte数组 然后马上又把a指向xxxx.getBytes()，也就是说第一句没有任何用处

然后你具体的代码 我已经不知道你想做什么了~~~如果你只是想用DatagrameSocket来实现数据传输其实很简单的……可以参见orelly的《java网络编程》里面的例子 我就不贴了

然后把例子改成多线程的就行了……

一个简单java实现udp通信

UDP也可以和TCP那样遍历list然后发送啊

客户端向外面开一个UDP端口接受数据报

然后服务器这边要是有消息要发送就直接发送数据报包就可以了嘛

UDP都不用保持着连接的，比TCP还简单些

另外也可以用组播来实现，搜索下java UDP 组播，你能找到不少实例性的代码，也有聊天室的代码

java 中怎么使用UDP？

发送步骤：

使用 DatagramSocket(int port) 建立socket（套间字）服务。

将数据打包到DatagramPacket中去

通过socket服务发送 （send()方法）

关闭资源

import java.io.IOException;  

import java.net.*;  

public class Send {  

public static void main(String[] args)  {  

DatagramSocket ds = null;  //建立套间字udpsocket服务  

try {  

ds = new DatagramSocket(8999);  //实例化套间字，指定自己的port  

} catch (SocketException e) {  

System.out.println("Cannot open port!");  

System.exit(1);   

}  

byte[] buf= "Hello, I am sender!".getBytes();  //数据  

InetAddress destination = null ;  

try {  

destination = InetAddress.getByName("192.168.1.5");  //需要发送的地址  

} catch (UnknownHostException e) {  

System.out.println("Cannot open findhost!");  

System.exit(1);   

}  

DatagramPacket dp =   

new DatagramPacket(buf, buf.length, destination , 10000);    

//打包到DatagramPacket类型中（DatagramSocket的send()方法接受此类，注意10000是接受地址的端口，不同于自己的端口！）  

try {  

ds.send(dp);  //发送数据  

} catch (IOException e) {  

}  

ds.close();  

}  

}

接收步骤：

使用 DatagramSocket(int port) 建立socket（套间字）服务。（我们注意到此服务即可以接收，又可以发送），port指定监视接受端口。

定义一个数据包（DatagramPacket），储存接收到的数据，使用其中的方法提取传送的内容

通过DatagramSocket 的receive方法将接受到的数据存入上面定义的包中

使用DatagramPacket的方法，提取数据。

关闭资源。

import java.net.*;  

public class Rec {  

public static void main(String[] args) throws Exception {  

DatagramSocket ds = new DatagramSocket(10000);  //定义服务，监视端口上面的发送端口，注意不是send本身端口  

byte[] buf = new byte[1024];//接受内容的大小，注意不要溢出  

DatagramPacket dp = new DatagramPacket(buf,0,buf.length);//定义一个接收的包  

ds.receive(dp);//将接受内容封装到包中  

String data = new String(dp.getData(), 0, dp.getLength());//利用getData()方法取出内容  

System.out.println(data);//打印内容  

ds.close();//关闭资源     

}  

}

java 实现 UDP连接的源程序

import java.io.*;

import java.lang.*;

import java.net.*;

public class uclient

{

private DatagramSocket cli;

private DatagramPacket pac;

private byte sb[];

private String sen;

public uclient()

{

Init();

}

public void Init()

{

try

{

//指定端口号，避免与其他应用程序发生冲突

cli=new DatagramSocket(10002);

sb=new byte[1024];

sen="UDP方式发送数据";

sb=sen.getBytes();

pac=new DatagramPacket(sb,sb.length,InetAddress.getByName("localhost"),10005);

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 java.net.*;

public class userve

{

private DatagramSocket ser;

private DatagramPacket pac;

private byte rb[];

private String rev;

public userve()

{

Init();

}

public void Init()

{

try

{

ser=new DatagramSocket(10005);

rb=new byte[1024];

pac=new DatagramPacket(rb,rb.length);

rev="";

int i=0;

while(i==0)//无数据，则循环

{

ser.receive(pac);

i=pac.getLength();

//接收数据

if(i0)

{

//指定接收到数据的长度,可使接收数据正常显示,开始时很容易忽略这一点

rev=new String(rb,0,pac.getLength());

System.out.println(rev);

i=0;//循环接收

}

}

}

catch(Exception e)

{

e.printStackTrace();

}

}

public static void main(String args[])

{

new userve();

}

}

Java写的一个udp的demo用来计算探针传送过来的数据，怎么实现一个接口来调用这个数据

Java UDP通信简单实现

1、Java实现方式

1）server端

/**

* UDPserver端

* */

public class UdpServer {

// 定义一些常量

private final intMAX_LENGTH = 1024; // 最大接收字节长度

private final intPORT_NUM   = 5066;   // port号

// 用以存放接收数据的字节数组

private byte[] receMsgs = new byte[MAX_LENGTH];

// 数据报套接字

private DatagramSocket datagramSocket;

// 用以接收数据报

private DatagramPacket datagramPacket;

public UdpServer(){

try {

/******* 接收数据流程**/

// 创建一个数据报套接字，并将其绑定到指定port上

datagramSocket = new DatagramSocket(PORT_NUM);

// DatagramPacket(byte buf[], int length),建立一个字节数组来接收UDP包

datagramPacket = new DatagramPacket(receMsgs, receMsgs.length);

// receive()来等待接收UDP数据报

datagramSocket.receive(datagramPacket);

/****** 解析数据报****/

String receStr = new String(datagramPacket.getData(), 0 , datagramPacket.getLength());

System.out.println("Server Rece:" + receStr);

System.out.println("Server Port:" + datagramPacket.getPort());

/***** 返回ACK消息数据报*/

// 组装数据报

byte[] buf = "I receive the message".getBytes();

DatagramPacket sendPacket = new DatagramPacket(buf, buf.length, datagramPacket.getAddress(), datagramPacket.getPort());

// 发送消息

datagramSocket.send(sendPacket);

} catch (SocketException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

// 关闭socket

if (datagramSocket != null) {

datagramSocket.close();

}

}

}

}

2）client

/***

* UDPclientClient端

***/

public class UdpClient {

private String sendStr = "SendString";

private String netAddress = "127.0.0.1";

private final intPORT_NUM = 5066;

private DatagramSocket datagramSocket;

private DatagramPacket datagramPacket;

public UdpClient(){

try {

/*** 发送数据***/

// 初始化datagramSocket,注意与前面Server端实现的差别

datagramSocket = new DatagramSocket();

// 使用DatagramPacket(byte buf[], int length, InetAddress address, int port)函数组装发送UDP数据报

byte[] buf = sendStr.getBytes();

InetAddress address = InetAddress.getByName(netAddress);

datagramPacket = new DatagramPacket(buf, buf.length, address, PORT_NUM);

// 发送数据

datagramSocket.send(datagramPacket);

/*** 接收数据***/

byte[] receBuf = new byte[1024];

DatagramPacket recePacket = new DatagramPacket(receBuf, receBuf.length);

datagramSocket.receive(recePacket);

String receStr = new String(recePacket.getData(), 0 , recePacket.getLength());

System.out.println("Client Rece Ack:" + receStr);

System.out.println(recePacket.getPort());

} catch (SocketException e) {

e.printStackTrace();

} catch (UnknownHostException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} finally {

// 关闭socket

if(datagramSocket != null){

datagramSocket.close();

}

}

}  

}