패킷 헤더 클래스 [StructLayout(LayoutKind.Sequential)]//[StructLayout(LayoutKind.Sequential, Pack=1)] public class HEADER { public ushort a1; public ushort a2; public ushort a3; public ushort a4; } 로그인 요청 클래스 // GetBuffer을 부모 클래스에서 정의하고 여기서는 상속 받지 않은 이유는 그렇게 하면 클래스의 // 데이타를...
더 읽기
서버 package main import ( "bufio" "fmt" "log" "net" "os" ) func main() { if len(os.Args) != 2 { log.Fatalf("Usage: %s <port>\n", os.Args[0]) } port := os.Args[1] server := NewServer(port) server.ListenAndServe() } type message string type Server struct { port...
더 읽기
클라이언트 관리를 채널 별로 나누어서 처리. distribute 라는 함수를 고루틴으로 동작시키고, 내부에서 채널을 통해서 메시지를 받는다. 클라이언트 접속, 클라이언트 접속 해제, 클라이언트에게 메시지 보내기 채널을 나눈다. 고루틴은 handle, distribute(메시지 보내기 채널을 호출하는 고루틴이 있음) 서버 package main import ( "bufio"...
더 읽기
출처 Graceful Shutdown main.go package main import ( "context" "log" "os" "os/signal" "syscall" "github.com/dmmlabo/tcpserver_go/tcp5/server" ) func main() { chSig := make(chan os.Signal, 1) // Ignore all signals signal.Ignore() signal.Notify(chSig, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT, syscall.SIGHUP) host := loadConf() svr := server.NewServer(context.Background(), host)...
더 읽기
출처 비동기 Write main.go package main import ( "context" "log" "os" "os/signal" "syscall" "github.com/dmmlabo/tcpserver_go/tcp4/server" ) func main() { sigChan := make(chan os.Signal, 1) // Ignore all signals signal.Ignore() signal.Notify(sigChan, syscall.SIGINT) svr := server.NewServer(context.Background(), "127.0.0.1:12345") err := svr.Listen() if err !=...
더 읽기
출처 server 패키지 만들기 struct를 이용한다. handleConnection에서 사용하는 속성을 Server 구조체, handleConnection에서 사용하는 속성을 Conn 구조체에 정리한다. main.go package main import ( "context" "log" "os" "os/signal" "syscall" "github.com/dmmlabo/tcpserver_go/tcp3/server" ) func main() { sigChan := make(chan os.Signal, 1) // Ignore all...
더 읽기
출처 서버 종료하기 package main import ( "context" "log" "net" "os" "os/signal" "strings" "sync" "syscall" ) const ( listenerCloseMatcher = "use of closed network connection" ) func handleConnection(conn *net.TCPConn, serverCtx context.Context, wg *sync.WaitGroup) { defer func() { conn.Close() wg.Done() }()...
더 읽기
출처 Echo Server 예제 코드 package main import ( "log" "net" ) func handleConnection(conn *net.TCPConn) { defer conn.Close() buf := make([]byte, 4*1024) for { n, err := conn.Read(buf) if err != nil { if ne, ok := err.(net.Error); ok {...
더 읽기
원문 C++의 표준 라이브러리로만 구현(thread, chrono, mutex, atomic, queue) 성능보다 구성 요소의 작음을 우선 소스 actor 모델? actor 모델은 병렬 계산의 수학적 모델의 일종이다. 병렬 처리 지향이라는 Erlang과 함수형 언어 Scala에서도 사용되고 있다. 어떤 actor 객체는 동시에 하나의(스레드, 프로세스, PC)상에서...
더 읽기
Redis 서버의 흔한 실수 법 Redis 서버가 떨어지거나 APP서버가 떨어질지는 상황에 따른다. KEYS 명령과 ZRANGE 명령으로 수만건 이상에 접근하여 I/O대기로 죽는다 데이터 설계를 실패하여 메모리 부족으로 쓸 수 없게 되어 죽는다 Redis 서버에서 장애 발생 시의 기본 대응 우선 메모리...
더 읽기
