콘텐츠로 이동

설치와 첫 연결

목차 | 이전: Stream Connector 개요 | 다음: Connector 옵션

다른 언어로 보기 — C++ · C#/.NET · Java · Kotlin · Node/TypeScript

이 장을 읽고 나면

connector package를 프로젝트에 추가하고, 서버에 연결해 첫 packet을 주고받을 수 있다. 이 장의 연결 코드는 framework/languages/cpp/tutorial/StreamClient에서 그대로 실행된다.

connector는 서버 framework와 별도로 배포되므로, client project는 connector package 하나만 참조한다. 이 장은 설치부터 첫 응답까지를 한 번에 따라 한다. 옵션 전체와 기본값은 Connector 옵션이 다룬다.

1. 설치

vcpkg install "zlink-stream-connector[tls,websocket]"

find_package(zlink-stream-connector CONFIG REQUIRED)

target_link_libraries(my_game PRIVATE zlink::stream_connector)

2. 연결과 첫 request

connector는 endpoint와 timeout을 담은 option으로 만든다. 연결이 끝나야 packet을 보낼 수 있으므로 연결을 먼저 기다린다. request는 서버 응답이 도착할 때까지 기다린 뒤 응답 payload를 돌려준다.

// A game client outside the mesh. It references the connector only, never
// the Framework, and speaks to the port the stream node opened. Every call
// here is the connector's blocking form.
sc::connector_options_t options;
options.typed_codec = sc::json_typed_codec ();
options.endpoint = "tcp://127.0.0.1:7421";
options.connect_timeout = std::chrono::seconds (5);
options.request_timeout = std::chrono::seconds (5);
options.wait_timeout = std::chrono::seconds (5);
options.dispatch_mode = sc::dispatch_mode_t::immediate;

auto connector = sc::connector_factory_t::create (options);

require (connector.connect (), "connect");
std::cout << "connected: " << std::boolalpha << connector.is_connected () << std::endl;

// A request waits for its reply. Use send for one-way traffic; the server
// then answers with write_packet rather than reply_packet.
const auto sent_at = now_unix_ms ();
const auto pong = value_of (
  connector.request (ping_t{std::to_string (sent_at)}).submit<pong_t> (), "ping");

std::cout << "round trip: " << (now_unix_ms () - std::stoll (pong.sent_at_unix_ms)) << "ms"
          << std::endl;

브라우저 계열 client는 ws://로 붙는다

네이티브 빌드는 tcp://·tls://·ws://·wss://를 모두 사용한다. 브라우저 계열은 OS 소켓을 열 수 없으므로 ws://나 wss://만 사용하며, 서버 쪽 endpoint도 같은 scheme이어야 한다.

3. 실행 결과

아래 명령은 tutorial(framework/languages/cpp/tutorial)의 Server를 그 README의 「실행」 절대로 띄운 상태에서 StreamClient를 실행한다. StreamClient는 Server의 stream endpoint에 연결한다.

dotnet run --project StreamClient/StreamClient.csproj
# connected: True
# round trip: 56ms

connected가 참이면 연결이 맺어진 것이다. 왕복 시간은 client가 보낸 시각을 서버가 그대로 돌려주어 잰 값이다.

4. 응답이 필요 없는 송신

응답을 기다리지 않는 packet은 send로 보낸다. 종결자를 호출해야 실제로 전송이 시작되고, 종결자는 전송이 실패하면 그 사실만 전달한다. 서버가 무엇을 했는지 알아야 하면 request를 사용한다.

connector.send (chat_message_t{"room-42", "hello"})
  .packet_name ("chat.send")   // 생략하면 payload 타입에서 이름을 정한다
  .submit ();

5. 서버가 먼저 보내는 packet 받기

서버가 먼저 보내는 packet은 handler를 등록해 받는다. 등록하면 해제할 수 있는 값이 돌아오고, 그 값이 살아 있는 동안 handler가 유지된다. 기본 설정에서는 handler가 수신 시점에 바로 실행되지 않고, application이 pump를 호출한 실행 문맥에서 실행된다. 게임 loop라면 frame마다 한 번 호출한다.

auto subscription = connector.on<leaderboard_update_t> (
  [] (const sc::message_t<leaderboard_update_t> &message) {
      std::cout << message.payload.rank << std::endl;
  });

while (running) {
    connector.dispatch ();   // 쌓여 있던 handler를 실행하고 돌아온다
    render_frame ();
}

6. 다음 장