1. import java.io.BufferedInputStream;
   
2. import java.io.BufferedReader;
   
3. import java.io.InputStreamReader;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. import java.text.SimpleDateFormat;
   
8. import java.util.Date;
   
9. import java.util.concurrent.Executors;
   
10. 
    
11. 
    
12. public class Demo
    
13. {
    
14.         public static void main(String[] args)
    
15.         {                                                                    
    
16.                 Executors.newSingleThreadExecutor().execute(new Sender());
    
17.                 Executors.newSingleThreadExecutor().execute(new Receiver());
    
18.                
    
19.         }
    
20. }
    
21. 
    
22. 
    
23. //此类用于向某个  ip 的某个端口发送信息
    
24. class Sender implements Runnable{
    
25.         int port = 2323;//目标端口
    
26.         String address="127.0.0.1";//目标 IP
    
27.        
    
28.         BufferedReader br;
    
29. 
    
30.         public void run() {
    
31.        
    
32.                 br = new BufferedReader(new InputStreamReader(System.in));
    
33.                 String str;
    
34.                 DatagramSocket socket;
    
35.                 DatagramPacket packet;
    
36.                 try {
    
37.                         socket = new DatagramSocket();
    
38.                         for (;;) {// 不断输入数据 并发送
    
39.                                 System.out.print("请输入：");
    
40.                                 str = br.readLine();
    
41.                                 byte[] buf = (new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + " ---->" + str).getBytes();
    
42.                                 packet = new DatagramPacket(buf, buf.length,InetAddress.getByName(address),port);
    
43.                                 socket.send(packet);
    
44.                                 str="";
    
45. 
    
46.                            }
    
47.                   } catch (Exception e) {
    
48.                System.out.println("发送失败");
    
49.                 }
    
50. 
    
51.         }
    
52. }
    
53. 
    
54. 
    
55. //此类用于 在 固定端口监听  接受信息
    
56. class Receiver implements Runnable{
    
57.      int port = 2323;
    
58.         public void run() {
    
59.        
    
60.                 try{
    
61.                         DatagramSocket socket =new DatagramSocket(port);//该端口应与 sender 发送的端口一致
    
62.                        
    
63.                         for(;;){
    
64.                                 byte[] buf=new byte[1024];
    
65.                                 DatagramPacket packet =new DatagramPacket(buf, buf.length);
    
66.                                 socket.receive(packet);
    
67.                                 String msg = new String(packet.getData());
    
68.                                 System.out.println(msg);
    
69.                         }
    
70.                        
    
71.                 }catch (Exception e) {
    
72.                       System.out.println("启动失败");
    
73.                 }
    
74.         }
    
75. }

复制代码

这是我今天在公司时写的一个小程序。在控制台输入信息发送到一个目标IP的某个端口，然后在端口接受信息并显示。现在的问题是 公司的系统用的是日文的，输入的中文在接受端显示的是乱码。我知道是编码问题，可是应该如何解决呢？ 试了好多方法不能奏效 请高手指点……

我记得在转换流里有个构造方法可以指定编码集，试下看！