边看视频边练习 写了个程序 可是有点小问题

1. 
   
2. 
   
3. import java.io.BufferedReader;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. import java.util.Scanner;
   
8. import java.util.concurrent.Executors;
   
9. 
   
10. import javax.sound.midi.Receiver;
    
11. 
    
12. public class Send {
    
13. 
    
14. /*
    
15. 通过udp通信 将一段数据发送出去
    
16. 1.建立 udp socket 服务
    
17. 2.提供数据 数据封装到 包
    
18. 3.发送
    
19. 4.关闭
    
20. */
    
21. 
    
22. public static void main(String[] args)throws Exception {
    
23. 
    
24. Executors.newSingleThreadExecutor().execute(new Runnable() {
    
25. public void run() {
    
26. try {
    
27. receice();
    
28. } catch (Exception e) {
    
29. // TODO Auto-generated catch block
    
30. e.printStackTrace();
    
31. }
    
32. };
    
33. });
    
34. 
    
35. Thread.sleep(1000);
    
36. Executors.newSingleThreadExecutor().execute(new Runnable() {
    
37. public void run() {
    
38. try {
    
39. send();
    
40. } catch (Exception e) {
    
41. // TODO Auto-generated catch block
    
42. e.printStackTrace();
    
43. }
    
44. };
    
45. });
    
46. 
    
47. }
    
48. 
    
49. 
    
50. static void send() throws Exception{
    
51. //建立 udp 服务 可以指定端口 送 不指定 则随机使用端口 发送数据
    
52. DatagramSocket ds =new DatagramSocket();
    
53. //确定数据 封装成包 DatagramPacket(字节数组, 要发送的长度,发送的ip,目标端口)
    
54. Scanner sc = new Scanner(System.in);
    
55. String str="";
    
56. for(;;){
    
57. System.out.print("请输入：");
    
58. str = sc.nextLine();
    
59. byte[] buf =str.getBytes();
    
60. DatagramPacket dp = new DatagramPacket(buf, buf.length,InetAddress.getLocalHost(),2255);
    
61. //发送数据
    
62. ds.send(dp);
    
63. }
    
64. 
    
65. }
    
66. 
    
67. 
    
68. static void receice() throws Exception{
    
69. //创建upd socket 服务 应该指定端口 则 该socket 将在此端口接受数据
    
70. DatagramSocket ds = new DatagramSocket(2255);
    
71. for(;;){
    
72. byte[] buf = new byte[1024];
    
73. DatagramPacket dp =new DatagramPacket(buf, buf.length);
    
74. ds.receive(dp);//接受数据包
    
75. String ip = dp.getAddress().getHostAddress();
    
76. String msg = new String(dp.getData(),0,dp.getLength());// 获取接受的信息
    
77. int port = dp.getPort();
    
78. 
    
79. System.out.println(ip+":"+port+"---->"+msg);
    
80. }
    
81. 
    
82. }
    
83. }
    

复制代码

程序有一个发送 方法 一个接受方法， 在main方法先用一个线程开启接受 ，间隔1s 后用另一个线程开启发送。
但是为什么第一次发送的数据总是接受不到呢？

边看视频边练习 写了个程序 可是有点小问题

1. 
   
2. 
   
3. import java.io.BufferedReader;
   
4. import java.net.DatagramPacket;
   
5. import java.net.DatagramSocket;
   
6. import java.net.InetAddress;
   
7. import java.util.Scanner;
   
8. import java.util.concurrent.Executors;
   
9. 
   
10. import javax.sound.midi.Receiver;
    
11. 
    
12. public class Send {
    
13. 
    
14. /*
    
15. 通过udp通信 将一段数据发送出去
    
16. 1.建立 udp socket 服务
    
17. 2.提供数据 数据封装到 包
    
18. 3.发送
    
19. 4.关闭
    
20. */
    
21. 
    
22. public static void main(String[] args)throws Exception {
    
23. 
    
24. Executors.newSingleThreadExecutor().execute(new Runnable() {
    
25. public void run() {
    
26. try {
    
27. receice();
    
28. } catch (Exception e) {
    
29. // TODO Auto-generated catch block
    
30. e.printStackTrace();
    
31. }
    
32. };
    
33. });
    
34. 
    
35. Thread.sleep(1000);
    
36. Executors.newSingleThreadExecutor().execute(new Runnable() {
    
37. public void run() {
    
38. try {
    
39. send();
    
40. } catch (Exception e) {
    
41. // TODO Auto-generated catch block
    
42. e.printStackTrace();
    
43. }
    
44. };
    
45. });
    
46. 
    
47. }
    
48. 
    
49. 
    
50. static void send() throws Exception{
    
51. //建立 udp 服务 可以指定端口 送 不指定 则随机使用端口 发送数据
    
52. DatagramSocket ds =new DatagramSocket();
    
53. //确定数据 封装成包 DatagramPacket(字节数组, 要发送的长度,发送的ip,目标端口)
    
54. Scanner sc = new Scanner(System.in);
    
55. String str="";
    
56. for(;;){
    
57. System.out.print("请输入：");
    
58. str = sc.nextLine();
    
59. byte[] buf =str.getBytes();
    
60. DatagramPacket dp = new DatagramPacket(buf, buf.length,InetAddress.getLocalHost(),2255);
    
61. //发送数据
    
62. ds.send(dp);
    
63. }
    
64. 
    
65. }
    
66. 
    
67. 
    
68. static void receice() throws Exception{
    
69. //创建upd socket 服务 应该指定端口 则 该socket 将在此端口接受数据
    
70. DatagramSocket ds = new DatagramSocket(2255);
    
71. for(;;){
    
72. byte[] buf = new byte[1024];
    
73. DatagramPacket dp =new DatagramPacket(buf, buf.length);
    
74. ds.receive(dp);//接受数据包
    
75. String ip = dp.getAddress().getHostAddress();
    
76. String msg = new String(dp.getData(),0,dp.getLength());// 获取接受的信息
    
77. int port = dp.getPort();
    
78. 
    
79. System.out.println(ip+":"+port+"---->"+msg);
    
80. }
    
81. 
    
82. }
    
83. }
    

复制代码

程序有一个发送 方法 一个接受方法， 在main方法先用一个线程开启接受 ，间隔1s 后用另一个线程开启发送。
但是为什么第一次发送的数据总是接受不到呢？