golanglibs

This is a toolkit that provide a lot of function or object that make programing easier like Python.

Index

• Tools

  • func LevelDB(datadir string) (l *LevelDB)
    • func (m *LevelDB) Close()
    • func (m *LevelDB) Destroy()
    • func (m *LevelDB) Exists(key string) bool
    • func (m *LevelDB) Get(key string) string
    • func (m *LevelDB) Set(key string, value string)
    • func (m *LevelDB) Delete(key string)
  • func Elasticsearch(baseurl string) *Elasticsearch
    • func (m *Elasticsearch) Collection(name string) *ElasticsearchCollection
      • func (m *ElasticsearchCollection) Index(id interface{}, data map[string]interface{})
      • func (m *ElasticsearchCollection) Search(key string, value string, page int, pagesize int, cfg ...ElasticsearchSearchingConfig) *ElasticsearchSearchedResult
      • func (m *ElasticsearchCollection) Delete(id interface{})
      • func (m *ElasticsearchCollection) Refresh()
    • func(m *Elasticsearch) Delete(collection string)
  • func Lock() *lock
    • func (*lock) Acquire()
    • func (*lock) Release()
  • func RWLock() *RWLock func (m *RWLock) RAcquire() func (m *RWLock) RRelease() func (m *RWLock) WAcquire() func (m *RWLock) WRelease()
  • func AliDNS(string, string) *alidns
    • func (m *alidns) Total() (TotalCount int64)
    • func (m *alidns) List(PageSize int64, PageNumber int64) (res []alidnsDomainInfo)
    • func (m *alidns) Domain(domainName string) *alidnsDomain
      • func (m *alidnsDomain) List() (res []alidnsRecord)
      • func (m *alidnsDomain) Add(recordName string, recordType string, recordValue string) (id string)
      • func (m *alidnsDomain) Delete(name string, dtype string, value string)
      • func (m *alidnsDomain) Modify(recordName string, srcRecordType string, srcRecordValue string, dstRecordName string, dstRecordType string, dstRecordValue string)
  • Chart
    • func LineChartWithTimestampAndNumber([]int64, []float64, string, string, string, string) 以时间为x轴，数据为y轴，做折线图
    • func LineChartWithNumberAndNumber([]float64, []float64, string, string, string, string) 以数据为x和y轴，做折线图
    • func BarChartWithNameAndNumber([]string, []float64, string, string, string) 以名字为x轴，数据为y轴，作柱状图, 注意：数据的数量会决定图片的宽度
    • func PieChartWithNameAndNumber([]string, []float64, string, string) 以x为名字，y的百分比为数据，做饼图
  • func CloudflareDNS(string, string) *cloudflare
    • func (m *cloudflare) Add(domain string) cloudflare.Zone
    • func (m *cloudflare) List() (res []cloudflareDomainInfo)
    • func (m *cloudflare) Domain(domainName string) *cloudflareDomain
      • func (m *cloudflareDomain) List() (res []cloudflareRecord)
      • func (m *cloudflareDomain) Delete(name string)
      • func (m *cloudflareDomain) Add(recordName string, recordType string, recordValue string, proxied ...bool) *cloudflare.DNSRecordResponse
      • func (m *cloudflareDomain) SetProxied(subdomain string, proxied bool)
      • func (m *cloudflareDomain) Update(recordName string, recordType string, recordValue string, proxied ...bool)
  • Compress
    • func LzmaCompressString(string) string
    • func LzmaDecompressString(string) string
    • func ZlibCompressString(string) string
    • func ZlibDecompressString(string) string
  • func Crontab() *crontab 定时任务
    • func (m *crontab) Add(schedule string, fn interface{}, args ...interface{})
    • func (m *crontab) Destory()
  • func GodaddyDNS(string, string) *godaddy
    • func (m *godaddy) List() (res []godaddyDomainInfo)
    • func (m *godaddy) Domain(domainName string) *godaddyDomain
      • func (m *godaddyDomain) List() (res []godaddyRecord)
      • func (m *godaddyDomain) Delete(name string, dtype string, value string)
      • func (m *godaddyDomain) Modify(recordName string, srcRecordType string, srcRecordValue string, dstRecordType string, dstRecordValue string)
      • func (m *godaddyDomain) Add(recordName string, recordType string, recordValue string)
  • func Ini(...string) *ini
    • func (m *ini) Get(SectionKeyDefaultComment ...string) (res string)
    • func (m *ini) GetInt(key ...string) int
    • func (m *ini) GetInt64(key ...string) int64
    • func (m *ini) GetFloat64(key ...string) float64
    • func (m *ini) Set(SectionKeyValueComment ...string)
    • func (m *ini) Save(fpath ...string) (exist bool)
  • func JavascriptVM() *javascriptVM
    • func (m *javascriptVM) Run(javascript string) *javascriptVM
    • func (m *javascriptVM) Get(variableName string) string
    • func (m *javascriptVM) Set(variableName string, variableValue interface{})
    • func (m *javascriptVM) Isdefined(variableName string) bool
  • func Matrix(string) *matrix
    • func (c *matrix) Login(username string, password string) string
    • func (c *matrix) SetToken(userID string, token string) *matrix
    • func (c *matrix) SetRoomID(roomID string) *matrix
    • func (c *matrix) Send(text string)
  • func Nats(string) *nats
    • func (m *nats) Subject(subject string) *subjectNats
      • func (m *subjectNats) Publish(message string)
      • func (m *subjectNats) Subscribe() chan string
      • func (m *subjectNats) Flush()
  • func Totp(string) *totp
    • func (m *totp) Validate(pass string) bool
    • func (m *totp) Password() string
  • func Pexpect(string) *pexpect
    • func (m *pexpect) Sendline(msg string)
    • func (m *pexpect) Close()
    • func (m *pexpect) IsAlive() bool
    • func (m *pexpect) LogToStdout(enable ...bool)
    • func (m *pexpect) ExitCode() int
    • func (m *pexpect) GetLog() string
    • func (m *pexpect) ClearLog()
  • func ProgressBar(string, int64, ...bool) *progressBar
    • func (m *progressBar) Add(num int64)
    • func (m *progressBar) Set(num int64)
    • func (m *progressBar) SetTotal(total int64)
    • func (m *progressBar) Clear()
  • func PrometheusClient(string) *prometheusClient
    • func (m *prometheusClient) Query(query string, time ...float64) (res []prometheusResult)
  • func PrometheusMetricServer(listenAddr string, path ...string) *prometheusMetricServer
    • func (m *prometheusMetricServer) NewCounter(name string, help string) prometheus.Counter
    • func (m *prometheusMetricServer) NewGauge(name string, help string) prometheus.Gauge
  • func MySQL(string, int, string, string, string, ...DatabaseConfig) *database
  • func SQLite(string) *database
    • func (m *database) Query(sql string, args ...interface{}) []gorose.Data
    • func (m *database) Close()
    • func (m *database) Execute(sql string) int64
    • func (m *database) RenameTable(oldTableName string, newTableNname string)
    • func (m *database) Tables() (res []string)
    • func (m *database) CreateTable(tableName string, engineName ...string) *databaseOrm
    • func (m *database) Table(tbname string) *databaseOrm
      • func (m *databaseOrm) Fields(items ...string) *databaseOrm
      • func (m *databaseOrm) Where(key string, operator string, value interface{}) *databaseOrm
      • func (m *databaseOrm) WhereIn(key string, value []interface{}) *databaseOrm
      • func (m *databaseOrm) WhereNotIn(key string, value []interface{}) *databaseOrm
      • func (m *databaseOrm) WhereNull(columnName string) *databaseOrm
      • func (m *databaseOrm) WhereNotNull(columnName string) *databaseOrm
      • func (m *databaseOrm) OrWhere(key string, operator string, value interface{}) *databaseOrm
      • func (m *databaseOrm) OrWhereIn(key string, value []interface{}) *databaseOrm
      • func (m *databaseOrm) Orderby(item ...string) *databaseOrm
      • func (m *databaseOrm) Limit(number int) *databaseOrm
      • func (m *databaseOrm) Get() (res []gorose.Data)
      • func (m *databaseOrm) Paginate(pagesize int, page int) []gorose.Data
      • func (m *databaseOrm) First() (res gorose.Data)
      • func (m *databaseOrm) Find(id int) gorose.Data
      • func (m *databaseOrm) Count() (res int64)
      • func (m *databaseOrm) Exists() (res bool)
      • func (m *databaseOrm) Chunk(limit int, callback func([]gorose.Data) error)
      • func (m *databaseOrm) BuildSQL() (string, []interface{})
      • func (m *databaseOrm) Data(data interface{}) *databaseOrm
      • func (m *databaseOrm) Offset(offset int) *databaseOrm
      • func (m *databaseOrm) InsertGetID() (num int64)
      • func (m *databaseOrm) Insert() (num int64)
      • func (m *databaseOrm) Update(data ...interface{}) (num int64)
      • func (m *databaseOrm) Delete() (num int64)
      • func (m *databaseOrm) DropTable() int64
      • func (m *databaseOrm) TruncateTable() (status int64)
      • func (m *databaseOrm) AddColumn(columnName string, columnType string, defaultValue ...string) *databaseOrm
      • func (m *databaseOrm) DropColumn(columnName string) *databaseOrm
      • func (m *databaseOrm) AddIndex(columnName ...string) *databaseOrm
      • func (m *databaseOrm) IndexExists(columnName ...string) (exists bool)
      • func (m *databaseOrm) DropIndex(columnName ...string) *databaseOrm
      • func (m *databaseOrm) Columns() (res map[string]string)
  • func RabbitMQ(string, string) *rabbitConnection
    • func (m *rabbitConnection) Send(data map[string]string)
    • func (m *rabbitConnection) Recv() chan map[string]string
  • func RateLimit(int) *rateLimit
    • func (m *rateLimit) Take()
  • func Redis(string, int, string, int, ...redisConfig) *Redis
    • func (m *Redis) Ping() string
    • func (m *Redis) Del(key string)
    • func (m *Redis) Set(key string, value string, ttl ...interface{})
    • func (m *Redis) Get(key string) *string
    • func (m *Redis) GetLock(key string, timeoutsec int) *RedisLock
      • func (m *RedisLock) Acquire()
      • func (m *RedisLock) Release()
  • func SeleniumLocal() *selenium
  • func SeleniumRemote (serverURL string) *selenium
    • func (c *selenium) PageSource() string
    • func (c *selenium) Close()
    • func (c *selenium) Cookie() (co string)
    • func (c *selenium) Url() string
    • func (c *selenium) ScrollRight(pixel int)
    • func (c *selenium) ScrollLeft(pixel int)
    • func (c *selenium) ScrollUp(pixel int)
    • func (c *selenium) ScrollDown(pixel int)
    • func (c *selenium) ResizeWindow(width int, height int) *selenium
    • func (c *selenium) Find(xpath string, nowait ...bool) *seleniumElement
      • func (c *seleniumElement) Clear() *seleniumElement
      • func (c *seleniumElement) Click() *seleniumElement
      • func (c *seleniumElement) Text() string
      • func (c *seleniumElement) Input(s string) *seleniumElement
      • func (c *seleniumElement) Submit() *seleniumElement
      • func (c *seleniumElement) PressEnter() *seleniumElement
  • func SSH(string, string, string, int) *ssh
    • func (m *ssh) Close()
    • func (m *ssh) Exec(cmd string) (output string, status int)
    • func (m *ssh) PushFile(local string, remote string)
    • func (m *ssh) PullFile(remote string, local string)
  • func StatikOpen(string) *statikFile
    • func (m *statikFile) Readlines() chan string
    • func (m *statikFile) Readline() string
    • func (m *statikFile) Close()
    • func (m *statikFile) Read(num ...int) string
    • func (m *statikFile) Seek(num int64)
  • func Table(...string) *table
    • func (m *table) SetMaxCellWidth(width ...int)
    • func (m *table) AddRow(row ...interface{})
    • func (m *table) Render() string
  • func Telegram(AppID int32, AppHash string, config ...TelegramConfig) *Telegram
    • func (m *Telegram) Chats() []*TelegramChat
      • func (m *TelegramChat) History(limit int32, offset ...int32) (resmsgs []*tgMessage)
      • func (m *TelegramChat) Send(text string)
    • func (m *Telegram) ResolvePeerByUsername(username string) *TelegramPeerResolved
      • func (m *TelegramPeerResolved) History(limit int32, offset ...int32) (resmsgs []*TelegramMessage)
  • func TelegramBot(string) *telegramBot
    • func (m *telegramBot) SetChatID(chatid int64) *telegramBot
    • func (m *telegramBot) SendFile(path string) tgbotapi.Message
    • func (m *telegramBot) SendImage(path string) tgbotapi.Message
    • func (m *telegramBot) SendVideo(path string) tgbotapi.Message
    • func (m *telegramBot) SendAudio(path string) tgbotapi.Message
    • func (m *telegramBot) Send(text string, cfg ...tgMsgConfig) tgbotapi.Message
  • func Telegraph(string) *telegraph
    • func (m *telegraph) Post(title string, content string) *telegraphPageInfo
  • func URL(string) *url
    • func (u *url) Parse() *urlComponents
    • func (u *url) Encode() string
    • func (u *url) Decode() string
  • func TTLCache(intervalInSecond interface {}) *ttlCache
    • func (m *ttlCache) Set(key string, value string)
    • func (m *ttlCache) Get(key string) string
    • func (m *ttlCache) Exists(key string) bool
    • func (m *ttlCache) Count() int
  • func VNC(string, ...VNCCfg) *vnc
    • func (m *vnc) Close()
    • func (m *vnc) Move(x, y int) *vnc
    • func (m *vnc) Click() *vnc
    • func (m *vnc) RightClick() *vnc
    • func (m *vnc) Input(s string) *vnc
    • func (m *vnc) Key() *vncKey
      • func (m *vncKey) Enter() *vncKey
      • func (m *vncKey) CtrlA() *vncKey
      • func (m *vncKey) CtrlC() *vncKey
      • func (m *vncKey) CtrlV() *vncKey
      • func (m *vncKey) CtrlZ() *vncKey
      • func (m *vncKey) CtrlX() *vncKey
      • func (m *vncKey) CtrlF() *vncKey
      • func (m *vncKey) CtrlD() *vncKey
      • func (m *vncKey) CtrlS() *vncKey
      • func (m *vncKey) CtrlR() *vncKey
      • func (m *vncKey) CtrlE() *vncKey
      • func (m *vncKey) Delete() *vncKey
      • func (m *vncKey) Tab() *vncKey
  • func WebSocket(string) *websocket
    • func (c *websocket) Send(text string)
    • func (c *websocket) Recv(timeout ...int) string
    • func (c *websocket) Close()
  • func Xlsx(string) *xlsx
    • func (c *xlsx) Save()
    • func (c *xlsx) Close()
    • func (c *xlsx) GetSheet(name string) *xlsxSheet
      • func (c *xlsxSheet) Get(coordinate string) string
      • func (c *xlsxSheet) Set(coordinate string, value string) *xlsxSheet
  • func XPath(string) *xpath
    • func (m *xpath) First(expr string) (res *xpath)
    • func (m *xpath) Find(expr string) (res []*xpath)
    • func (m *xpath) Text() string
    • func (m *xpath) GetAttr(attr string) string
    • func (m *xpath) Html() string
  • Sysinfo
    • Host
      • func Info() types.HostInfo
      • func Memory() *types.HostMemoryInfo
      • func CPUTimes() types.CPUTimes
    • func Process(pid int) *sysinfoProcess
      • func (p *sysinfoProcess) Info() types.ProcessInfo {
      • func (p *sysinfoProcess) Memory() types.MemoryInfo {
      • func (p *sysinfoProcess) User() types.UserInfo {
      • func (p *sysinfoProcess) Parent() *sysinfoProcess {
      • func (p *sysinfoProcess) CPUTimes() types.CPUTimes {
  • Queue(datadir string) (q *queue)
    • func (m *queue) Close()
    • func (m *queue) Destroy()
    • func (m *queue) New(queueName ...string) *namedQueue
      • func (m *namedQueue) Size() int64
      • func (m *namedQueue) Get(nonblock ...bool) string
      • func (m *namedQueue) Put(value string)
  • Jieba() *Jieba 中文分词
    • func (m *Jieba) Close()
    • func (m *Jieba) Cut(s string) []string
    • func (m *Jieba) AddWord(text string)

• Random

  • func Int(min, max int64) int64
  • func Choice(array interface{}) interface{}
  • func String(length int, charset ...string) string

• Re

  • func FindAll(pattern string, text string, multiline ...bool) [][]string
  • func Replace(pattern string, newstring string, text string) string

• Socket

  • KCP
    • func Listen(string, int, string, string) *kcpServerSideListener
      • func (m *kcpServerSideListener) Accept() chan *kcp.UDPSession
    • func Connect(string, int, string, string) *kcp.UDPSession
  • Smux
    • func ServerWrapper(io.ReadWriteCloser, ...SmuxConfig) *smuxServerSideListener
      • func (m *smuxServerSideListener) Accept() chan *smuxServerSideConnection
        • func (m *smuxServerSideConnection) Send(data map[string]string, timeout ...int)
        • func (m *smuxServerSideConnection) Recv(timeout ...int) (data map[string]string)
        • func (m *smuxServerSideConnection) Close()
    • func ClientWrapper(io.ReadWriteCloser, ...SmuxConfig) *smuxClientSideSession
      • func (m *smuxClientSideSession) Connect() *smuxClientSideConnection
      • func (m *smuxClientSideSession) Close()
        • func (m *smuxClientSideConnection) Send(data map[string]string, timeout ...int)
        • func (m *smuxClientSideConnection) Recv(timeout ...int) (data map[string]string)
        • func (m *smuxClientSideConnection) Close()
  • SSL
    • func Listen(string, int, string, string) *tcpServerSideListener
      • func (m *tcpServerSideListener) Accept() chan *TcpServerSideConn
      • func (m *tcpServerSideListener) Close()
        • func (m *TcpServerSideConn) Close()
        • func (m *TcpServerSideConn) Send(str string)
        • func (m *TcpServerSideConn) Recv(buffersize int) string
    • func ServerWrapper(net.Conn, string, string) *tcpServerSideConn
      • func (m *tcpClientSideConn) Send(str string, timeout ...int)
      • func (m *tcpClientSideConn) Recv(buffersize int, timeout ...int) string
      • func (m *tcpClientSideConn) Close()
    • func Connect(string, int, ...sslCfg) *sslClientSideConn
    • func ClientWrapper(net.Conn, ...sslCfg) *sslClientSideConn
      • func (m *sslClientSideConn) Send(str string)
      • func (m *sslClientSideConn) Recv(buffersize int) string
      • func (m *sslClientSideConn) Close()
  • TCP
    • func Listen(string, int) *tcpServerSideListener
      • func (m *tcpServerSideListener) Accept() chan *TcpServerSideConn
      • func (m *tcpServerSideListener) Close()
        • func (m *TcpServerSideConn) Close()
        • func (m *TcpServerSideConn) Send(str string)
        • func (m *TcpServerSideConn) Recv(buffersize int) string
    • func Connect(string, int, ...int) *tcpClientSideConn
      • func (m *tcpClientSideConn) Send(str string, timeout ...int)
      • func (m *tcpClientSideConn) Recv(buffersize int, timeout ...int) string
      • func (m *tcpClientSideConn) Close()
  • Unix
    • func Listen(path string) *tcpServerSideListener
      • func (m *tcpServerSideListener) Accept() chan *TcpServerSideConn
      • func (m *tcpServerSideListener) Close()
        • func (m *TcpServerSideConn) Close()
        • func (m *TcpServerSideConn) Send(str string)
        • func (m *TcpServerSideConn) Recv(buffersize int) string
    • func Connect(path string) *tcpClientSideConn
      • func (m *tcpClientSideConn) Send(str string, timeout ...int)
      • func (m *tcpClientSideConn) Recv(buffersize int, timeout ...int) string
      • func (m *tcpClientSideConn) Close()
  • UDP
    • func Listen(string, int) udpServerSideConn
      • func (m *udpClientSideConn) Send(str string)
      • func (m *udpClientSideConn) Close()
      • func (m *udpClientSideConn) Recv(buffersize int) string
    • func Connect(string, int) udpClientSideConn
      • func (m *udpServerSideConn) Recvfrom(buffersize int, timeout ...int) (string, *net.UDPAddr)
      • func (m *udpServerSideConn) Sendto(data string, address *net.UDPAddr, timeout ...int)
      • func (m *udpServerSideConn) Close()

• String

  • func (s *string) Get() string
  • func (s *string) Sub(start, end int) *string
  • func (s *string) Has(substr string) bool
  • func (s *string) Len() int
  • func (s *string) Reverse() string
  • func (s *string) Chunk(length int) (res []string)
  • func (s *string) Utf8Len() int
  • func (s *string) Repeat(count int) *string
  • func (s *string) Shuffle() *string
  • func (s *string) Index(substr string) int
  • func (s *string) Replace(old, new string) *string
  • func (s *string) Upper() *string
  • func (s *string) Lower() *string
  • func (s *string) Join(pieces []string) *string
  • func (s *string) Strip(characterMask ...string) *string
  • func (s *string) Split(sep ...string) []string
  • func (s *string) Count(substr string) int
  • func (s *string) EndsWith(substr string) (res bool)
  • func (s *string) StartsWith(substr string) (res bool)
  • func (s *string) Splitlines(strip ...bool) []string
  • func (s *string) In(str string) bool
  • func (s *string) LStrip(characterMask ...string) *string
  • func (s *string) RStrip(characterMask ...string) *string
  • func (ss*string) Isdigit() bool
  • func (s *string) HasChinese() bool
  • func (s *string) Filter(charts ...string) *string
  • func (s *string) RemoveHtmlTag() *string
  • func (s *string) RemoveNonUTF8Character() *string
  • func (s *string) DetectLanguage() string
  • func (s *string) IsAscii() bool
  • func (s *string) RegexFindAll(pattern string, multiline ...bool) (res [][]*string)
  • func (s *string) RegexReplace(pattern string, newstring string) *string

• Time:

  • func Now() float64
  • func TimeDuration(interface {}) time.Duration
  • func FormatDuration(int64) string
  • func Sleep(interface {})
  • func Strptime(string, string) int64
  • func Strftime(string, interface {}) string

• Argparser(description string) *argparseIni

  • func (m *argparseIni) Get(section, key, defaultValue, comment string) (res string)
  • func (m *argparseIni) GetInt(section, key, defaultValue, comment string) int
  • func (m *argparseIni) GetInt64(section, key, defaultValue, comment string) int64
  • func (m *argparseIni) GetFloat64(section, key, defaultValue, comment string) float64
  • func (m *argparseIni) GetBool(section, key, defaultValue, comment string) bool
  • func (m *argparseIni) Save(fpath ...string) (exist bool)
  • func (m *argparseIni) GetHelpString() (h string)
  • func (m *argparseIni) ParseArgs() *argparseIni

• Base64

  • func Encode(str string) string
  • func Decode(str string) string

• Binary

  • func Map2bin(m map[string]string) string
  • func Bin2map(s string) (res map[string]string)

• Cmd

  • func GetOutput(command string, timeoutSecond ...interface{}) string
  • func GetStatusOutput(command string, timeoutSecond ...interface{}) (int, string)
  • func GetOutputWithShell(command string, timeoutSecond ...interface{}) string
  • func GetStatusOutputWithShell(command string, timeoutSecond ...interface{}) (int, string)
  • func Tail(command string) chan string
  • func Exists(cmd string) bool
  • func Which(cmd string) (path string)

• Crypto

  • func Xor(data, key string) string
  • func Aes(key string) *aes
    • func (a *aes) Encrypt(plaintext string) string
    • func (a *aes) Decrypt(ciphertext string) string
  • func ChaCha20Poly1305(key string) *chacha20poly1305
    • func (m *chacha20poly1305) Encrypt(plantext string) (ciphertext string)
    • func (m *chacha20poly1305) Decrypt(ciphertext string) (plaintext string)

• File(filePath string) *file

  • func (f *file) Time() *fileTime
  • func (f *file) Stat() os.FileInfo
  • func (f *file) Size() int64
  • func (f *file) Touch()
  • func (f *file) Chmod(mode int) bool
  • func (f *file) Chown(uid, gid int) bool
  • func (f *file) Mtime() int64
  • func (f *file) Unlink()
  • func (f *file) Copy(dest string)
  • func (f *file) Move(newPosition string)

• Open(args ...string) *fileIO

  • func (m *fileIO) Readlines() chan string
  • func (m *fileIO) Readline() string
  • func (m *fileIO) Close()
  • func (m *fileIO) Write(str interface{}) *fileIO
  • func (m *fileIO) Read(num ...int) string
  • func (m *fileIO) Seek(num int64)

• Funcs

  • func Nslookup(name string, querytype string, dnsService ...string) [][]string
  • func FakeName() string
  • func FileType(fpath string) string
  • func Inotify(path string) chan *fsnotifyFileEvent
  • func IPLocation(ip string, dbpath ...string) *ipLocationInfo
  • func HightLightHTMLForCode(code string, codeType ...string) (html string)
  • func Markdown2html(md string) string
  • func CPUUsagePerProgress() (res map[int64]progressCPUUsage)
  • func ResizeImg(srcPath string, dstPath string, width int, height ...int)
  • func GetRSS(url string, config ...rssConfig) *gofeed.Feed
  • func GbkToUtf8(s string) string
  • func Utf8ToGbk(s string) string
  • func GetSnowflakeID(nodeNumber ...int) int64
  • func GetRemoteServerSSLCert(host string, port ...int) []*x509.Certificate
  • func Tailf(path string, startFromEndOfFile ...bool) chan *tail.Line
  • func BaiduTranslateAnyToZH(text string) string
  • func ParseUserAgent(UserAgent string) ua.UserAgent
  • func Wget(url string, cfg ...WgetCfg) (filename string)
  • func Whois(s string, servers ...string) string
  • func IpInNet(ip string, Net string, mask ...string) bool
  • func Int2ip(ipnr int64) string
  • func Ip2int(ipnr string) int64
  • func Zh2PinYin(zh string) (ress []string)
  • func Fmtsize(num uint64) string
  • func Sniffer(interfaceName string, filterString string, promisc ...bool) chan *networkPacket
  • func ReadPcapFile(pcapFile string) chan *networkPacket

• Hash

  • func Md5sum(str string) string
  • func Md5File(path string) string
  • func Sha1sum(str string) string
  • func Sha1File(path string) string

• Html

  • func Encode(str string) string
  • func Decode(str string) string

• Http

  • func Head(uri string, args ...interface{}) httpResp
  • func PostFile(uri string, filePath string, args ...interface{}) httpResp
  • func PostRaw(uri string, body string, args ...interface{}) httpResp
  • func PostJSON(uri string, json interface{}, args ...interface{}) httpResp
  • func Post(uri string, args ...interface{}) httpResp
  • func Get(uri string, args ...interface{}) httpResp
  • func PutJSON(uri string, json interface{}, args ...interface{}) httpResp
  • func Put(uri string, args ...interface{}) httpResp
  • func PutRaw(uri string, body string, args ...interface{}) httpResp
  • func Delete(uri string, args ...interface{}) httpResp

• Json

  • func Dumps(v interface{}, pretty ...bool) string
  • func Loads(str string) map[string]interface{}
  • func Valid(j string) bool
  • func Yaml2json(y string) string 转换yaml到json
  • func Json2yaml(j string) string 转换json到yaml, 注意：字段的顺序会改变
  • func Format(js string) string 格式化json字符串, 可以多次format，不报错，结果正常
  • func XPath(string) *xpathJson
    • func (m *xpathJson) Exists(expr string) bool
    • func (m *xpathJson) First(expr string) (res *xpathJson)
    • func (m *xpathJson) Find(expr string) (res []*xpathJson)
    • func (m *xpathJson) Text() *string

• Math

  • func Abs(number float64) float64
  • func Sum(array interface{}) (sumresult float64)
  • func Average(array interface{}) (avgresult float64)
  • func DecimalToAny(num, n int64) string
  • func AnyToDecimal(num string, n int64) int64

• Os

  • func Mkdir(filename string)
  • func Getcwd() string
  • func Exit(status int)
  • func Touch(filePath string)
  • func Chmod(filePath string, mode int) bool
  • func Chown(filePath string, uid, gid int) bool
  • func Copy(filePath, dest string)
  • func Rename(filePath, newPosition string)
  • func Move(filePath, newPosition string)
  • Path
    • func Exists(path string) bool
    • func IsFile(path string) bool
    • func IsDir(path string) bool
    • func Basename(path string) string
    • func Basedir(path string) string
    • func Dirname(path string) string
    • func Join(args ...string) string
    • func Abspath(path string) string
    • func IsSymlink(path string) bool
  • func System(command string, timeoutSecond ...interface{}) int
  • func SystemWithShell(command string, timeoutSecond ...interface{}) int
  • func Hostname() string
  • func Envexists(varname string) bool
  • func Getenv(varname string) string
  • func Walk(path string) chan string
  • func Listdir(path string) (res []string)
  • func SelfDir() string
  • func TempFilePath() string
  • func TempDirPath() string
  • func Getuid() int
  • func ProgressAlive(pid int) bool
  • func GoroutineID() int64
  • func Unlink(filename string)
  • Stdin
    • func Readlines() chan *String
    • func Readline() *String
    • func Read(num ...int) *String
  • Stdout
    • Write(str interface{}) *fileIO Others

• func Open(filePath string) *fileIO

• func Try(f func(), trycfg ...TryConfig) exception

• Lg *log

  • func (m *log) SetLevel(level string)
  • func (m *log) GetLevel() string
  • func (m *log) SetLogFile(path string, maxLogFileCount int, logFileSizeInMB ...int)
  • func (m *log) Error(args ...interface{})
  • func (m *log) Warn(args ...interface{})
  • func (m *log) Info(args ...interface{})
  • func (m *log) Trace(args ...interface{})
  • func (m *log) Debug(args ...interface{})

• func Chr(ascii int) string

• func Ord(char string) int

• func Repr(obj interface{}) string

• func Print(data ...interface{}) int

• func Printf(format string, data ...interface{}) int

• func Sprint(data ...interface{}) string

• func Range(num ...int) []int

• func Typeof(v interface{}) string

Example

Json.Yaml2Json

func main() {
	j := `code: 0
mesg: Get Domains Successful
result:
  active: true
  domains:
  - ishomee.com
  - dx2cone1.xyz
  - zhiyunxianghe.com
success: true`
	fmt.Println(Json.Yaml2json(j))
}

Json.Json2yaml

func main() {
	j := `{"code":0,"mesg":"Get Domains Successful","result":{"active":true,"domains":["ishomee.com","dx2cone1.xyz","zhiyunxianghe.com"]},"success":true}`
	Print(Json.Json2yaml(j))
}

Tools.Chart.LineChartWithTimestampAndNumber

func main() {
	x := "2020-04-21,2020-05-09,2020-05-11,2020-05-14,2020-05-15,2020-05-17,2020-05-19,2020-05-20,2020-05-21,2020-05-22,2020-05-24,2020-05-25,2020-05-26,2020-05-27,2020-05-28,2020-05-29,2020-05-30,2020-05-31,2020-06-01,2020-06-02,2020-06-03,2020-06-04,2020-06-05,2020-06-06,2020-06-07,2020-06-08,2020-06-09,2020-06-10,2020-06-11,2020-06-12,2020-06-13,2020-06-14,2020-06-15,2020-06-16,2020-06-17,2020-06-18,2020-06-19,2020-06-20,2020-06-21,2020-06-22,2020-06-23,2020-06-25,2020-06-26,2020-06-27,2020-06-28,2020-06-29,2020-06-30,2020-07-01,2020-07-02,2020-07-03,2020-07-04,2020-07-05,2020-07-06,2020-07-07,2020-07-08,2020-07-09,2020-07-10,2020-07-11,2020-07-12,2020-07-13,2020-07-14,2020-07-15,2020-07-16,2020-07-17,2020-07-18,2020-07-19,2020-07-20,2020-07-21,2020-07-22,2020-07-23,2020-07-24,2020-07-25,2020-07-26,2020-07-27,2020-07-28,2020-07-29,2020-07-30,2020-07-31,2020-08-01,2020-08-02,2020-08-03,2020-08-04,2020-08-05,2020-08-06,2020-08-07,2020-08-08,2020-08-09,2020-08-10,2020-08-11,2020-08-12,2020-08-13"
	var xx []int64
	for _, i := range String(x).Split(",") {
		xx = append(xx, Time.Strptime("%Y-%m-%d", i))
	}

	y := "100,100,500,100,100,100,200,700,200,700,300,400,900,1100,1400,900,3004,908,1460,4400,1500,2000,2950,2150,2750,7150,3850,4050,3900,4800,4200,7400,6700,6150,7400,7250,7550,9800,8900,5300,1700,1000,800,1500,1150,1300,2060,3820,4852,4320,4960,5160,2610,2640,3300,1770,2690,2020,2360,2050,1580,1410,1080,850,1540,1410,1460,1540,1620,1370,3328,3898,2218,2238,2398,2038,1700,750,1100,1700,1650,1340,950,2270,540,890,1390,1900,1580,2450,1680"
	var yy []float64
	for _, i := range String(y).Split(",") {
		yy = append(yy, Float64(i))
	}

	drawLineChartWithTimeSeries(xx, yy, "日期", "人数", "每日访问量", "output.png") // 不论文件名，都输出png格式图片
}

Tools.Crontab

func func1(arg string) {
	Print(arg)
}

func main() {
	c := Tools.Crontab()
	
	c.Add("*/1 * * * *", func() {
		Print(now())
	})

	c.Add("*/1 * * * *", func(param1 string, param2 string) {
		Print(Time.Now(), "with param: "+param1+" and "+param2)
	}, "paramValue1", "paramValue2")

	c.Add("00 16 * * *", func1, "args1")

	select {}
}

关于时间格式

*     *     *     *     *        

^     ^     ^     ^     ^
|     |     |     |     |
|     |     |     |     +----- day of week (0-6) (Sunday=0)
|     |     |     +------- month (1-12)
|     |     +--------- day of month (1-31)
|     +----------- hour (0-23)
+------------- min (0-59)

举例子

1. * * * * * run on every minute
2. 10 * * * * run at 0:10, 1:10 etc
3. 10 15 * * * run at 15:10 every day
4. * * 1 * * run on every minute on 1st day of month
5. 0 0 1 1 * Happy new year schedule
6. 0 0 * * 1 Run at midnight on every Monday
7. * 10,15,19 * * * run at 10:00, 15:00 and 19:00
8. 1-15 * * * * run at 1, 2, 3...15 minute of each hour
9. 0 0-5,10 * * * run on every hour from 0-5 and in 10 oclock
10. */2 * * * * run every two minutes
11. 10 */3 * * * run every 3 hours on 10th min
12. 0 12 */2 * * run at noon on every two days
13. 1-59/2 * * * * run every two minutes, but on odd minutes

Tools.JavascriptVM

func main() {
  s := "a = 1;console.log(b);"
  vm := Tools.JavascriptVM()
  vm.Set("b", "2")
  vm.Run(s)
  Print(vm.Get("a"))
}

Tools.Matrix

  // 设置homeserver的url, 以及需要发送到的会话的id, 这个房间的消息不能是加密的
  cli = Tools.Matrix("https://example.com").SetRoomID("!AquOdzAnBLIQvfPkan:example.com")

  // 可以使用帐号密码登录, 它会先获取token, 然后使用token去交互, 每次登录获取一次token
  token := cli.Login("bot", "123456") // 登录成功会返回一个token
  // 也可以直接使用token, 默认synapse的token是没有过期时间的
  cli.SetToken("@bot:example.com", "syt_Ym90_iHallJrSVvDLFCfnvnZZ_4a2WKt")
  
  cli.Send(msg)
}

Tools.Nats

func main() {
	server := "nat://nats.nats.svc.cluster.local"
	subj := Tools.Nats(server).Subject("mysubject")

	go func() {
		for msg := range subj.Subscribe() {
			Lg.trace(msg)
		}
	}()

	for {
		sleeptime := Rand.Int(1, 3)
		Time.Sleep(sleeptime)
		subj.Publish("sleep for " + str(sleeptime) + " second(s) just now")
	}
}

Tools.Pexpect

准备个py，做交互的子进程

try:
    while True:
        a = input("Enter something: ")
        Print("You Enter: ", a)
except:
	pass

func main() {
	i := 0
	p := Tools.Pexpect("python3 test.py")
	defer p.Close()
	p.LogToStdout()
	for p.IsAlive() {
		Time.Sleep(1)
		if strings.Contains(p.GetLog(), "Enter something:") {
			p.ClearLog()
            p.Sendline(Str(i))
		}
		i++
		if i >= 5 {
			p.Close()
			break
		}
	}
	Print("Exit code:", p.ExitCode())
}

Tools.Ini

func main() {
	i := Tools.Ini("c.ini")                               // 直接读，不存在就返回空的ini结构体
	Print(i.Get("section", "key", "value", "comment")) // 直接读，如果存在就返回配置项目，如果不存在就写入配置项目到结构体，并返回默认值
	Print(i.Save())                                    // 保存文件，如果文件存在返回true，不存在返回false
}

Tools.ProgressBar

func main() {
	bar := Tools.ProgressBar("example bar", 100)
	for i := 0; i < 100; i++ {
		bar.Add(1)
		Time.Sleep(5)
		if i == 80 {
			bar.SetTotal(300) // 重设最大长度
		}
	}

	for i := 0; i < 200; i++ {
		bar.Add(1)
		Time.Sleep(5)
	}
}

Tools.PrometheusClient

如果聚合成一个值, 没有label的, 应该是不支持(暂时没这个需求, 没做适配)

func main() {
	p := Tools.PrometheusClient("http://localhost:9090")
	pr := p.Query("sum_over_time(channel_register_count_in_5_minutes{channel=\"1\"}[1h]) / sum_over_time(channel_inpour_count_in_5_minutes[1h]) < 100")
	Lg.Debug(pr)
}

上例输出

[]main.prometheusResult{
  main.prometheusResult{
    Label: map[string]string{
      "instance":  "10.0.0.1:9100",
      "job":       "my-service-svc",
      "namespace": "default",
      "pod":       "my-service-332332234-1231232",
      "service":   "my-service-svc",
      "channel":   "1",
      "endpoint":  "my-endpoint",
    },
    Value: 44.651376,
  },
}

Tools.PrometheusMetricServer

func TestPrometheusMetricServer(t *testing.T) {
	p := getPrometheusMetricServer("0.0.0.0:9301")
	c := p.NewCounter("test_counter", "this is a test Counter metrics")
	g := p.NewGauge("test_gauge", "this is a test Gauge metrics")

	go func() {
		for {
			c.Add(1)
			Time.Sleep(1)
		}
	}()

	for {
		g.Set(Float64(Random.Int(0, 10000)))
		Time.Sleep(1)
	}
}

Tools.MySQL

操作表

func main() {
	db := Tools.MySQL("mysql-svc", 3306, "root", "", "test")
	//db := getSQLite("data.db")
	// 建表
	db.CreateTable("tbName")
	// 添加列
	db.Table("tbName").AddColumn("intType", "int")      // bigint
	db.Table("tbName").AddColumn("floatType", "float")  // double
	db.Table("tbName").AddColumn("vcharType", "string") // VARCHAR(512)
	db.Table("tbName").AddColumn("textType", "text")    // LONGTEXT
	// 删除列
	db.Table("tbName").DropColumn("intType") // SQLite不支持
	// 添加索引
	db.Table("tbName").AddIndex("floatType")
	db.Table("tbName").AddIndex("floatType", "vcharType")
	// 删除索引
	db.Table("tbName").DropIndex("floatType")
	db.Table("tbName").DropIndex("floatType", "vcharType")

	// 也可以链式操作
	db.CreateTable("usercodes").
		AddColumn("usercode", "string").
		AddColumn("start", "int").
		AddColumn("duration", "int").
		AddIndex("usercode")

	// 临时使用的表
	pg := getSQLite(":memory:").
		CreateTable("progress").
		AddColumn("pid", "float").
		AddColumn("name", "string").
		AddColumn("cpu", "float").
		AddColumn("cmd", "string").
		AddColumn("start", "int").
		AddColumn("end", "int").
		AddColumn("notified", "string").
		AddIndex("cpu")
}

数据查询

func main() {
	db := getMySQL("mysql-svc", 3306, "root", "", "test")

	u := db.Table("user") // 之后使用u这个变量去操作的话，线程不安全, 多线程就需要每个线程都一次db.Table()

	// select
	reses := db.Table("user").Fields("id", "name", "age").Where("age", ">", 0).Orderby("id desc").limit(2).get()
	fmt.Println(reses) // [map[age:6 id:5 name:cat ] map[age:5 id:4 name:monkey]]
	// 获取一个行
	fmt.Println(reses[0]) // map[age:6 id:5 name:cat ]
	// 便利所有行获取某个字段
	for _, r := range reses {
		fmt.Println(r["name"])
	}

	// 获取第一条记录
	res := db.Table("user").Where("age", ">", 0).Orderby("id", "desc").First()
	fmt.Println(res) // map[age:6 id:5 name:cat ]
	Print(len(res)) // 0, 如果没数据 

	count := db.Table("user").Where("age", ">", 0).count()
	fmt.Println(count) // 5

	// 便利数据库
	db.Table("user").Fields("id", "name", "age").Where("age", ">", 0).Orderby("id").chunk(2, func(data []gorose.Data) error {
		fmt.Println("In Chunk: ", data)
		// In Chunk:  [map[age:1 id:1 name:cookie] map[age:2 id:2 name:ares]]
		// In Chunk:  [map[age:3 id:3 name:div] map[age:5 id:4 name:monkey]]
		// In Chunk:  [map[age:6 id:5 name:cat ]]
		return nil
	})

	// 插入一条数据
	var data = map[string]interface{}{"age": 17, "name": "it3"}
	id := db.Table("user").Data(data).InsertGetID()
	fmt.Println(id) // 6， 为新数据的id

	// 插入多条数据
	var multiData = []map[string]interface{}{{"age": 18, "name": "it4"}, {"age": 19, "name": "it5"}}
	re := db.Table("user").Data(multiData).Insert()
	fmt.Println(re) // 2 ， 插入的数据条数

	// 更新数据
	re = db.Table("user").Where("id", "=", 1).OrWhere("age", ">", 5).Data(map[string]interface{}{"age": 29, "name": "new Name"}).update()
	fmt.Println(re) // 5, 更新的数据条数

	// 删除数据
	re = db.Table("user").Where("id", "=", 1).Delete()
	fmt.Println(re) // 1, 删除的数据条数

	rese := db.Query("select count(id) as `count`, `age` from `user` group by `age` order by `count` desc")
	fmt.Println(rese) // [map[age:29 count:4] map[age:2 count:1] map[age:3 count:1] map[age:5 count:1]]

	ress := db.Execute("delete from `user` where `age` = 29")
	fmt.Println(ress) // 4

	sql, param := db.Table("user").Fields("id", "name", "age").Where("age", ">", 0).Orderby("id desc").limit(2).buildSQL()
	fmt.Println(sql, param) // SELECT `id`,`name`,`age` FROM `user` WHERE `age` > ? ORDER BY id desc LIMIT 2 [0]
}

上面范例用到的SQL

CREATE TABLE `user`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
  `age` int(11) NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 0 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;

INSERT INTO `user` VALUES (1, 'cookie', 1);
INSERT INTO `user` VALUES (2, 'ares', 2);
INSERT INTO `user` VALUES (3, 'div', 3);
INSERT INTO `user` VALUES (4, 'monkey', 5);
INSERT INTO `user` VALUES (5, 'cat ', 6)

jsonDumps() - 序列化类型到json字符串

func main() {
	a := jsonMap{
		"a": "b",
		"c": "d",
		"e": jsonMap{"f": "g"},
		"h": jsonArr{1, "k"},
	}
	j := jsonDumps(a) // {"a":"b","c":"d","e":{"f":"g"},"h":[1,"k"]}
	Print(j)
	k := jsonLoads(j)
	Print(k)      // map[a:b c:d e:map[f:g] h:[1 k]]
	Print(k["a"]) // b
}

Tools.RabbitMQ

func main() {
	go func() {
		rb := Tools.RabbitMQ("amqp://guest:guest@rabbitmq-svc:5672/", "default")
		rb.Send(map[string]string{"data": "Test Message"})
	}()

	go func() {
		rb := Tools.RabbitMQ("amqp://guest:guest@rabbitmq-svc:5672/", "default")
		msg := <-rb.Recv()
		Lg.debug(msg)
	}()

	select {}
}

Tools.Redis

func main() {
	rdb := Tools.Redis("redis-svc", 6379, "", 1)
	rdb.Set("key", "value")
	fmt.Println(*rdb.Get("key")) // 如果key不存在返回nil, 存在则返回value的类型为string的指针
	rdb.Set("ttl", "delete after 1 second", 1)
	rdb.Set("ttl2", "delete after 0.5 second", 0.5)
	rdb.Del("key")
}

Tools.Selenium

func main() {
	// 需要chromedriver在PATH环境变量所在的目录里面, 会先起一个服务, 然后连接, 返回一个客户端
	sn := Tools.Selenium("https://example.com/auth/login")
	defer sn.Close() // 关闭服务端和客户端

	// 登录
	Lg.Trace("选语言")
	// 直接写select的下拉菜单的option的xpath
	sn.First(`/html/body/div/div[1]/div[1]/div[2]/form/div[3]/div/select/option[2]`).click()
	Lg.Trace("输入用户名")
	sn.First(`//*[@id="login"]`).clear().input("user") // 先清空再输入
	Lg.Trace("输入密码")
	sn.First(`//*[@id="password"]`).clear().input("pass")
	Lg.Trace("点击登录")
	sn.First(`/html/body/div[1]/div[1]/div[1]/div[2]/form/center/div/input`).click()

	// 查找单个会员信息
	Lg.Trace("搜索单个会员帐号")
	sn.First(`//*[@id="gotomemberinfo"]`).input("uid12345").pressEnter() // 输入并回车
	vipLevel := sn.First(`/html/body/div[2]/div/div[1]/div[1]/div[3]/div/div/div/div[1]/fieldset[2]/div/div[1]/div[1]`).text()
	Lg.Trace("VIP等级:", is.VipLevel)

	Lg.Trace("直接查询接口")
	url := sn.url() // 获取当前的url
	uid := String(url).Split("/")[len(String(url).Split("/"))-1]
	j := Http.Get("https://example.com/player_management/getDetails/"+uid, httpHeader{
		"cookie": sn.Cookie(), // cookie的字符串
	}).content
	//Lg.Trace(j)
	jj := Tools.JsonXPath(j)
	length = jj.First("//Details/total").Text()
	Lg.Trace("剩余时长:", is.length)


	select {}
}

Tools.SSH

func main() {
	s := Tools.SSH("root", "root", "192.168.152.19", 22)
	Print(s.Exec("id"))
	s.PullFile("anaconda-ks.cfg", "tmp.file")
	s.PushFile("main.go", "main.go")
}

Tools.VNC

func main() {
	v := Tools.VNC("192.168.3.49:5900", VNCCfg{Password: "r"}) // vncCfg可选
	v.Move(237, 570).click()
	v.Input("Hello world!\nHHHHHH") // 不支持中文, 只支持键盘上有的按键. 

    v.Key().CtrlC()

	// Ctrl-C
	v.VC.KeyEvent(vncNonAsciiKeyMap.Control, true)
	v.VC.KeyEvent(vncAsciiKeyMap["c"][0], true)
	v.VC.KeyEvent(vncAsciiKeyMap["c"][0], false)
	v.VC.KeyEvent(vncNonAsciiKeyMap.Control, false)
}

Tools.Xlsx

func main() {
	// 不存在则新建, 会读取所有内容到内存
	xlsx := Tools.Xlsx("Book1.xlsx")
	// 不存在则新建, 表名字的第一个字母会大写
	sheet1 := xlsx.GetSheet("sheet4")
	// 设置B列第14行的值为value, 和C列第3行的值为key
	sheet1.Set("B14", "value").Set("C3", "key")
	// 获取值
	fmt.Println(sheet1.Get("C3"))
	// 关闭
	xlsx.Close()
}

Tools.XPath

准备个xml实例

<bookstore>

<book category="cooking">
  <title lang="en">Everyday Italian</title>
  <author>Giada De Laurentiis</author>
  <year>2005</year>
  <price>30.00</price>
</book>

<book category="children">
  <title lang="zh-cn">Harry Potter</title>
  <author>J K. Rowling</author>
  <year>2005</year>
  <price>29.99</price>
</book>

<book category="web">
  <title lang="zh-tw">XQuery Kick Start</title>
  <author>James McGovern</author>
  <author>Per Bothner</author>
  <author>Kurt Cagle</author>
  <author>James Linn</author>
  <author>Vaidyanathan Nagarajan</author>
  <year>2003</year>
  <price>49.99</price>
</book>

<book category="web">
  <title lang="zh-hk">Learning XML</title>
  <author>Erik T. Ray</author>
  <year>2003</year>
  <price>39.95</price>
</book>

</bookstore> 

如下代码

package main

func main() {
	content := Open("i.html").Read()
	doc := Tools.XPath(content)
	for _, title := range doc.Find("//title") {
		Lg.Trace("获取lang属性: " + title.GetAttr("lang") + ". 获取title标签的文字: " + title.Text())
	}

	book := doc.Find("//bookstore/book[1]")[0]
	Lg.Trace("只包含子节点的html: ", book.ChildHTML())

	Lg.Trace("包含book标签本身的html: ", book.Html())

	author := doc.Find("//bookstore/book[1]/author[2]")
	Lg.Trace("在第一个book找不到第二个author:", author)
}

输出

02-10 00:54:10   1 [TRAC] (main.go:7) 获取lang属性: en. 获取title标签的文字: Everyday Italian
02-10 00:54:10   1 [TRAC] (main.go:7) 获取lang属性: zh-cn. 获取title标签的文字: Harry Potter
02-10 00:54:10   1 [TRAC] (main.go:7) 获取lang属性: zh-tw. 获取title标签的文字: XQuery Kick Start
02-10 00:54:10   1 [TRAC] (main.go:7) 获取lang属性: zh-hk. 获取title标签的文字: Learning XML
02-10 00:54:10   1 [TRAC] (main.go:11) 只包含子节点的html:  
                        <title lang="en">Everyday Italian</title>
                        <author>Giada De Laurentiis</author>
                        <year>2005</year>
                        <price>30.00</price>
02-10 00:54:10   1 [TRAC] (main.go:13) 包含book标签本身的html:  <book category="cooking">
                        <title lang="en">Everyday Italian</title>
                        <author>Giada De Laurentiis</author>
                        <year>2005</year>
                        <price>30.00</price>
                      </book>
02-10 00:54:10   1 [TRAC] (main.go:16) 在第一个book找不到第二个author: []

Socket.KCP

注意:

1. 没有TCP的连接这个概念, 所以需要手动维护连接. 1.1 客户端的Connect实际上不会发送任何数据到服务端, 需要随便发送一个东西, 服务端才会收到连接, 类似于TCP的SYN包 1.2 NAT网关上面有个UDP的超时时间, 如果超时了, 那服务端发送的数据就到不了客户端了, 这里实现了心跳，20秒一次，客户端发给服务端。如果服务端3次20秒都没收到心跳，则关闭连接。如果客户端3次20秒没有收到心跳的回复，也关闭连接。 1.3 如果发送数据包， 发送之后程序立刻就退出或者关闭连接了，那么这个发送是没有成功的，sleep一下，等它发送完，最好等对端有回应确认 1.4 任意一端关闭了连接，另一端是不知道的，另一端发送或者读取会timeout，timeout时间是120秒。（应该120秒内还没timeout，就会被心跳goroutine关掉连接）
2. 其它的 1.1 写入一个关闭的链接就抛异常， 调用send，在另一个goroutine关闭链接也是这样

package main

var key string = "demo key keykeykeykeykeykeykey"
var salt string = "demo salt saltsaltsaltsaltsaltsalt"

var lg *log

func main() {
	args := Argparser("test kcp")
	side := args.Get("", "side", "s", "\"c\" for client, \"s\" for server")
	addr := args.Get("", "addr", "127.0.0.1", "address for listen or connect to")
	port := args.GetInt("", "port", "12345", "port for listen or connect to")
	args.ParseArgs()

  // 客户端
	if side == "c" {
		c := Socket.KCP.Connect(addr, port, key, salt)
		c.Send("1", "2", "3")
    Time.Sleep(1) // 等待1秒， 让数据都发出去， 再退出
  // 服务端
	} else if side == "s" {
		k := Socket.KCP.Listen(addr, port, key, salt)
		c := <-k.Accept()
    Print(c.Recv(10)) // 收到[]string{"1", "2", "3"}, 如果10秒内没收到, 得到nil
	}
}

Socket.TCP.Connect

func main() {
	c := Socket.TCP.Connect("localhost", 8888)
	defer c.Close()
	c.Send("GET / HTTP/1.1\r\n\r\n")
	fmt.Println(c.Recv(1024))
}

Socket.TCP.Listen

func main() {
	l := Socket.TCP.Listen("0.0.0.0", 8899)
	defer l.Close()

	for c := range l.Accept() {
		fmt.Println(c.Recv(1024))
		c.Send("HTTP/1.1 200 OK\r\n\r\n")
		c.Close()
	}
}

Socket.SSL.Listen

func main() {
	crt := `-----BEGIN CERTIFICATE-----
-----END CERTIFICATE-----`
	key := `-----BEGIN PRIVATE KEY-----
-----END PRIVATE KEY-----`
	cacrt := `-----BEGIN CERTIFICATE-----
-----END CERTIFICATE-----`
	if os.Args[1] == "s" {
		Lg.Trace("SSL Server started.")
		sl := Socket.SSL.Listen("0.0.0.0", 7789, key, crt)
		for sc := range sl.Accept() {
			go func(sc *TcpServerSideConn) {
				defer sc.Close()
				try(func() {
					for {
						sc.Send(sc.Recv(1024))
					}
				}).Except(func(e error) {
					Lg.Trace("Error:", e)
				})
			}(sc)
		}
	} else if os.Args[1] == "c" {
		Lg.Trace("SSL Client started")
		sc := Socket.SSL.Connect("127.0.0.1", 7789, SSLCfg{Domain: "k.example.it", AdditionRootCA: []string{cacrt}})
		for {
			sc.Send(Time.Strftime("%Y-%m-%d %H:%M:%S", Time.Now()))
			fmt.Println(sc.Recv(1024))
			Time.Sleep(1)
		}
	}
}

Socket.SSL.ServerWrapper

func main() {
	crt := `-----BEGIN CERTIFICATE-----
...
-----END CERTIFICATE-----`
	key := `-----BEGIN PRIVATE KEY-----
...
-----END PRIVATE KEY-----`
	cacrt := `-----BEGIN CERTIFICATE-----
...
-----END CERTIFICATE-----`

	if os.Args[1] == "s" {
		tl := Socket.TCP.Listen("0.0.0.0", 65432)
		tc := <-tl.Accept()

		buf := tc.Recv(10)
		Lg.Trace("Receive from TCP:", buf)

		sc := Socket.SSL.ServerWrapper(tc.Conn, key, crt)

		buf = sc.Recv(10)
		Lg.Trace("Receive from SSL:", buf)
	} else {
		tc := Socket.TCP.Connect("127.0.0.1", 65432)
		tc.Send("Hello TCP!")

		sc := Socket.SSL.ClientWrapper(
			tc.Conn,
			SSLCfg{
				WithoutSystemRootCA: true,
				AdditionRootCA:      []string{cacrt},
				Domain:              "k.example.it",
			})

		sc.Send("Hello SSL!")

		Time.Sleep(1)
	}
}

Socket.UDP

Connect

func main() {
	c := Socket.UDP.Connect("localhost", 8899)
	defer c.Close()
	c.Send("Hello World!")
	fmt.Println(c.Recv(1024))
}

Listen

func main() {
	c := Socket.UDP.Listen("0.0.0.0", 8899)
	defer c.Close()
	data, addr := c.Recvfrom(1024)
	fmt.Println(data)
	c.Sendto("You are welcome!", addr)
}

Argparser

• -b在后台执行
• -c指定配置文件, 如果没有指定, 会寻找二进制目录下的配置文件, 以及当前工作目录下的配置文件, 查找规则例如二进制文件名字为app, 则查找app.ini文件
• -h查看帮助, 可以直接在命令行指定
• 可以通过环境变量指定, 指定的名字参考命令行方式
• 参数读取优先级, 首先命令行指定, 其次环境变量, 然后读配置文件, 如果都没有, 就使用内置的默认值

type arg struct {
	InCluster      bool
	ConfigFile     string
	Namespace      string
	TelegramAPIKey string
	TelegramChatID int64
}

func main() {
	args := new(arg)
	a := Argparser("kubernetes的pod程序崩溃通知程序")
	args.InCluster = a.GetBool("", "InCluster", "false", "是否在集群内部, 如果不在集群内部需要指定config文件")
	args.ConfigFile = a.Get("", "ConfigFile", "", "如果不在集群内部, 需要指定配置文件")
	args.Namespace = a.Get("", "Namespace", "", "需要监听事件的namespace, 逗号分割, 默认为空, 即监听所有")
	args.TelegramAPIKey = a.Get("", "TelegramAPIKey", "", "telegram bot的api key")
	args.TelegramChatID = a.GetInt64("", "TelegramChatID", "0", "telegram bot需要发送通知到的group或者channel的id")
	a.ParseArgs()
}

Json.XPath

package main

import (
	"fmt"
	"strings"
)

func main() {
	s := `{
		"name": "John",
		"age"      : 26,
		"address"  : {
		  "streetAddress": "naist street",
		  "city"         : "Nara",
		  "postalCode"   : "630-0192"
		},
		"phoneNumbers": [
		  {
			"type"  : "iPhone",
			"number": "0123-4567-8888"
		  },
		  {
			"type"  : "home",
			"number": "0123-4567-8910"
		  }
    	],
		"brothers": [
			"john",
			"jack",
		]
    	"nullvalue": null
	}`
	x := Json.XPath(s)
	name := x.First("//name").Text()
	fmt.Printf("Name: %s\n", name)

	var a []string
	for _, n := range x.Find("//phoneNumbers/*/number") {
		a = append(a, n.Text())
	}
	fmt.Printf("All phone number: %s\n", strings.Join(a, ","))

	if n := x.First("//address/streetAddress"); n != nil {
		fmt.Printf("address: %s\n", n.Text())
	}

	for _, b := range j.Find("//brothers/*") {
		Print(b.Text())
	}

  fmt.Println("First phone number:", x.First("//phoneNumbers[1]/*/number").Text()) // 这里有个*, 因为数组的话会额外加一个元素element在xml里面, 去包含
  
  Lg.Debug(x.First("//nullvalue").Text()) // ""
}

输出

Name: John
All phone number: 0123-4567-8888,0123-4567-8910
address: naist street
First phone number: 0123-4567-8888

Tools.GodaddyDNS

func main() {
	gd := Tools.GodaddyDNS("333", "222")
	Print(gd.List())                                  // 获取域名列表
	dm := gd.Domain("yletx.com")                      // 处理单个主域名
	dm.Add("googledns", "A", "8.8.8.8")               // 增
	dm.Add("googledns_cname", "CNAME", "twitter.com") // 增
	dm.Add("googledns_txt", "TXT", "by twitter")      // 增
	dm.Delete("googledns")                            // 删，需要传入名称、类型、值，如果传入空字符串则忽略这一项目的判断
	dm.Modify("googledns", "A", "1.1.1.1")            // 改
	Print(dm.List())                                  // 查
}

Tools.CloudflareDNS

整体来说, 操作接口跟godaddy的没什么区别, 是多了一个添加域名, 以及是否开启cdn. 返回的域名的列表, 信息没有godaddy的多.

package main

func main() {
	cf := Tools.CloudflareDNS("ip5lwomzy87ohjuoacfzvqup591ipsqi", "example@gmail.com")

	// 添加cloudflare还没有接管的域名
	cf.Add("example.com")

	Lg.Trace("获取域名列表")
	for _, i := range cf.List() {
		if i.Status == "active" {
			Print(i)
			break
		}
	}

	dm := cf.Domain("example.com")

	Lg.Trace("获取域名的记录列表")
	for _, i := range dm.List() {
		Print(i)
	}

	Lg.Trace("添加dns记录")
	dm.Add("@", "A", "8.8.8.8")
	dm.Add("arecord", "a", "7.7.7.7")
	dm.Add("cnamerecord", "cname", "google.com")
	dm.Add("txtrecord", "txt", "this is a text")

	Lg.Trace("删除所有a记录")
	dm.Delete("", "a", "")

	Lg.Trace("修改指定a记录")
	dm.Add("@", "A", "8.8.8.8")
	Time.Sleep(5) // 连续添加, 后面这个会加不上, 不知道休眠多少秒, 就随便5秒吧
	dm.Add("@", "A", "6.6.6.6")
	dm.Add("arecord", "a", "7.7.7.7")
	// 修改指定a记录
	dm.Modify("@", "a", "8.8.8.8", "a", "5.5.5.5")

	Lg.Trace("设置开启cdn")
	dm.SetProxied("@", true)

	Lg.Trace("删除所有记录")
	dm.Delete("", "", "")
}

Open

func main() {
	for line := range Open("/etc/passwd").Readlines() { // 返回一个chan, for循环处理
		fmt.Println(line) // 要循环完，才会close，所以不要在这里面break
	}

	fd := Open("/etc/passwd") // 默认打开模式是r
	defer fd.Close()
	fmt.Println(fd.Readline()) // 打印一行， 需要手动调用close
	fmt.Println(fd.Readline()) // 再打印一行， 需要手动调用close
	fmt.Println(fd.Read(10))   // 打印10个字符， 需要手动调用close
	fmt.Println(fd.Read())     // 打印所有, 会自动close

	fd = Open("text.txt", "w") // 以写方式打开文件
	defer fd.Close()
	fd.Write("this is a test text")
	fd.Close()

	fd = Open("text.txt", "rb") // 二进制打开，read函数返回字节数组
	defer fd.Close()
	fmt.Println(fd.Read(5))

	fd = Open("text.txt", "a") // 以追加写方式打开文件
	defer fd.Close()
	fd.Write(" append text 中文")
	fd.close()
}

Try

func main() {
	Try(func() {
		Bool("abc")
	}).Except(func(err error) {
		fmt.Println(err)
	})
}

Note

Func.Sniffer和Func.ReadPcapFile需要编译的时候加tag: pcap, 以及只处理TCP和UDP数据包.

$ go build -tags pcap .