PingAndList can ping now but not just list
This commit is contained in:
41
bot/mcbot.go
41
bot/mcbot.go
@ -1,10 +1,8 @@
|
|||||||
package bot
|
package bot
|
||||||
|
|
||||||
import (
|
import (
|
||||||
// "bufio"
|
|
||||||
// "bytes"
|
|
||||||
"fmt"
|
"fmt"
|
||||||
// "net"
|
"time"
|
||||||
|
|
||||||
"github.com/Tnze/go-mc/net"
|
"github.com/Tnze/go-mc/net"
|
||||||
pk "github.com/Tnze/go-mc/net/packet"
|
pk "github.com/Tnze/go-mc/net/packet"
|
||||||
@ -17,10 +15,10 @@ const ProtocalVersion = 477
|
|||||||
// PingAndList chack server status and list online player
|
// PingAndList chack server status and list online player
|
||||||
// Return a JSON string about server status.
|
// Return a JSON string about server status.
|
||||||
// see JSON format at https://wiki.vg/Server_List_Ping#Response
|
// see JSON format at https://wiki.vg/Server_List_Ping#Response
|
||||||
func PingAndList(addr string, port int) (string, error) {
|
func PingAndList(addr string, port int) ([]byte, time.Duration, error) {
|
||||||
conn, err := net.DialMC(fmt.Sprintf("%s:%d", addr, port))
|
conn, err := net.DialMC(fmt.Sprintf("%s:%d", addr, port))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", err
|
return nil, 0, err
|
||||||
}
|
}
|
||||||
|
|
||||||
//握手
|
//握手
|
||||||
@ -34,23 +32,48 @@ func PingAndList(addr string, port int) (string, error) {
|
|||||||
pk.Byte(1),
|
pk.Byte(1),
|
||||||
))
|
))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("bot: send handshake packect fail: %v", err)
|
return nil, 0, fmt.Errorf("bot: send handshake packect fail: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//LIST
|
||||||
//请求服务器状态
|
//请求服务器状态
|
||||||
err = conn.WritePacket(pk.Marshal(0))
|
err = conn.WritePacket(pk.Marshal(0))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("bot: send list packect fail: %v", err)
|
return nil, 0, fmt.Errorf("bot: send list packect fail: %v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
//服务器返回状态
|
//服务器返回状态
|
||||||
recv, err := conn.ReadPacket()
|
recv, err := conn.ReadPacket()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return "", fmt.Errorf("bot: recv list packect fail: %v", err)
|
return nil, 0, fmt.Errorf("bot: recv list packect fail: %v", err)
|
||||||
}
|
}
|
||||||
var s pk.String
|
var s pk.String
|
||||||
err = recv.Scan(&s)
|
err = recv.Scan(&s)
|
||||||
return string(s), err
|
if err != nil {
|
||||||
|
return nil, 0, fmt.Errorf("bot: scan list packect fail: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
//PING
|
||||||
|
now := time.Now()
|
||||||
|
err = conn.WritePacket(pk.Marshal(0x01, pk.Long(now.Unix())))
|
||||||
|
if err != nil {
|
||||||
|
return nil, 0, fmt.Errorf("bot: send ping packect fail: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
recv, err = conn.ReadPacket()
|
||||||
|
if err != nil {
|
||||||
|
return nil, 0, fmt.Errorf("bot: recv pong packect fail: %v", err)
|
||||||
|
}
|
||||||
|
var t pk.Long
|
||||||
|
err = recv.Scan(&t)
|
||||||
|
if err != nil {
|
||||||
|
return nil, 0, fmt.Errorf("bot: scan pong packect fail: %v", err)
|
||||||
|
}
|
||||||
|
if t != pk.Long(now.Unix()) {
|
||||||
|
return nil, 0, fmt.Errorf("bot: pong packect no match: %v", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return []byte(s), time.Now().Sub(now), err
|
||||||
}
|
}
|
||||||
|
|
||||||
// JoinServer connect a Minecraft server for playing the game.
|
// JoinServer connect a Minecraft server for playing the game.
|
||||||
|
@ -6,9 +6,9 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
resp, err := bot.PingAndList("play.miaoscraft.cn", 25565)
|
resp, delay, err := bot.PingAndList("play.miaoscraft.cn", 25565)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("ping and list server fail: %v", err)
|
log.Fatalf("ping and list server fail: %v", err)
|
||||||
}
|
}
|
||||||
log.Println("Status:" + resp)
|
log.Println("Status:"+string(resp), "\nDealy:", delay)
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user