疯狂Java讲义：使用DatagramSocket发送、接收数据[2]

程序客户端代码也与此类似 客户端采用循环不断地读取用户键盘输入 每当读到用户输入内容后就将该内容封装成DatagramPacket数据报 再将该数据报发送出去 接着把DatagramSocket中的数据读入接收用的DatagramPacket中（实际上是读入该DatagramPacket所封装的字节数组中） 客户端代码如下

成都创新互联自2013年创立以来，是专业互联网技术服务公司，拥有项目网站设计、网站建设网站策划，项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命，1280元任县做网站,已为上家服务,为任县各地企业和个人服务,联系电话:18980820575

程序清单 codes/ / /UdpClient java

public class UdpClient

{

//定义发送数据报的目的地

public static final int DEST_PORT = ;

public static final String DEST_IP = ;

//定义每个数据报的最大大小为 K

private static final int DATA_LEN = ;

//定义该客户端使用的DatagramSocket

private DatagramSocket socket = null;

//定义接收网络数据的字节数组

byte[] inBuff = new byte[DATA_LEN];

//以指定字节数组创建准备接受数据的DatagramPacket对象

private DatagramPacket inPacket =

new DatagramPacket（inBuff inBuff length）

//定义一个用于发送的DatagramPacket对象

private DatagramPacket outPacket = null;

public void init（）throws IOException

{

try

{

//创建一个客户端DatagramSocket 使用随机端口

socket = new DatagramSocket（）

//初始化发送用的DatagramSocket 它包含一个长度为 的字节数组

outPacket = new DatagramPacket（new byte[ ]

InetAddress getByName（DEST_IP） DEST_PORT）

//创建键盘输入流

Scanner scan = new Scanner（System in）

//不断读取键盘输入

while（scan hasNextLine（））

{

//将键盘输入的一行字符串转换字节数组

byte[] buff = scan nextLine（） getBytes（）

//设置发送用的DatagramPacket里的字节数据

outPacket setData（buff）

//发送数据报

socket send（outPacket）

//读取Socket中的数据 读到的数据放在inPacket所封装的字节数组里

socket receive（inPacket）

System out println（new String（inBuff

inPacket getLength（）））

}

}

//使用finally块保证关闭资源

finally

{

if （socket != null）

{

socket close（）

}

}

}

public static void main（String[] args）

throws IOException

{

new UdpClient（） init（）

}

}

上面程序的粗体字代码同样也是通过DatagramSocket发送 接收DatagramPacket的关键代码 这些代码与服务器的代码基本相似 而客户端与服务器端的唯一区别在于 服务器所在IP地址 端口是固定的 所以客户端可以直接将该数据报发送给服务器 而服务器则需要根据接收到的数据报来决定将 反馈 数据报的目的地

读者可能会发现 使用DatagramSocket进行网络通信时 服务器端无须 也无法保存每个客户端的状态 客户端把数据报发送到服务器后 完全有可能立即退出 但不管客户端是否退出 服务器无法知道客户端的状态

当使用UDP协议时 如果想让一个客户端发送的聊天信息可被转发到其他所有客户端则比较困难 可以考虑在服务器使用Set来保存所有客户端信息 每当接收到一个客户端的数据报之后 程序检查该数据报的源SocketAddress是否在Set集合中 如果不在就将该SocketAddress添加到该Set集合中 但这样一来又涉及一个问题 可能有些客户端发送一个数据报之后永久性地退出了程序 但服务器端还将该客户端的SocketAddress保存在Set集合中……总之 这种方式需要处理的问题比较多 编程比较烦琐 幸好Java为UDP协议提供了MulticastSocket类 通过该类可以轻松实现多点广播

返回目录 疯狂Java讲义

编辑推荐

Java程序性能优化 让你的Java程序更快 更稳定

新手学Java 编程

Java程序设计培训视频教程

lishixinzhi/Article/program/Java/hx/201311/27260

java写一个用于接收json数据的接口

java中的接口是一种特殊的类，使用关键字interface创建。接口功能完全实现后，可以打成jar包，提供给其他公司使用。

要返回json格式数据，可以把接口中抽象方法的返回值类型规定为JSONObject或JSONString类型。这样当其他公司调用时，得到的数据就是json数据了。

另外，以jar形式提供的接口，可以通过反编译得到你的源码，如果你不希望开源，就要加密了。

用JAVA写一个SOCKET 接收TCP发来的消息

public class TalkServer{

public static void main(String args[]) {

try{

ServerSocket server=null;

try{

server=new ServerSocket(4700);

//创建一个ServerSocket在端口4700监听客户请求

}catch(Exception e) {

System.out.println("can not listen to:"+e);

//出错，打印出错信息

}

Socket socket=null;

try{

socket=server.accept();

//使用accept()阻塞等待客户请求，有客户

//请求到来则产生一个Socket对象，并继续执行

}catch(Exception e) {

System.out.println("Error."+e);

//出错，打印出错信息

}

String line;

BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));

　//由Socket对象得到输入流，并构造相应的BufferedReader对象

PrintWriter os=newPrintWriter(socket.getOutputStream());

　//由Socket对象得到输出流，并构造PrintWriter对象

BufferedReader sin=new BufferedReader(new InputStreamReader(System.in));

　//由系统标准输入设备构造BufferedReader对象

System.out.println("Client:"+is.readLine());

//在标准输出上打印从客户端读入的字符串

line=sin.readLine();

//从标准输入读入一字符串

while(!line.equals("bye")){

//如果该字符串为 "bye"，则停止循环

os.println(line);

//向客户端输出该字符串

os.flush();

//刷新输出流，使Client马上收到该字符串

System.out.println("Server:"+line);

//在系统标准输出上打印读入的字符串

System.out.println("Client:"+is.readLine());

//从Client读入一字符串，并打印到标准输出上

line=sin.readLine();

//从系统标准输入读入一字符串

} 　//继续循环

os.close(); //关闭Socket输出流

is.close(); //关闭Socket输入流

socket.close(); //关闭Socket

server.close(); //关闭ServerSocket

}catch(Exception e){

System.out.println("Error:"+e);

//出错，打印出错信息

}

}

}

网站标题：java写代码接收数据 java接收报文
当前地址：http://scyanting.com/article/hgjihp.html