[练习]go版的并发ping

laputa73

在<Go语言编程>中有icmp ping的例子,不过实际测试不通过....这个有空研究一下源码再看.

--补充,原文代码未考虑ipv4的包头长度
_, err = conn.Read(msg[0:])  改为
_, err = conn.Read(msg[20:])


在网找到了一个可用的模块,还可以支持ipv6.

http://golangtc.com/t/526e1f8b320b522433000003

https://github.com/paulstuart/ping/blob/master/ping.go

利用协程实现并发ping测试

1. /*gorouting版本的并行ping */
   
2. 
   
3. package main
   
4. import (
   
5. "ping"
   
6. "fmt"
   
7. "time"
   
8. //"os"
   
9. "strconv"
   
10. )
    
11. 
    
12. var fin chan string; //用于实现joinall
    
13. 
    
14. //go没有pop/shift操作,只能自己计数
    
15. var cur int
    
16. 
    
17. 
    
18. /*定义协程
    
19. ping单个目标
    
20. 输入:目标ip/域名
    
21. 输出:结果, 时延
    
22. */
    
23. func doit(){
    
24.         if cur >= len(iplist){
    
25.                 return
    
26.         }
    
27.         ip:=iplist[cur]
    
28.         cur++
    
29.         go pingr(ip,1000)
    
30. }
    
31. 
    
32. 
    
33. func pingr(host string,timeout int){
    
34.         t1:=time.Now().UnixNano()
    
35.         alive,err:=ping.Ping(host,timeout)
    
36.         //alive,err:=true,0
    
37.         t2:=time.Now().UnixNano()
    
38.         fmt.Println(host,alive,(t2-t1)/1000000,err);
    
39.         fin <- host
    
40.         doit()
    
41. }
    
42. 
    
43. 
    
44. //定义iplist
    
45. var iplist [253]string
    
46. 
    
47. func main() {
    
48. 
    
49. //创建队列
    
50. fin = make(chan string)
    
51. 
    
52. 
    
53.   //数组赋值
    
54. for i := 0; i < len(iplist); i++ {
    
55.                 iplist[i]="192.168.99."+strconv.Itoa(i+1)
    
56.                
    
57. }       
    
58. 
    
59. 
    
60. //控制并发
    
61. cocurrent := 100
    
62. cur =0
    
63. for j := 0; j < cocurrent; j++ {
    
64.         doit()
    
65. }
    
66. 
    
67. 
    
68. 
    
69. //等待结束
    
70. for i := 0; i < len(iplist); i++ {
    
71.                
    
72.                   <-fin
    
73.            //fmt.Println(ip,"joined")
    
74. }
    
75. 
    
76. }

复制代码

__b1ueguy__

看看这是难点