MasterClient.go

package staff

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

	"saseul/config"
	"saseul/ipc"
)

// MasterClient 구조체는 마스터 서버와 통신하기 위한 클라이언트입니다.
type MasterClient struct {
	client *ipc.TCPClient
	mu     sync.Mutex
}

var instance *MasterClient
var once sync.Once

// Instance 함수는 MasterClient의 싱글톤 인스턴스를 반환합니다.
// 인스턴스가 존재하지 않으면 새로운 인스턴스를 생성하고 연결을 설정합니다.
func Instance() *MasterClient {
	once.Do(func() {
		instance = &MasterClient{
			client: ipc.NewTCPClient(),
		}
		instance.connect()
	})
	return instance
}

// connect 함수는 마스터 서버에 TCP 연결을 설정합니다.
func (mc *MasterClient) connect() {
	mc.client.Connect(config.MasterAddr, config.MasterPort)
}

// Send 함수는 마스터 서버에 명령을 보내고 응답을 받습니다.
// 동기화된 접근을 보장하기 위해 뮤텍스를 사용합니다.
// 클라이언트가 연결되어 있지 않으면 연결을 다시 설정합니다.
// 명령을 생성하고 전송한 후 응답을 반환합니다.
func (mc *MasterClient) Send(commandType string, data interface{}) (string, error) {
	mc.mu.Lock()
	defer mc.mu.Unlock()

	if !mc.client.IsConnected() {
		mc.connect()
	}

	command := ipc.NewTCPCommand(commandType, data)
	response, err := mc.client.Send(command)
	if err != nil {
		return "", err
	}

	return response, nil
}

코드 설명

이 코드는 MasterClient라는 구조체를 정의하고 이를 통해 마스터 서버와 통신할 수 있는 클라이언트 기능을 제공합니다. 이 구조체는 ipc 패키지를 사용하여 TCP 연결을 관리하고, 마스터 서버에 명령을 보내고 응답을 받습니다. 싱글톤 패턴을 사용하여 MasterClient의 인스턴스를 관리합니다.

주요 구조체와 함수 설명

구조체: MasterClient

• MasterClient 구조체는 마스터 서버와 통신하기 위한 클라이언트입니다.

• 필드:

  • client: ipc.TCPClient 타입의 클라이언트 인스턴스입니다.

  • mu: 동기화된 접근을 보장하기 위한 뮤텍스입니다.

변수: instance와 once

• instance: MasterClient의 싱글톤 인스턴스를 저장하는 변수입니다.

• once: sync.Once 타입의 변수로, MasterClient 인스턴스가 한 번만 초기화되도록 보장합니다.

함수: Instance

• Instance 함수는 MasterClient의 싱글톤 인스턴스를 반환합니다.

• 인스턴스가 존재하지 않는 경우 once.Do를 통해 인스턴스를 초기화하고 connect 함수를 호출합니다.

func Instance() *MasterClient {
	once.Do(func() {
		instance = &MasterClient{
			client: ipc.NewTCPClient(),
		}
		instance.connect()
	})
	return instance
}

메서드: connect

• connect 메서드는 마스터 서버에 TCP 연결을 설정합니다.

func (mc *MasterClient) connect() {
	mc.client.Connect(config.MasterAddr, config.MasterPort)
}

메서드: Send

• Send 메서드는 마스터 서버에 명령을 보내고 응답을 받습니다.

• 뮤텍스를 사용하여 동기화된 접근을 보장합니다.

• 클라이언트가 연결되어 있지 않으면 connect 메서드를 호출하여 연결을 설정합니다.

• ipc.NewTCPCommand를 사용하여 명령을 생성하고, mc.client.Send를 통해 명령을 전송한 후 응답을 반환합니다.

func (mc *MasterClient) Send(commandType string, data interface{}) (string, error) {
	mc.mu.Lock()
	defer mc.mu.Unlock()

	if !mc.client.IsConnected() {
		mc.connect()
	}

	command := ipc.NewTCPCommand(commandType, data)
	response, err := mc.client.Send(command)
	if err != nil {
		return "", err
	}

	return response, nil
}

코드 요약

이 코드는 MasterClient 구조체를 통해 마스터 서버와 통신하는 기능을 제공합니다. 싱글톤 패턴을 사용하여 MasterClient 인스턴스를 관리하며, TCP 연결을 설정하고 명령을 전송하고 응답을 받는 기능을 포함합니다. 동기화를 위해 뮤텍스를 사용하여 여러 고루틴에서 안전하게 접근할 수 있도록 보장합니다.

코드 설명

1. MasterClient 구조체:

   • 마스터 서버와의 통신을 담당하며, client 필드로 ipc.TCPClient 인스턴스를 가지고 있습니다.

   • mu는 동시성 제어를 위한 뮤텍스입니다.

2. 싱글톤 인스턴스:

   • instance와 once를 사용하여 MasterClient의 싱글톤 인스턴스를 관리합니다.

   • Instance 함수는 MasterClient의 싱글톤 인스턴스를 반환합니다. 인스턴스가 없으면 새로운 인스턴스를 생성하고, connect 메서드를 호출하여 마스터 서버와의 연결을 설정합니다.

3. connect 메서드:

   • 마스터 서버와의 연결을 설정합니다. config.MasterAddr와 config.MasterPort를 사용하여 연결을 설정합니다.

4. Send 메서드:

   • commandType과 data를 받아서 마스터 서버로 전송하고 응답을 반환합니다.

   • 메서드 실행 중에는 뮤텍스를 잠금으로 설정하여 동시 접근을 제어합니다.

   • 연결이 끊어져 있으면 connect 메서드를 호출하여 다시 연결을 설정합니다.

   • ipc.NewTCPCommand를 사용하여 명령을 생성하고, mc.client.Send를 통해 전송합니다.

   • 응답을 문자열로 반환하며, 오류가 발생하면 오류를 반환합니다.