Question

java网络端口循环读取问题？

我有2个程序，都能进行服务端与客服端的通信
服务端用ObjectInputStream流循环读取代码如下
try{
ServerSocket ss=new ServerSocket(9999);
s=ss.accept();
while(true){
ObjectInputStream ois=new ObjectInputStream(s.getInputStream());
Message ms=(Message)ois.readObject();
String time=Calendar.getInstance().getTime().toLocaleString();
wby.append(ms.getSender()+"对"+ms.getGeter()+": "+ms.getXx()+"\t"+time+"\r\n");
}
}
catch(Exception e1){}
客服端用的是ObjectIOutputStream发的
另一个服务端用BuferedReader流循环读取代码如下
try{
ServerSocket ss=new ServerSocket(9999);
s=ss.accept();
InputStreamReader isr=new InputStreamReader(s.getInputStream());
BufferedReader br=new BufferedReader(isr);
while(true){

String s=br.readLine();
System.out.println(s);
}
}
catch(Exception e1){}
这个的客服端用的是PrintWriter发的
我想问为什么一个程序中ObjectInputStream必须放在while里才能时时得到客服端发来的信息；
而用BuferedReader的就不用却能时时得到客服端发来的信息？？
求大神解答

Answer 1

1、UDPRece的DatagramSocket需指定端口。

2、UdpSend的DatagramPacket的目标端口需要和UDPRece的DatagramSocket的端口一致。

import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class UdpRece {
  public static void main(String[] args) throws Exception {
    // 1.创建udp Socket，建立端点
    DatagramSocket ds = new DatagramSocket(20000);
    // 2.定义数据包。用于存储数据。
    byte[] buf = new byte[1024];
    DatagramPacket dp = new DatagramPacket(buf, buf.length);
    // 3.通过服务的receive方法将数到数据存入数据包中
    ds.receive(dp);
    // 4.通过数据包的方法获取其中的数据。
    String ip = dp.getAddress().getHostAddress();
    String data = new String(dp.getData(), 0, dp.getLength());
    int port = dp.getPort();
    System.out.println(ip + "::" + data + "::" + port);
    // 4.关闭资源
    ds.close();
  }
}
   
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
   
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class UdpSend {
  public static void main(String[] args) throws Exception {
    // 1.创建udp服务，通过DatagramSocket对象
    DatagramSocket ds = new DatagramSocket(10000);
    // 2.确定数据，并封装成数据包。
    // DatagramPacket(byte[] buf, int length, InetAddress address, int port)
    // 构造数据报包，用来将长度为 length 的包发送到指定主机上的指定端口号。
    byte[] buf = "udp shu ju lai le".getBytes();
    DatagramPacket dp = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.1.100"),
        20000);
    // 3.通过Socket服务，将已有的数据包发送出去。通过send方法。
    ds.send(dp);
    // 4.关闭资源
    ds.close();
  }
}