Microsoft MVP성태의 닷넷 이야기
VC++: 150. Golang - TCP client/server echo 예제 코드 [링크 복사], [링크+제목 복사],
조회: 14679
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일

Golang - TCP client/server echo 예제 코드


서버 측 코드와,

package main

import (
    "io"
    "log"
    "net"
    "strconv"
    "strings"
    "time"
)

func main() {
    sock, err := net.Listen("tcp", ":18080")
    if err != nil {
        log.Fatalf("Failed to bind address: %v", err)
    }
    
    defer sock.Close()
    
    for {
        conn, err := sock.Accept()
        if err != nil {
            log.Printf("Failed to accept: %v", err)
            continue
        }
        
        go ClientHandler(conn)
    }
}

func ClientHandler(conn net.Conn) {
    defer conn.Close()

    recvBuf := make([]byte, 4096)

    for {

        readBytes, err := conn.Read(recvBuf)
        if err != nil {
            if err == io.EOF {
                log.Printf("Client closed the socket: %v", conn.RemoteAddr().String())
                return
            }

            log.Printf("Failed to receive data: %v", err)
            return
        }

        if readBytes > 0 {
            data := recvBuf[:readBytes]

            if number, err := strconv.Atoi(strings.Trim(string(data), string('\n'))); err == nil {
                time.Sleep(time.Duration(number) * time.Second)
            }

            conn.Write(data)

            log.Println(string(data))
        } else {
            log.Println("Can you see me?")
        }

    }
}

클라이언트 측 예제 코드입니다.

package main

import (
    "bufio"
    "fmt"
    "io"
    "log"
    "net"
    "os"
    "strconv"
    "strings"
)

func main() {
    socket, err := net.Dial("tcp", "localhost:18080")
    if err != nil {
        log.Fatalf("Failed to connect to server: %v", err)
        return
    }

    defer socket.Close()
    console := bufio.NewReader(os.Stdin)
    recvBuf := make([]byte, 4096)

    for {
        fmt.Print("socket> ")
        text, _ := console.ReadString('\n')

        if number, err := strconv.Atoi(strings.Trim(string(text), string('\n'))); err == nil {
            fmt.Printf("Echo delayed: %v\n", number)
        }

        if text == "quit\n" {
            break
        }
        socket.Write([] byte(text))

        readBytes, err := socket.Read(recvBuf)
        if err != nil {
            if err == io.EOF {
                fmt.Printf("Server closed the socket: %v", socket.RemoteAddr().String())
                return
            }

            fmt.Printf("Failed to receive data: %v", err)
            return
        }

        if readBytes > 0 {
            data := recvBuf[:readBytes]
            fmt.Println(string(data))
        } else {
            fmt.Println("Can you see me?")
        }
    }
}

실행하면, 서버와 클라이언트의 출력이 각각 다음과 같은 식으로 나옵니다.

[서버 측]
2021/09/03 15:39:10 test

2021/09/03 15:39:12 qwer

2021/09/03 15:39:18 5

2021/09/03 15:39:23 Client closed the socket: [::1]:1264


[클라이언트 측] socket> test test socket> qwer qwer socket> 5 Echo delayed: 5 5 socket> quit Debugger finished with the exit code 0




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]







[최초 등록일: ]
[최종 수정일: 9/6/2021]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 




1  2  3  [4]  5  6  7  8  9  10  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
13887정성태2/17/20255849닷넷: 2320. Blazor의 razor 페이지에서 code-behind 파일로 코드를 분리 및 DI 사용법
13886정성태2/15/20254131VS.NET IDE: 196. Visual Studio - Code-behind처럼 cs 파일을 그룹핑하는 방법
13885정성태2/14/20255737닷넷: 2319. ASP.NET Core Web API / Razor 페이지에서 발생할 수 있는 async void 메서드의 부작용
13884정성태2/13/20256091닷넷: 2318. C# - (async Task가 아닌) async void 사용 시의 부작용파일 다운로드1
13883정성태2/12/20255801닷넷: 2317. C# - Memory Mapped I/O를 이용한 PCI Configuration Space 정보 열람파일 다운로드1
13882정성태2/10/20254096스크립트: 70. 파이썬 - oracledb 패키지 연동 시 Thin / Thick 모드
13881정성태2/7/20254494닷넷: 2316. C# - Port I/O를 이용한 PCI Configuration Space 정보 열람파일 다운로드1
13880정성태2/5/20255945오류 유형: 947. sshd - Failed to start OpenSSH server daemon.
13879정성태2/5/20255837오류 유형: 946. Ubuntu - N: Updating from such a repository can't be done securely, and is therefore disabled by default.
13878정성태2/3/20255695오류 유형: 945. Windows - 최대 절전 모드 시 DRIVER_POWER_STATE_FAILURE 발생 (pacer.sys)
13877정성태1/25/20254977닷넷: 2315. C# - PCI 장치 열거 (레지스트리, SetupAPI)파일 다운로드1
13876정성태1/25/20256091닷넷: 2314. C# - ProcessStartInfo 타입의 Arguments와 ArgumentList파일 다운로드1
13875정성태1/24/20254515스크립트: 69. 파이썬 - multiprocessing 패키지의 spawn 모드로 동작하는 uvicorn의 workers
13874정성태1/24/20255771스크립트: 68. 파이썬 - multiprocessing Pool의 기본 프로세스 시작 모드(spawn, fork)
13873정성태1/23/20254350디버깅 기술: 217. WinDbg - PCI 장치 열거파일 다운로드1
13872정성태1/23/20253988오류 유형: 944. WinDbg - 원격 커널 디버깅이 연결은 되지만 Break (Ctrl + Break) 키를 눌러도 멈추지 않는 현상
13871정성태1/22/20254582Windows: 278. Windows - 윈도우를 다른 모니터 화면으로 이동시키는 단축키 (Window + Shift + 화살표)
13870정성태1/18/20255620개발 환경 구성: 741. WinDbg - 네트워크 커널 디버깅이 가능한 NIC 카드 지원 확대
13869정성태1/18/20254696개발 환경 구성: 740. WinDbg - _NT_SYMBOL_PATH 환경 변수에 설정한 경로로 심벌 파일을 다운로드하지 않는 경우
13868정성태1/17/20254253Windows: 277. Hyper-V - Windows 11 VM의 Enhanced Session 모드로 로그인을 할 수 없는 문제
13867정성태1/17/20256251오류 유형: 943. Hyper-V에 Windows 11 설치 시 "This PC doesn't currently meet Windows 11 system requirements" 오류
13866정성태1/16/20256653개발 환경 구성: 739. Windows 10부터 바뀐 device driver 서명 방법
13865정성태1/15/20255909오류 유형: 942. C# - .NET Framework 4.5.2 이하의 버전에서 HttpWebRequest로 https 호출 시 "System.Net.WebException" 예외 발생
13864정성태1/15/20255909Linux: 114. eBPF를 위해 필요한 SELinux 보안 정책
13863정성태1/14/20254492Linux: 113. Linux - 프로세스를 위한 전용 SELinux 보안 문맥 지정
13862정성태1/13/20255091Linux: 112. Linux - 데몬을 위한 SELinux 보안 정책 설정
1  2  3  [4]  5  6  7  8  9  10  11  12  13  14  15  ...