找不到是那里出了错,收不到信息,可是发送成功(UDP聊天程序)
Java codepackage CheviC_UDP;import java.awt.*;import java.awt.event.*;import java.net.*;import java.util.*;public class UDPChat extends Frame{ Label label_myPort = null; TextField textF_myPort = null; Button but_sureMyPort = null; TextArea textA_Chat = null; ScrollPane scrollPane = null; Label label_ip = null; TextField textF_ip = null; Label label_port = null; TextField textF_port = null; Label label_name = null; TextField textF_name = null; TextField textF_send = null; Button butSend = null; DatagramSocket socket = null; AcceptMsg am = null; // 构造函数 public UDPChat() { super("CheviC UDP Chat"); setBounds(400, 400, 600, 350); setLayout(new BorderLayout()); setVisible(true); init(); actionAdd(); acceptMsg(); } // 添加组件 void init() { Panel p1 = new Panel(); p1.setLayout(new FlowLayout(FlowLayout.LEFT)); label_myPort = new Label("set your port here:"); p1.add(label_myPort); textF_myPort = new TextField("5482", 3); p1.add(textF_myPort); but_sureMyPort = new Button("set"); p1.add(but_sureMyPort); label_ip = new Label(" set the connect ip here:"); p1.add(label_ip); textF_ip = new TextField("127.0.0.1",11); p1.add(textF_ip); label_port = new Label("port:"); p1.add(label_port); textF_port = new TextField("5483", 3); p1.add(textF_port); add(p1, BorderLayout.NORTH); textA_Chat = new TextArea(10, 40); scrollPane = new ScrollPane(); scrollPane.add(textA_Chat); add(scrollPane, BorderLayout.CENTER); Panel p = new Panel(); label_name = new Label("name:"); p.add(label_name); textF_name = new TextField("Naruto", 6); p.add(textF_name); textF_send = new TextField(51); p.add(textF_send); butSend = new Button(" Send "); p.add(butSend); add(p, BorderLayout.SOUTH); } // 事件添加 void actionAdd() { // 窗体关闭 addWindowListener(new WindowAdapter() { public void windowClosing(WindowEvent e) { System.exit(0); } }); // 设置端口 but_sureMyPort.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { setMyPort(); } }); // 发送信息 butSend.addActionListener(new ActionListener() { public void actionPerformed(ActionEvent e) { send(); } }); } // 设置本机端口 void setMyPort() { try { int port = Integer.parseInt(textF_myPort.getText()); socket = new DatagramSocket(port); } catch (Exception ex) { textF_myPort.setText("error"); } } // 发送信息 void send() { try { Calendar time = Calendar.getInstance(); String sendMsg = textF_name.getText() + "(" + time.getTime().toString() + "):\r\n" + textF_send.getText() + "\r\n"; byte[] msg = sendMsg.getBytes(); DatagramPacket out = new DatagramPacket(msg, 0, msg.length, InetAddress.getByName(textF_ip.getText().trim()), Integer.parseInt(textF_port.getText())); socket.send(out); showMsg(sendMsg); } catch (Exception ex) { textA_Chat.append(ex.toString()+"\r\n"); } } // 接收消息 void acceptMsg() { am = new AcceptMsg(); am.start(); //原来写错写成了am.run(); } //显示MSG void showMsg(String msg) { textA_Chat.append(msg); } // 接收信息的类 class AcceptMsg extends Thread { byte[] msg = null; AcceptMsg() { msg = new byte[256]; } @Override public void run() { if (socket != null) { while (true) { try { DatagramPacket in = new DatagramPacket(msg, msg.length); socket.receive(in); showMsg(in.getData().toString()); } catch (Exception ex) { // TODO 接收错误时的处理 textA_Chat.append("sorry,there is something wrong."); } } } } } public static void main(String[] args) { new UDPChat(); }}