How to ping remote mysql using golang

huangapple
go评论132阅读模式
英文:

How to ping remote mysql using golang

问题

我正在使用go来ping一些Linux机器。
但是它的工作不准确，因为它总是需要近10秒钟才能连接到远程的mysql。

我使用的命令是：

mysql -u USER -p PASSWORD -h REMOTE_IP

所以我想知道如何使用Linux命令来判断它是否打开。

然后我将使用golang的exec.Command来执行这个命令。

这是我的ping代码：

  1. package main
  3. import (
  4.     "errors"
  5.     "fmt"
  6.     "github.com/tatsushid/go-fastping"
  7.     "net"
  8.     "net/smtp"
  9.     "strings"
  10.     "time"
  11. )
  13. func main(){
  14.     err := ping("192.168.2.1")
  15.     if err != nil{
  16.         fmt.Println("WARNING!!!!!!")
  17.     }
  18. }
  19. func ping(ip string) error {
  20.     p := fastping.NewPinger()
  21.     ra, err := net.ResolveIPAddr("ip", ip)
  22.     if err != nil {
  23.         return err
  24.     }
  25.     p.AddIPAddr(ra)
  26.     found := false
  27.     p.OnRecv = func(addr *net.IPAddr, rtt time.Duration) {
  28.         found = true
  29.     }
  30.     err = p.Run()
  31.     if err != nil {
  32.         return err
  33.     }
  34.     if !found {
  35.         return errors.New("response error")
  36.     }
  37.     return nil
  38. }
英文:

I am using go to ping some Linux machines.
But it is not work accurate, because it always needs almost 10 seconds to connect the remote mysql.

I use this command:

> mysql -u USER -p PASSWORD -h REMOTE_IP

So i want to know how to use linux command to know whether it open or not.

Then I will use golang 's exec.Command to do that .

Here is my ping code:

  1. package main
  3. import (
  4.     "errors"
  5.     "fmt"
  6.     "github.com/tatsushid/go-fastping"
  7.     "net"
  8.     "net/smtp"
  9.     "strings"
  10.     "time"
  11. )
  13. func main(){
  14.     err := ping("192.168.2.1")
  15.     if err != nil{
  16.         fmt.Println("WARNING!!!!!!")
  17.     }
  18. }
  19. func ping(ip string) error {
  20.     p := fastping.NewPinger()
  21.     ra, err := net.ResolveIPAddr("ip", ip)
  22.     if err != nil {
  23.         return err
  24.     }
  25.     p.AddIPAddr(ra)
  26.     found := false
  27.     p.OnRecv = func(addr *net.IPAddr, rtt time.Duration) {
  28.         found = true
  29.     }
  30.     err = p.Run()
  31.     if err != nil {
  32.         return err
  33.     }
  34.     if !found {
  35.         return errors.New("response error")
  36.     }
  37.     return nil
  38. }

答案1

得分: 4

我假设你想知道mysql是否可达。你可以使用以下示例代码：

  1. package main
  3. import (
  4. 	"database/sql"
  5. 	"flag"
  6. 	"fmt"
  7. 	"log"
  9. 	_ "github.com/go-sql-driver/mysql"
  10. )
  12. func main() {
  13. 	var (
  14. 		server = flag.String("mysql", "localhost:3306", "mysql服务器")
  15. 		user   = flag.String("user", "root", "mysql用户")
  16. 		pass   = flag.String("password", "", "mysql密码")
  17. 	)
  18. 	flag.Parse()
  20. 	db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s)/", *user, *pass, *server))
  21. 	if err != nil {
  22. 		log.Fatalln(err)
  23. 	}
  24. 	defer db.Close()
  26. 	err = db.Ping()
  28. 	if err != nil {
  29. 		log.Fatalln(err)
  30. 	} else {
  31. 		log.Println("mysqld is alive")
  32. 	}
  33. }

这段代码用于检查mysql是否可达。你可以根据需要修改服务器地址、用户名和密码。

英文:

I assume you want to know if mysql is reachable or not. You can use following example:

  1. package main
  3. import (
  4. 	"database/sql"
  5. 	"flag"
  6. 	"fmt"
  7. 	"log"
  9. 	_ "github.com/go-sql-driver/mysql"
  10. )
  12. func main() {
  13. 	var (
  14. 		server = flag.String("mysql", "localhost:3306", "mysql server")
  15. 		user   = flag.String("user", "root", "mysql user")
  16. 		pass   = flag.String("password", "", "mysql password")
  17. 	)
  18. 	flag.Parse()
  20. 	db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s)/", *user, *pass, *server))
  21. 	if err != nil {
  22. 		log.Fatalln(err)
  24. 	}
  25. 	defer db.Close()
  27. 	err = db.Ping()
  29. 	if err != nil {
  30. 		log.Fatalln(err)
  32. 	} else {
  33. 		log.Println("mysqld is alive")
  35. 	}
  37. }

答案2

得分: 2

如果你只需要检查与特定主机和端口的连接，你可以这样做：

  1. package main
  3. import (
  4. 	"fmt"
  5. 	"net"
  6. )
  8. const (
  9. 	host = "192.168.2.1"
  10. 	port = "3306" // 默认的MySQL端口
  11. )
  13. func main() {
  15. 	conn, err := net.Dial("tcp", host+":"+port)
  16. 	if err != nil {
  17. 		panic(err)
  18. 	}
  19. 	defer conn.Close()
  21. 	fmt.Printf("已连接到 %s \n", conn.RemoteAddr().String())
  22. }

希望对你有帮助！

英文:

If you just need to check connection to a specific host & port, you can do this as:

  1. package main
  3. import (
  4. 	"fmt"
  5. 	"net"
  6. )
  8. const (
  9. 	host = "192.168.2.1"
  10. 	port = "3306" // default MySQL port
  11. )
  13. func main() {
  15. 	conn, err := net.Dial("tcp", host+":"+port)
  16. 	if err != nil {
  17. 		panic(err)
  18. 	}
  19. 	defer conn.Close()
  21. 	fmt.Printf("Connected to %s \n", conn.RemoteAddr().String())
  22. }

huangapple
  • 本文由 发表于 2016年12月9日 13:43:37
  • 转载请务必保留本文链接：https://go.coder-hub.com/41053830.html
  • go
  • linux
  • mysql
匿名

发表评论

匿名网友

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

确定