家里蹲的狐狸简单的添加账号和密码
server服务端
package main
import (
"fmt"
"io"
"net"
"net/http"
"strings"
"text/template"
)
type Consys struct {
data string
c net.Conn
}
var info string
func index(w http.ResponseWriter, r *http.Request) {
t, _ := template.ParseFiles("index.html") //找模板
t.Execute(w, nil) //执行模板
}
func ajax(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-type", "application/json;charset=utf-8")
fmt.Fprintln(w,info)
}
func main() {
go startserver()//开个协程，要不然会跟http的监听有冲突
http.Handle("/assets/", http.StripPrefix("/assets/", http.FileServer(http.Dir("assets"))))
http.HandleFunc("/", index) //函数也是一种变量
http.HandleFunc("/ajax", ajax) //函数也是一种变量
http.ListenAndServe(":8082", nil)
}
func startserver(){
addr, _ := net.ResolveTCPAddr("tcp4", "localhost:8899")
lis, _ := net.ListenTCP("tcp4", addr)
fmt.Println("服务器已启动")
for {//通过gorountine，每个客户端分配一个独立协程。
conn, _ := lis.Accept()
go handleConn(conn)
}
fmt.Println("服务器结束")
}
func handleConn(conn net.Conn){
defer conn.Close()
b := make([]byte, 256)
count, err := conn.Read(b)//接收第一个传过来的账号和密码
if err != nil && err != io.EOF{//这里判断一下err，如果断开就跳出循环，关闭当前连接
fmt.Println("客户端断开连接")
return
}
arr := strings.Split(string(b[:count]),":")//验证账号和密码
if arr[0] != "abc" || arr[1] != "123" {
fmt.Println("用户名或者密码错误！")
return
}
for{//验证通过了，就一直保持连接接收信息
count, err := conn.Read(b)
if err != nil && err != io.EOF{//这里判断一下err，如果断开就跳出循环，关闭当前连接
fmt.Println("客户端断开连接")
break
}
info = string(b[:count])
}
}client客户端
package main
import (
"encoding/json"
"fmt"
"strconv"
"time"
net2 "net"
"github.com/shirou/gopsutil/cpu"
"github.com/shirou/gopsutil/disk"
"github.com/shirou/gopsutil/mem"
"github.com/shirou/gopsutil/net"
"github.com/shirou/gopsutil/host"
)
type Sys struct {
Cpuused int
Memused int
Memavailable float64
Swaptotal float64
Swapfree float64
Memtotal float64
Disktotal float64
Diskfree float64
Diskused int
Netsend float64
Netrecv float64
Netup string
Netdown string
Uptime int
}
func main(){
//服务器端ip和端口
conn, _ := net2.Dial("tcp", "localhost:8899")
//向服务端发送数据
s:=Sys{}
c := make(chan []byte,2)//设置2个缓存，这样取了一个就会马上放进去一个
go func() {
for{
s = getstatus()
d, _ := json.Marshal(s)
c<-d
}
}()
_,err:=conn.Write([]byte("hqhyco:jiajia111"))//发送账号密码
if err != nil {//如果验证不通过就结束程序
fmt.Println(err.Error())
return
}
for{
_,err:=conn.Write(<-c)
if err != nil {
fmt.Println(err.Error())
break
}
}
////关闭连接
conn.Close()
}
func toG(i uint64) float64 {
return float64(i) / 1024 / 1024 / 1024
}
func toKB(i uint64) float64 {
return float64(i) / 1024
}
func toMB(i uint64) float64 {
return float64(i) / 1024 / 1024
}
func Decimal(value float64) float64 {
value, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", value), 64)
return value
}
func getNetSpeed() (string, string) {
// 读取所有网卡网速
Net, _ := net.IOCounters(true)
// 定义网速保存变量
var rx, tx uint64
// 循环网络信息
for _, nv := range Net {
// 去除多余信息
if "eth0" == nv.Name {
// 加上网速信息
rx += nv.BytesRecv
tx += nv.BytesSent
}
}
// 暂停一秒
time.Sleep(time.Second)
// 重新读取网络信息
Net, _ = net.IOCounters(true)
// 网络信息保存变量
var rx2, tx2 uint64
// 循环网络信息
for _, nv := range Net {
// 去除多余信息
if "eth0" == nv.Name {
// 加上网速信息
rx2 += nv.BytesRecv
tx2 += nv.BytesSent
}
}
// 两次相减
if toKB(rx2-rx) > 1024 || toKB(tx2-tx) > 1024 {
down:= strconv.FormatFloat(toMB(rx2 - rx),'f',2,64)+"MB/S"
up:= strconv.FormatFloat(toMB(tx2 - tx),'f',2,64)+"MB/S"
return down, up
} else {
down:= strconv.FormatFloat(toKB(rx2 - rx),'f',2,64)+"KB/S"
up:= strconv.FormatFloat(toKB(tx2 - tx),'f',2,64)+"KB/S"
return down, up
}
}
func getstatus() Sys {
s := Sys{}
m, _ := mem.VirtualMemory()
c, _ := cpu.Percent(time.Second, false)
d, _ := disk.Usage("/")
n, _ := net.IOCounters(true)
swap,_:=mem.SwapMemory()
s.Netsend = Decimal(toG(n[1].BytesSent))
s.Netrecv = Decimal(toG(n[1].BytesRecv))
s.Diskused = int(d.UsedPercent)
s.Diskfree = Decimal(toG(d.Free))
s.Disktotal = Decimal(toG(d.Total))
s.Memused = int(m.UsedPercent)
s.Memtotal = Decimal(toG(m.Total))
s.Memavailable = Decimal(toG(m.Available))
s.Cpuused = int(c[0])
s.Netdown, s.Netup = getNetSpeed()
s.Uptime = int(getUptime()/60/60/24)
s.Swaptotal=Decimal(toG(swap.Total))
s.Swapfree=Decimal(toG((swap.Free)))
return s
}
func getUptime() uint64 {//获取的是秒数
up, err := host.BootTime()
if nil != err {
return 0
}
return uint64(time.Now().Unix()) - up
}
简单的添加了单一的用户名和密码
