Golang项目中可能常用到的工具库

邮件发送

# install the package
$ go get -v github.com/goops-top/utils/mail

# update the mail data
$ cat test-mail.go

package main

import (
	"fmt"

	"github.com/goops-top/utils/mail"
)

func main() {
	maildata := &mail.EmailMetaData{
		Smtp:        "smtp.qq.com",
		From:        "[email protected]",
		Pass:        "passwoed",
		To:          []string{"[email protected]"},
		Cc:          []string{"[email protected]"},
		Subject:     "test",
		ContentType: "text",
		Content:     []byte("hahahah"),
	}
	emailErr := maildata.PostEmail()
	if emailErr != nil {
		fmt.Printf("邮件发送失败:%v\n", emailErr)
	} else {
		fmt.Println("邮件已发送")
	}

}


# test mail
$ go run test-mail.go
邮件已发送

kafka

$ go get -v github.com/goops-top/utils/kafka

$ cat consumer.go
package main 
import (
    "os/signal"
    "syscall"
    "os"

    "github.com/goops-top/utils/kafka"
    log "github.com/sirupsen/logrus"
)


func main() {

	brokers := []string{"127.0.0.1:9092"}
	consumerApi := kafka.NewConsumerApi(brokers,"consumerGroup","latest")

	defer consumerApi.Close()

	c := consumerApi.ConsumerMsgFromTopics("topicName")

	sigterm := make(chan os.Signal, 1)
	signal.Notify(sigterm, syscall.SIGINT, syscall.SIGTERM)
	select {
	case <-sigterm:
		log.Warnln("terminating: via signal")
	}
	c()


}