Java UDP编程问题

sagittariu

最近在学Java网络通讯，做毕业设计，我想使用UDP协议，今天写了一个C/S通讯，但服务器收不到发送出去的数据。
程序如下，Server端：

1. 
   
2. import java.net.DatagramSocket;
   
3. import java.net.SocketException;
   
4. import java.nio.channels.DatagramChannel;
   
5. import java.net.*;
   
6. import java.io.*;
   
7. import java.nio.*;
   
8. public class STest {
   
9.         public static void main(String args[]){
   
10.                 new Server();
    
11.         }
    
12. }
    
13. 
    
14. class Server{
    
15.         private DatagramChannel channel;
    
16.         DatagramSocket socket;
    
17.         public Server(){
    
18.                 try{
    
19.                         channel=DatagramChannel.open();
    
20.                         socket=channel.socket();
    
21.                         socket.bind(new InetSocketAddress(5569));
    
22.                         SThread s=new SThread(channel);
    
23.                         s.start();
    
24.                 }catch(SocketException e){
    
25.                         e.printStackTrace();
    
26.                 }catch(IOException e){
    
27.                         e.printStackTrace();
    
28.                 }
    
29.         }
    
30. }
    
31. 
    
32. class SThread extends Thread{
    
33.         private DatagramChannel socket;
    
34.         public SThread(DatagramChannel socket){
    
35.                 this.socket=socket;
    
36.         }
    
37.         public void run(){
    
38.                 ByteBuffer buf=ByteBuffer.allocate(3000);
    
39.                 while(true){
    
40.                         buf.clear();
    
41.                         try{
    
42.                                 socket.receive(buf);
    
43.                                 if(buf.limit()==0){
    
44.                                         System.out.println("Empty buf");
    
45.                                         continue;
    
46.                                 }
    
47.                                 buf.flip();
    
48.                                 System.out.println(buf.getInt());
    
49.                         }catch(IOException e){
    
50.                                 e.printStackTrace();
    
51.                         }
    
52.                 }
    
53.         }
    
54. }
    

复制代码

Client端

1. 
   
2. import java.net.*;
   
3. import java.nio.*;
   
4. import java.nio.channels.DatagramChannel;
   
5. import java.io.*;
   
6. public class CTest {
   
7.         public static void main(String args[]){
   
8.                         try{
   
9.                 new Client().start();
   
10.                 Thread.sleep(1000);
    
11.                         }catch(InterruptedException e){
    
12.                                
    
13.                         }
    
14.         }
    
15. 
    
16. }
    
17. 
    
18. class Client extends Thread{
    
19.         public Client(){
    
20.         }
    
21.         public void run(){
    
22.                 while(true){
    
23.                 ByteBuffer buf=ByteBuffer.allocate(3000);
    
24.                 buf.flip();
    
25.                 try{
    
26.                         DatagramChannel dc=DatagramChannel.open();
    
27.                         InetSocketAddress ad=new InetSocketAddress("localhost",5569);
    
28.                         dc.connect(ad);
    
29.                         dc.socket().setSoTimeout(1000);
    
30.                         buf.putInt(33559900);
    
31.                         int out=dc.write(buf);
    
32.                         this.sleep(1000);
    
33.                 }catch(IOException e){
    
34.                         e.printStackTrace();
    
35.                 }catch(InterruptedException e){
    
36.                         e.printStackTrace();
    
37.                 }
    
38.                 }
    
39.         }
    
40. }
    

复制代码

当客户端发送数据后，服务器端收到的总是空的ByteBuffer
谁能给我一个有关DatagramChannel的服务器端和客户端的正确的例子？
还有一问，为什么linuxsir越来越慢了。。。。。:ask

yuezu1026

我试了你的代码，好像不能用哦。我用的jdk1.4

cqw22

你的Client类代码有问题!
改成
buf.putInt(33559900);
buf.flip();
int out=dc.write(buf);
buf.clear();