Elixir에서 웹소켓을 사용하는 방법은?

Q1: Elixir에서 웹소켓을 사용하려면 어떤 라이브러리를 사용할 수 있나요?
A1: Elixir와 Phoenix 프레임워크에서는 기본적으로 `Phoenix.Socket` 모듈을 사용해 웹소켓을 구현합니다. Phoenix를 사용하지 않는 경우에는 `cowboy` 웹서버의 웹소켓 지원 기능이나 `websockex`, `neotoma` 같은 라이브러리를 활용할 수 있습니다.

Q2: Phoenix에서 웹소켓 채널(Channel)을 어떻게 생성하나요?
A2:
1. `lib/your_app_web/channels/` 디렉토리에 새로운 채널 모듈을 생성합니다. 예: `room_channel.ex`
2. 모듈에 `use Phoenix.Channel`을 선언합니다.
3. `join/3` 콜백에서 클라이언트의 채널 참여를 처리합니다.
4. `handle_in/3` 콜백에서 클라이언트 메시지를 처리하고 브로드캐스트할 수 있습니다.

예시:
```elixir
defmodule YourAppWeb.RoomChannel do
use Phoenix.Channel

def join("room:lobby", _payload, socket) do
{:ok, socket}
end

def handle_in("new_msg", %{"body" => body}, socket) do
broadcast!(socket, "new_msg", %{body: body})
{:noreply, socket}
end
end
```

Q3: 웹소켓을 라우터에 어떻게 연결하나요?
A3: `lib/your_app_web/endpoint.ex` 파일의 `socket` 매크로에서 경로와 채널 모듈을 지정합니다.
예:
```elixir
socket "/socket", YourAppWeb.UserSocket,
websocket: true,
longpoll: false
```

그리고 `user_socket.ex`에서 채널을 정의합니다.
```elixir
channel "room:*", YourAppWeb.RoomChannel
```

Q4: 클라이언트에서 Phoenix 웹소켓에 연결하려면?
A4: Phoenix는 JavaScript 클라이언트 라이브러리를 제공합니다.
1. `assets/js/socket.js`에서 Phoenix Socket을 import 합니다. 2. `let socket = new Socket("/socket", {params: {userToken: "..."}})` 로 소켓을 생성합니다.
3. `socket.connect()`를 호출해 연결합니다.
4. `let channel = socket.channel("room:lobby", {})`로 채널에 참여합니다.
5. `channel.join()`으로 서버와 통신을 시작합니다.

Q5: 웹소켓을 통한 메시지 송수신 방법은?
A5:
- 서버에서는 `handle_in/3` 콜백에서 클라이언트 메시지를 받고 처리할 수 있습니다.
- 서버는 `broadcast!/3` 또는 `push/3`로 메시지를 클라이언트에 보냅니다.
- 클라이언트는 채널에서 `channel.push("event", payload)`로 메시지를 보내고, `channel.on("event", callback)`으로 서버 메시지를 받습니다.

Q6: Phoenix가 아닌 일반 Elixir 프로젝트에서 웹소켓을 쓸 때는?
A6: Phoenix 없이 순수 Elixir 환경에서는 다음과 같이 할 수 있습니다.
- `:cowboy` 웹서버를 직접 설정하여 웹소켓 핸들러를 구현
- `websockex` 라이브러리를 사용해 웹소켓 클라이언트 구현
- 직접 OTP GenServer를 사용해 이벤트 관리

Q7: 웹소켓 연결 유지 및 재접속 전략은?
A7: Phoenix JS 클라이언트는 기본적으로 재연결(reconnect) 기능을 내장합니다.
- 재접속 시간 간격(incremental backoff)을 자동 적용합니다.
- 필요 시 클라이언트에서 직접 `socket.connect()`를 재호출하거나, `socket.onError`와 `socket.onClose` 이벤트에서 재연결 로직을 구현할 수 있습니다.

Q8: 웹소켓 보안은 어떻게 확보하나요?
A8:
- HTTPS 및 WSS(WebSocket Secure) 프로토콜을 사용하세요.
- Phoenix에서 토큰 기반 인증(`Phoenix.Token`)을 이용해 클라이언트 인증을 수행합니다.
- `UserSocket` 모듈의 `connect/3` 콜백에서 인증 로직을 작성해 유효하지 않은 연결을 차단합니다.

Q9: 웹소켓에서 상태 관리는 어떻게 하나요?
A9:
- 각 웹소켓 접속은 `socket.assigns`를 통해 상태를 저장할 수 있습니다.
- 백그라운드 프로세스(GenServer, Agent 등)와 연동해 상태를 공유하거나 영속화할 수 있습니다.
- 여러 노드 클러스터에서는 `Phoenix.PubSub`를 활용해 메시지를 공유합니다.

Q10: 웹소켓 성능 최적화 팁은?
A10:
- 불필요한 메시지 브로드캐스트를 줄이세요.
- 압축 옵션을 활성화할 수 있습니다 (Cowboy 설정 참고).
- 적절한 셀프 모니터링과 로깅을 통해 병목을 파악하세요.
- 분산 환경에서 `Phoenix.PubSub` 클러스터링을 활용하세요.

---

이상으로 Elixir와 Phoenix에서 웹소켓을 사용하는 기본적인 방법과 주의 사항들에 대한 FAQ였습니다.

Elixir에서 웹소켓을 사용하는 방법은 주로 Phoenix 프레임워크를 통해 이루어집니다.

Phoenix는 Elixir로 작성된 웹 프레임워크로, 실시간 기능을 쉽게 구현할 수 있도록 돕는 여러 도구와 라이브러리를 제공합니다.

웹소켓을 사용하여 클라이언트와 서버 간의 실시간 통신을 구현하는 방법에 대해 자세히 설명하겠습니다.

1. Phoenix 프로젝트 생성 먼저, Phoenix 프로젝트를 생성해야 합니다.

Elixir와 Phoenix가 설치되어 있어야 하며, 다음 명령어를 사용하여 새로운 프로젝트를 생성할 수 있습니다.

```bash mix phx.new my_app --no-ecto cd my_app ``` `--no-ecto` 플래그는 데이터베이스를 사용하지 않는 경우에 추가합니다.

데이터베이스가 필요하다면 이 플래그를 생략하면 됩니다.



2. 웹소켓 설정 Phoenix에서는 웹소켓을 설정하기 위해 `Channel`을 사용합니다.

Channels는 클라이언트와 서버 간의 실시간 통신을 가능하게 해주는 추상화된 개념입니다.



2.1. Channel 생성 `lib/my_app_web/channels` 디렉토리에서 새로운 채널 파일을 생성합니다.

예를 들어, `room_channel.ex`라는 파일을 생성합니다.

```elixir defmodule MyAppWeb.RoomChannel do use MyAppWeb, :channel def join("room:lobby", _message, socket) do {:ok, socket} end def handle_in("shout", %{"message" => message}, socket) do broadcast(socket, "shout", %{message: message}) {:noreply, socket} end end ``` 위의 코드에서 `join/3` 함수는 클라이언트가 "room:lobby"라는 주제에 가입할 때 호출됩니다.

`handle_in/3` 함수는 클라이언트가 "shout" 메시지를 보낼 때 호출되어, 해당 메시지를 모든 클라이언트에게 브로드캐스트합니다.



2.2. Router 설정 `lib/my_app_web/channels/user_socket.ex` 파일을 열고, 방금 생성한 채널을 소켓에 추가합니다.

```elixir defmodule MyAppWeb.UserSocket do use Phoenix.Socket channel "room:*", MyAppWeb.RoomChannel 나머지 코드... end ``` 이제 "room:*" 패턴에 대한 모든 채널 요청이 `RoomChannel`으로 라우팅됩니다.



3. 클라이언트 측 코드 작성 클라이언트 측에서는 JavaScript를 사용하여 웹소켓에 연결하고 메시지를 주고받을 수 있습니다.

`assets/js` 디렉토리 내의 `app.js` 파일을 수정하여 다음과 같이 웹소켓을 설정합니다.

```javascript import { Socket } from "phoenix" let socket = new Socket("/socket", { params: { userToken: "123" } }) socket.connect() let channel = socket.channel("room:lobby", {}) channel.join() .receive("ok", resp => { console.log("Joined successfully", resp) }) .receive("error", resp => { console.log("Unable to join", resp) }) document.getElementById("send-button").addEventListener("click", () => { let input = document.getElementById("message-input") channel.push("shout", { message: input.value }) input.value = "" }) channel.on("shout", payload => { let messages = document.getElementById("messages") messages.innerHTML += `

${payload.message}

` }) ``` 위의 코드에서는 웹소켓에 연결하고 "room:lobby" 채널에 가입합니다.

사용자가 메시지를 입력하고 버튼을 클릭하면, 해당 메시지가 서버로 전송되고, 서버는 이를 모든 클라이언트에게 브로드캐스트합니다.



4. 서버 실행 및 테스트 이제 모든 설정이 완료되었습니다.

서버를 실행하려면 다음 명령어를 사용합니다.

```bash mix phx.server ``` 브라우저에서 `http://localhost:4000`에 접속하여 웹소켓 기능이 제대로 작동하는지 확인합니다.

여러 브라우저 탭을 열고 메시지를 보내보면, 모든 탭에서 메시지가 실시간으로 업데이트되는 것을 확인할 수 있습니다.



5. 추가적인 고려사항 - 인증 및 권한 관리 : 실제 애플리케이션에서는 사용자의 인증 및 권한 관리를 고려해야 합니다.

Phoenix에서는 `Guardian`과 같은 라이브러리를 사용하여 JWT 기반의 인증을 구현할 수 있습니다.

- 에러 처리 : 웹소켓 통신 중 발생할 수 있는 에러를 적절히 처리하는 것이 중요합니다.

클라이언트와 서버 모두에서 에러 핸들링 로직을 추가해야 합니다.

- 성능 최적화 : 많은 클라이언트가 동시에 연결될 경우 성능 문제가 발생할 수 있습니다.

이를 해결하기 위해 `Presence` 기능을 사용하여 클라이언트의 상태를 관리하거나, 메시지 큐를 도입할 수 있습니다.

이와 같이 Elixir와 Phoenix를 사용하여 웹소켓을 구현하는 방법에 대해 알아보았습니다.

Phoenix의 강력한 기능을 활용하여 실시간 웹 애플리케이션을 쉽게 개발할 수 있습니다.