protoevent

ProtoEvent는 Golang의 이벤트 기반 TCP 연결 처리 라이브러리입니다. 이는 간단하며 새로운 프로토콜 연결을 만드는 기본 기능을 너무 많이 활용하지 않습니다. ProtoEvent는 네트워크 통신에서 발생한 다양한 이벤트를 캡처하는 기능을 확장하기 위해 net.Listener 및 net.Conn 인터페이스를 다시 구현합니다.

배경

잘 정리되지 않은 단순한 네트워크 애플리케이션 코드베이스를 관리해야 할 때 결국 더 많은 스파게티 코드를 생성하게 되면 충분히 고통스럽습니다. 적어도 이제는 특정 네트워크 이벤트를 기반으로 애플리케이션 로직을 구성할 수 있습니다.

설치

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

데모

예

서버측 애플리케이션:

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

클라이언트측 애플리케이션:

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

저에게 연락하세요

문의사항이 있으시면 다음에서 저를 따라잡을 수 있습니다:

• 링크드인
• 지저귀다
• 인스타그램
• 이메일