protoevent

ProtoEvent est une bibliothèque de gestion de connexion TCP basée sur les événements dans Golang. C'est simple et n'exploite pas trop la fonctionnalité de base consistant à établir une nouvelle connexion protocolaire. ProtoEvent réimplémente les interfaces net.Listener et net.Conn pour avoir une capacité étendue de capture de divers événements survenus dans la communication réseau.

Arrière-plan

C'est déjà assez pénible lorsque vous devez vous occuper de la base de code de votre application réseau simple qui n'est pas bien organisée et qui finit par produire plus de code spaghetti. Au moins, nous sommes désormais capables d'organiser des logiques d'application basées sur un certain événement réseau.

Installation

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

Démo

Exemples

Application côté serveur :

 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 ()
}

Application côté client :

 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 )
	}
}

Contactez-moi

Si vous avez des questions. Vous pouvez me rattraper sur :

• Linkedin
• Gazouillement
• Instagram
• E-mail