protoevent

ProtoEvent é uma biblioteca de manipulação de conexões TCP baseada em eventos em Golang. É simples e não explora muito a funcionalidade básica de fazer uma nova conexão de protocolo. ProtoEvent reimplementa a interface net.Listener e net.Conn para ter capacidade estendida de capturar vários eventos que aconteceram na comunicação de rede.

Fundo

Já é doloroso o suficiente quando você precisa cuidar de uma base de código de aplicativo de rede simples que não está bem organizada e acaba produzindo mais código espaguete. Pelo menos agora podemos organizar lógicas de aplicativos com base em um determinado evento de rede.

Instalação

 go get -u https://github.com/parinpan/protoevent

Demonstração

Exemplos

Aplicativo do lado do servidor:

 package main

import (
	"encoding/json"
	"fmt"
	"net"

	"github.com/parinpan/protoevent"
)

type Message struct {
	From string `json:"from"`
}

func main () {
	servant , event , err := protoevent . CreateServant ( "tcp" , "0.0.0.0:8089" )

	if nil != err {
		panic ( err )
	}

	event . OnConnectionError ( func ( err error ) {
	
	})

	event . OnConnectionAccepted ( func ( conn net. Conn ) {
		fmt . Println ( "Accepting new connection: " , conn . RemoteAddr ())
	})

	event . OnConnectionClosed ( func ( conn net. Conn ) {
	
	})

	event . OnReceiveMessageError ( func ( conn net. Conn , err error ) {
	
	})

	event . OnMessageReceived ( func ( conn net. Conn , message [] byte , rawMessage [] byte ) {
		fmt . Println ( "Received a message: " , string ( message ))
		
		var msg Message
		_ = json . Unmarshal ( message , & msg )
		
		// send a message back to client
		sayHiMessage := fmt . Sprint ( "Hi " , msg . From , ". Welcome to ProtoEvent!" )
		conn . Write ([] byte ( sayHiMessage ))
	})

	event . OnSendMessageError ( func ( conn net. Conn , message [] byte , err error ) {
	
	})

	event . OnMessageSent ( func ( conn net. Conn , message [] byte ) {
		fmt . Println ( "Sent a message: " , string ( message ))
	})

	servant . SetDefaultReadSize ( 4096 ) // set default read size per chunk in bytes
	servant . Serve ()
}

Aplicação do lado do cliente:

 package main

import (
	"fmt"
	"net"

	"github.com/parinpan/protoevent"
)

func main () {
	agent , event := protoevent . CreateAgent ( "tcp" , "0.0.0.0:8089" )
	agent . SetDefaultReadSize ( 4096 ) // set default read size per chunk in bytes

	event . OnConnectionError ( func ( err error ) {

	})

	event . OnConnectionAccepted ( func ( conn net. Conn ) {
		fmt . Println ( "Accepting new connection: " , conn . RemoteAddr ())
	})

	event . OnConnectionClosed ( func ( conn net. Conn ) {

	})

	event . OnReceiveMessageError ( func ( conn net. Conn , err error ) {

	})

	event . OnMessageReceived ( func ( conn net. Conn , message [] byte , rawMessage [] byte ) {
		fmt . Println ( "Received a message: " , string ( message ))
	})

	event . OnSendMessageError ( func ( conn net. Conn , message [] byte , err error ) {

	})

	event . OnMessageSent ( func ( conn net. Conn , message [] byte ) {
		fmt . Println ( "Sent a message: " , string ( message ))
	})

	// trigger a message to get connected with the server at first
	err := agent . Run ( func ( conn net. Conn ) error {
		_ , err := conn . Write ([] byte ( `{"from": "AgentV1"}` ))
		return err
	})

	if nil != err {
		panic ( err )
	}
}

Entre em contato comigo

Se você tiver alguma dúvida. Você pode me acompanhar:

• Linkedin
• Twitter
• Instagram
• E-mail