[練習(xí)]go版的并發(fā)ping

laputa73

在<Go語(yǔ)言編程>中有icmp ping的例子,不過(guò)實(shí)際測(cè)試不通過(guò)....這個(gè)有空研究一下源碼再看.

--補(bǔ)充,原文代碼未考慮ipv4的包頭長(zhǎng)度
_, err = conn.Read(msg[0:])  改為
_, err = conn.Read(msg[20:])


在網(wǎng)找到了一個(gè)可用的模塊,還可以支持ipv6.

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

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

利用協(xié)程實(shí)現(xiàn)并發(fā)ping測(cè)試

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; //用于實(shí)現(xiàn)joinall
    
13. 
    
14. //go沒(méi)有pop/shift操作,只能自己計(jì)數(shù)
    
15. var cur int
    
16. 
    
17. 
    
18. /*定義協(xié)程
    
19. ping單個(gè)目標(biāo)
    
20. 輸入:目標(biāo)ip/域名
    
21. 輸出:結(jié)果, 時(shí)延
    
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. //創(chuàng)建隊(duì)列
    
50. fin = make(chan string)
    
51. 
    
52. 
    
53.   //數(shù)組賦值
    
54. for i := 0; i < len(iplist); i++ {
    
55.                 iplist[i]="192.168.99."+strconv.Itoa(i+1)
    
56.                
    
57. }       
    
58. 
    
59. 
    
60. //控制并發(fā)
    
61. cocurrent := 100
    
62. cur =0
    
63. for j := 0; j < cocurrent; j++ {
    
64.         doit()
    
65. }
    
66. 
    
67. 
    
68. 
    
69. //等待結(jié)束
    
70. for i := 0; i < len(iplist); i++ {
    
71.                
    
72.                   <-fin
    
73.            //fmt.Println(ip,"joined")
    
74. }
    
75. 
    
76. }

復(fù)制代碼

__b1ueguy__

看看這是難點(diǎn)