기본적인 null 체크와 자원 종료시 예외를 잡아서 처리하는 코드가 들어가 있다. 참고로 자원 정리 과정에서 문제가 발생해도 코드에서 직접 대응할 수 있는 부분은 거의 없다. 이 경우 간단히 로그를 남겨서 이후에 개발자가 인지할 수 있는 정도면 충분하다.
각각의 예외를 잡아서 처리했기 때문에 Socket, InputStream, OuputStream 중 하나를 닫는 과정에서 예외가 발생해도 다음 자원을 닫을 수 있다.
Socket 을 먼저 생성하고 Socket 기반으로 InputStream, OutputStream 을 생성했기 때문에 닫을 때는 InputStream, OutputStream, Socket 순으로 닫아야 한다.
참고로 InputStream, OutputStream의 닫는 순서는 상관 없다.
클라이언트 코드 먼저 자원을 잘 정리할 수 있도록 수정해보자.
package network.tcp.v4;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;
import static network.tcp.SocketCloseUtil.*;
import static util.MyLogger.log;
public class ClientV4 {
private static final int PORT = 12345;
public static void main(String[] args) throws IOException {
log("클라이언트 시작");
// finally 블록에서 변수에 접근해야 한다.
Socket socket = null;
DataInputStream input = null;
DataOutputStream output = null;
try {
socket = new Socket("localhost", PORT);
input = new DataInputStream(socket.getInputStream());
output = new DataOutputStream(socket.getOutputStream());
log("소켓 연결 : " + socket);
Scanner scanner = new Scanner(System.in);
while (true) {
// 서버에 문자 보내기
System.out.print("전송 문자 : ");
String toSend = scanner.nextLine();
output.writeUTF(toSend);
log("client -> server : " + toSend);
if (toSend.equals("exit")) {
break;
}
// 서버로부터 문자 받기
String received = input.readUTF();
log("client <- server : " + received);
}
} catch (IOException e) {
log(e);
} finally {
log("연결 종료 : " + socket);
closeAll(socket, input, output);
}
}
}
자원 정리시 finally 코드 블럭에서 SocketCloseUtil.closeAll() 만 호출하면 된다.
이번에는 서버 코드를 수정하자.
package network.tcp.v4;
import network.tcp.SocketCloseUtil;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import static network.tcp.SocketCloseUtil.*;
import static util.MyLogger.log;
public class SessionV4 implements Runnable{
private final Socket socket;
public SessionV4(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
// finally 블록에서 변수에 접근해야 한다.
DataInputStream input = null;
DataOutputStream output = null;
try {
input = new DataInputStream(socket.getInputStream());
output = new DataOutputStream(socket.getOutputStream());
while (true) {
// 클라이언트로부터 문자 받기
String received = input.readUTF();
log("client -> server : " + received);
if (received.equals("exit")) {
break;
}
// 클라이언트에게 문자 보내기
String toSend = received + ", World";
output.writeUTF(toSend);
log("client <- server : " + toSend);
}
} catch (IOException e) {
log(e);
} finally {
log("연결 종료 : " + socket);
closeAll(socket, input,output);
}
}
}
자원 정리시 finally 코드 블럭에서 SocketCloseUtil.closeAll() 만 호출하면 된다.
ServerV4는 기존 ServerV3 와 같은 코드이다. SessionV4 만 사용하면 된다.
package network.tcp.v4;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import static util.MyLogger.log;
public class ServerV4 {
private static final int PORT = 12345;
public static void main(String[] args) throws IOException, InterruptedException {
log("서버 시작");
ServerSocket serverSocket = new ServerSocket(PORT);
log("서버 소켓 시작 - 리스닝 포트 : " + PORT);
while (true) {
Socket socket = serverSocket.accept();
log("소켓 연결 : " + socket);
SessionV4 session = new SessionV4(socket);
Thread thread = new Thread(session);
thread.start();
}
}
}
기존 코드의 문제는 클라이언트를 직접 종료하면 서버의 Session 에 EOFException 이 발생하면서 자원을 제대로 정리하지 못했다.
변경한 코드에서는 서버에 접속한 클라이언트를 직접 종료해도 서버의 Sesseion 이 연결 종료라는 메시지를 남기면서 자원을 잘 정리하는 것을 볼 수 있다.
네트워크 프로그램5 - 자원 정리2
이번에는 자원 정리에 try-with-resources 를 적용해보자.
package network.tcp.v5;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;
import static util.MyLogger.log;
public class ClientV5 {
private static final int PORT = 12345;
public static void main(String[] args) throws IOException {
log("클라이언트 시작");
try(Socket socket = new Socket("localhost", PORT);
DataInputStream input = new DataInputStream(socket.getInputStream());
DataOutputStream output = new DataOutputStream(socket.getOutputStream())) {
log("소켓 연결 : " + socket);
Scanner scanner = new Scanner(System.in);
while (true) {
// 서버에 문자 보내기
System.out.print("전송 문자 : ");
String toSend = scanner.nextLine();
output.writeUTF(toSend);
log("client -> server : " + toSend);
if (toSend.equals("exit")) {
break;
}
// 서버로부터 문자 받기
String received = input.readUTF();
log("client <- server : " + received);
}
} catch (IOException e) {
log(e);
}
}
}
클라이언트에 try-with-resources 를 적용했다.
자원 정리시 try-with-resources 에 선언되는 순서의 반대로 자원 정리가 적용되기 때문에 여기서는 output, input, socket 순으로 close() 가 호출된다.
참고로 OutputStream , InputStream , Socket 모두 AutoCloseable 을 구현하고 있다.
package network.tcp.v5;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import static network.tcp.SocketCloseUtil.closeAll;
import static util.MyLogger.log;
public class SessionV5 implements Runnable{
private final Socket socket;
public SessionV5(Socket socket) {
this.socket = socket;
}
@Override
public void run() {
try(socket;
DataInputStream input = new DataInputStream(socket.getInputStream());
DataOutputStream output = new DataOutputStream(socket.getOutputStream())) {
while (true) {
// 클라이언트로부터 문자 받기
String received = input.readUTF();
log("client -> server : " + received);
if (received.equals("exit")) {
break;
}
// 클라이언트에게 문자 보내기
String toSend = received + ", World";
output.writeUTF(toSend);
log("client <- server : " + toSend);
}
} catch (IOException e) {
log(e);
}
log("연결 종료 : " + socket + " isClosed : " + socket.isClosed());
}
}
서버에 try-with-resources 를 적용했다.
Socket 객체의 경우 Session 에서 직접 생성하는 것이 아니라 외부에서 받아오는 객체이다. 이 경우 try 선언부에 예제와 같이 객체의 참조를 넣어두면 자원 정리 시점에 AutoCloseable 이 호출된다.
AutoCloseable 이 호출되어서 정말 소켓의 close() 메서드가 호출되었는지 확인하기 위해 마지막에 socket.isClosed() 를 호출하는 코드를 넣어두었다.
package network.tcp.v5;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import static util.MyLogger.log;
public class ServerV5 {
private static final int PORT = 12345;
public static void main(String[] args) throws IOException, InterruptedException {
log("서버 시작");
ServerSocket serverSocket = new ServerSocket(PORT);
log("서버 소켓 시작 - 리스닝 포트 : " + PORT);
while (true) {
Socket socket = serverSocket.accept();
log("소켓 연결 : " + socket);
SessionV5 session = new SessionV5(socket);
Thread thread = new Thread(session);
thread.start();
}
}
}
마지막에 있는 isClosed: true 로그를 통해 소켓의 close() 메서드가 try-with-resources 를 통해 잘 호출된 것을 확인할 수 있다.
네트워크 프로그램6 - 자원 정리3
이번에는 서버(프로세스)를 종료할 때, 서버 소켓과 연결된 모든 소켓 자원을 다 반납하고 서버를 안정적으로 종료하는 방법을 알아보자.
서버를 종료하려면 서버에 종료라는 신호를 전달해야 한다. 예를 들어, 서버도 콘솔 창을 통해서 입력을 받도록 만들고,
"종료" 라는 메시지를 입력하면 모든 자원을 정리하면서 서버가 종료되도록 하면 된다.
하지만 보통 서버에서 콘솔 입력은 잘 하지 않으므로, 이번에는 서버를 직접 종료하면서 자원도 함께 정리하는 방법을 알아보겠다.
셧다운 훅(Shutdown Hook)
자바는 프로세스가 종료될 때, 자원 정리나 로그 기록과 같은 종료 작업을 마무리 할 수 있는 셧다운 훅이라는 기능을 지원한다.
프로세스 종료 상태는 크게 2가지로 분류할 수 있다.
정상 종료
모든 non 데몬 스레드의 실행 완료로 자바 프로세스 정상 종료
사용자가 Ctrl+C를 눌러서 프로그램을 중단
kill 명령 전달 (kill -9 제외)
IntelliJ의 stop 버튼
강제 종료
운영체제에서 프로세스를 더 이상 유지할 수 없다고 판단할 때 사용
리눅스/유닉스의 kill -9 나 Windows의 taskkill /F
정상 종료의 경우에는 셧다운 훅이 작동해서 프로세스 종료 전에 필요한 후 처리를 할 수 있다.
반면에 강제 종료의 경우에는 셧다운 훅이 작동하지 않는다.
셧다운 훅의 사용 방법을 코드를 통해서 알아보고, 서버 종료시 자원도 함께 정리해보자.
클라이언트 코드는 기존과 같다. 이름만 ClientV6로 복사해서 만들자.
package network.tcp.v6;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;
import static util.MyLogger.log;
public class ClientV6 {
private static final int PORT = 12345;
public static void main(String[] args) throws IOException {
log("클라이언트 시작");
try(Socket socket = new Socket("localhost", PORT);
DataInputStream input = new DataInputStream(socket.getInputStream());
DataOutputStream output = new DataOutputStream(socket.getOutputStream())) {
log("소켓 연결 : " + socket);
Scanner scanner = new Scanner(System.in);
while (true) {
// 서버에 문자 보내기
System.out.print("전송 문자 : ");
String toSend = scanner.nextLine();
output.writeUTF(toSend);
log("client -> server : " + toSend);
if (toSend.equals("exit")) {
break;
}
// 서버로부터 문자 받기
String received = input.readUTF();
log("client <- server : " + received);
}
} catch (IOException e) {
log(e);
}
}
}
서버는 세션을 관리하는 세션 매니저가 필요하다.
package network.tcp.v6;
import java.util.ArrayList;
import java.util.List;
public class SessionManagerV6 {
private List<SessionV6> sessions = new ArrayList<>();
public synchronized void add(SessionV6 session) {
sessions.add(session);
}
public synchronized void remove(SessionV6 session) {
sessions.remove(session);
}
public synchronized void closeAll() {
for (SessionV6 session : sessions) {
session.close();
}
sessions.clear();
}
}
각 세션은 소켓과 연결 스트림을 가지고 있다. 따라서 서버를 종료할 때 사용하는 세션들도 함께 종료해야 한다. 모든 세션들을 찾아서 종료하려면 생성한 세션을 보관하고 관리할 객체가 필요하다.
SessionManager
add() : 클라이언트의 새로운 연결을 통해, 세션이 새로 만들어지는 경우 add() 를 호출해서 세션 매니저에 세션을 추가한다.
remove() : 클라이언트의 연결이 끊어지면 세션도 함께 정리된다. 이 경우 remove() 를 호출해서 세션 매니저에서 세션을 제거한다.
closeAll() 서버를 종료할 때 사용하는 세션들도 모두 닫고, 정리한다.
package network.tcp.v6;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import static network.tcp.SocketCloseUtil.*;
import static util.MyLogger.log;
public class SessionV6 implements Runnable{
private final Socket socket;
private final DataInputStream input;
private final DataOutputStream output;
private final SessionManagerV6 sessionManager;
private boolean closed = false;
public SessionV6(Socket socket, SessionManagerV6 sessionManager) throws IOException {
this.socket = socket;
this.input = new DataInputStream(socket.getInputStream());
this.output = new DataOutputStream(socket.getOutputStream());
this.sessionManager = sessionManager;
this.sessionManager.add(this);
}
@Override
public void run() {
try{
while (true) {
// 클라이언트로부터 문자 받기
String received = input.readUTF();
log("client -> server : " + received);
if (received.equals("exit")) {
break;
}
// 클라이언트에게 문자 보내기
String toSend = received + ", World";
output.writeUTF(toSend);
log("client <- server : " + toSend);
}
} catch (IOException e) {
log(e);
} finally {
sessionManager.remove(this);
close();
}
}
// 세션 종료시, 서버 종료시 동시에 호출될 수 있다.
public synchronized void close() {
if(closed) {
return;
}
closeAll(socket, input, output);
closed = true;
log("연결 종료 : " + socket + " isClosed : " + socket.isClosed());
}
}
아쉽지만 Session 은 이제 try-with-resources 를 사용할 수 없다.
왜냐하면 서버를 종료하는 시점에도 Session 의 자원을 정리해야 하기 때문이다.
try-with-resources 는 사용과 해제를 함께 묶어서 처리할 때 사용한다.
try-with-resources 는 try 선언부에서 사용한 자원을 try가 끝나는 시점에 정리한다. 따라서 try에서 자원의 선언과 자원 정리를 묶어서 처리할 때 사용할 수 있다. 하지만 지금은 서버를 종료하는 시점에도 Session 이 사용하는 자원을 정리해야 한다. 서버를 종료하는 시점에 자원을 정리하는 것은 Session 안에 있는 try-with-resources 를 통해 처리할 수 없다.
동시성 문제
public synchonized void close() {...}
자원을 정리하는 close() 메서드는 2곳에서 호출될 수 있다.
클라이언트와 연결이 종료되었을 때 (exit 또는 예외 발생)
서버를 종료할 때
따라서 close() 가 다른 스레드에서 동시에 중복 호출될 가능성이 있다.
이런 문제를 막기 위해서 synchronized 키워드를 사용했다. 그리고 자원 정리 코드가 중복 호출 되는 것을 막기 위해서 closed 변수를 플레그로 사용했다.
네트워크 프로그램6 - 자원 정리4
package network.tcp.v6;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import static util.MyLogger.log;
public class ServerV6 {
private static final int PORT = 12345;
public static void main(String[] args) throws IOException, InterruptedException {
log("서버 시작");
SessionManagerV6 sessionManager = new SessionManagerV6();
ServerSocket serverSocket = new ServerSocket(PORT);
log("서버 소켓 시작 - 리스닝 포트 : " + PORT);
// ShutdownHook 등록
ShutdownHook shutdownHook = new ShutdownHook(serverSocket, sessionManager);
Runtime.getRuntime().addShutdownHook(new Thread(shutdownHook, "shutdown"));
try {
while (true) {
Socket socket = serverSocket.accept();
log("소켓 연결 : " + socket);
SessionV6 session = new SessionV6(socket, sessionManager);
Thread thread = new Thread(session);
thread.start();
}
} catch (IOException e) {
log("서버 소켓 종료 : " + e);
}
}
static class ShutdownHook implements Runnable {
private final ServerSocket serverSocket;
private final SessionManagerV6 sessionManager;
public ShutdownHook(ServerSocket serverSocket, SessionManagerV6 sessionManager) {
this.serverSocket = serverSocket;
this.sessionManager = sessionManager;
}
@Override
public void run() {
log("ShutdownHoot 실행");
try {
sessionManager.closeAll();
serverSocket.close();
Thread.sleep(1000); // 자원 정리 대기
} catch (Exception e) {
e.printStackTrace();
System.out.println("e = " + e);
}
}
}
}
셧다운 훅 등록
// ShutdownHook 등록
ShutdownHook shutdownHook = new ShutdownHook(serverSocket, sessionManager);
Runtime.getRuntime().addShutdownHook(new Thread(shutdownHook, "shutdown"));
Runtime.getRuntime().addShutdownHook() 을 사용하면 자바 종료시 호출되는 셧다운 훅을 등록할 수 있다.
여기에 셧다운이 발생했을 떄 처리할 작업과 스레드를 등록하면 된다.
셧다운 훅 실행 코드
@Override
public void run() {
log("ShutdownHoot 실행");
try {
sessionManager.closeAll();
serverSocket.close();
Thread.sleep(1000); // 자원 정리 대기
} catch (Exception e) {
e.printStackTrace();
System.out.println("e = " + e);
}
}
셧다운 훅이 실행될 때 모든 자원을 정리한다.
sessionManager.closeAll() : 모든 세션이 사용하는 자원( Socket , InputStream , OutputStream )을 정리한다.
serverSocket.close() : 서버 소켓을 닫는다.
자원 정리 대기 이유
Thread.sleep(1000); // 자원 정리 대기
보통 모든 non 데몬 스레드의 실행이 완료되면 자바 프로세스가 정상 종료된다. 하지만 다음과 같은 종료도 있다.
사용자가 Ctrl+C를 눌러서 프로그램을 중단
kill 명령 전달 (kill -9 제외)
IntelliJ의 stop 버튼
이런 경우에는 non 데몬 스레드의 종료 여부와 관계없이 자바 프로세스가 종료된다. (정상 종료)
단, 셧다운 훅의 실행이 끝날 때 까지는 기다려준다.
셧다운 훅의 실행이 끝나면 non 데몬 스레드의 실행 여부와 상관 없이 자바 프로세스는 종료된다.
따라서 다른 스레드가 자원을 정리하거나 필요한 로그를 남길 수 있도록 셧다운 훅의 실행을 잠시 대기한다.
서버를 종료하면 shutdown 스레드가 shutdownHook 을 실행하고, 세션의 Socket 의 연결을 close() 로 닫는다.
연결이 거절되었다는 것은, 우선은 네트워크를 통해 해당 IP의 서버 컴퓨터에 접속은 했다는 뜻이다.
그런데 해당 서버 컴퓨터가 45678 포트를 사용하지 않기 때문에 TCP 연결을 거절한다.
IP에 해당하는 서버는 켜져있지만, 사용하는 PORT가 없을 때 주로 발생한다.
네트워크 방화벽 등에서 무단 연결로 인지하고 연결을 막을 때도 발생한다.
서버 컴퓨터의 OS는 이때 TCP RST(Reset)라는 패킷을 보내서 연결을 거절한다.
클라이언트가 연결 시도 중에 RST 패킷을 받으면 이 예외가 발생한다.
TCP RST(Reset) 패킷
TCP 연결에 문제가 있다는 뜻이다. 이 패킷을 받으면 받은 대상은 바로 연결을 해제해야 한다.
네트워크 예외2 - 타임아웃
네트워크 연결을 시도해서 서버 IP 에 연결 패킷을 전달했지만 응답이 없는 경우 어떻게 될까?
TCP 연결 타임아웃 - OS 기본
package network.exception.connect;
import java.io.IOException;
import java.net.ConnectException;
import java.net.Socket;
public class ConnectTimeoutMain1 {
public static void main(String[] args) throws IOException {
long start = System.currentTimeMillis();
try {
Socket socket = new Socket("192.168.1.250", 45678);
} catch (ConnectException e) {
e.printStackTrace();
}
long end = System.currentTimeMillis();
System.out.println("end = " + (end - start));
}
}
사설 IP 대역(주로 공유기에서 사용하는 IP 대역)의 192.168.1.250 을 사용했다. 혹시 해당 IP로 무언가 연결 되어 있다면 다른 결과가 나올 수 있다. 이 경우 마지막 3자리를 변경해보자.
해당 IP로 연결 패킷을 보내지만 IP를 사용하는 서버가 없으므로 TCP 응답이 오지 않는다.
또는 해당 IP로 연결 패킷을 보내지만 해당 서버가 너무 바쁘거나 문제가 있어서 연결 응답 패킷을 보내지 못하는 경우도 있다.
그렇다면 이때 무한정 기다려야 할까?
OS 기본 대기 시간
TCP 연결을 시도했는데 연결 응답이 없다면 OS에는 연결 대기 타임아웃이 설정되어 있다.
Windows: 약 21초
Linux: 약 75초에서 180초 사이
mac test 75초
해당 시간이 지나면 java.net.ConnectException: Operation timed out 이 발생한다.
TCP 연결을 클라이언트가 이렇게 오래 대기하는 것은 좋은 방법이 아니다.
연결이 안되면 고객에게 빠르게 현재 연결에 문제가 있다고 알려주는 것이 더 나은 방법이다.
TCP 연결 타임아웃 - 직접 설정
TCP 연결 타임아웃 시간을 직접 설정해보자.
package network.exception.connect;
import java.io.IOException;
import java.net.ConnectException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketTimeoutException;
public class ConnectTimeoutMain2 {
public static void main(String[] args) throws IOException {
long start = System.currentTimeMillis();
try {
Socket socket = new Socket();
socket.connect(new InetSocketAddress("192.168.1.250", 45678), 1000);
} catch (SocketTimeoutException e) {
e.printStackTrace();
}
long end = System.currentTimeMillis();
System.out.println("end = " + (end - start));
}
}
new Socket()
Socket 객체를 생성할 때 인자로 IP, PORT를 모두 전달하면 생성자에서 바로 TCP 연결을 시도한다.
하지만 IP, PORT를 모두 빼고 객체를 생성하면, 객체만 생성되고, 아직 연결은 시도하지 않는다. 추가적으로 필요한 설정을 더 한 다음에 socket.connect() 를 호출하면 그때 TCP 연결을 시도한다. 이 방식을 사용하면 추가적인 설정을 더 할 수 있는데, 대표적으로 타임아웃을 설정할 수 있다.
public void connect(SocketAddress endpoint, int timeout) throws IOException
{...}
InetSocketAddress : SocketAddress 의 자식이다. IP, PORT 기반의 주소를 객체로 제공한다.
timeout : 밀리초 단위로 연결 타임아웃을 지정할 수 있다.
타임아웃 시간이 지나도 연결이 되지 않으면 다음 예외가 발생한다.
java.net.SocketTimeoutException: Connect timed out
TCP 소켓 타임아웃 - read 타임아웃
타임아웃 중에 또 하나 중요한 타임아웃이 있다.
바로 소켓 타임아웃 또는 read 타임 아웃이라고 부르는 타임아웃이다.
앞에서 설명한 연결 타임아웃은 TCP 연결과 관련이 되어있다.
연결이 잘 된 이후에 클라이언트가 서버에 어떤 요청을 했다고 가정하자. 그런데 서버가 계속 응답을 주지 않는다면, 무한정 기다려야 하는 것일까?
서버에 사용자가 폭주하고 매우 느려져서 응답을 계속 주지 못하는 상황이라면 어떻게 해야할까?
이런 경우에 사용하는 것이 바로 소켓 타임아웃(read 타임아웃)이다.
package network.exception.connect;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class SoTimeoutServer {
public static void main(String[] args) throws IOException, InterruptedException {
ServerSocket serverSocket = new ServerSocket(12345);
Socket socket = serverSocket.accept();
Thread.sleep(1000000);
}
}
socket.setSoTimeout() 을 사용하면 밀리초 단위로 타임아웃 시간을 설정할 수 있다. 여기서는 3초를 설정 했다.
3초가 지나면 다음 예외가 발생한다.
java.net.SocketTimeoutException: Read timed out
타임아웃 시간을 설정하지 않으면 read() 는 응답이 올 때 까지 무한 대기한다.
실무 이야기
실무에서 자주 발생하는 장애 원인 중 하나가 바로 연결 타임아웃, 소켓 타임아웃(read 타임 아웃)을 누락하기 때문에 발생한다.
서버도 외부에 존재하는 데이터를 네트워크를 통해 불러와야 하는 경우가 있다.
예를 들어서 주문을 처리하는 서버가 있는데, 주문 서버는 외부에 있는 서버를 통해 고객의 신용카드 결제를 처리해야 한다고 가정해보자.
신용카드를 처리하는 회사가 3개 있다고 가정하자.
고객 -> 주문 서버 -> 신용카드A 회사 서버(정상)
고객 -> 주문 서버 -> 신용카드B 회사 서버(정상)
고객 -> 주문 서버 -> 신용카드C 회사 서버(문제)
신용카드 A, 신용카드 B 서버는 문제가 없고, 신용카드C 회사 서버에 문제가 발생해서 응답을 주지 못하는 상황이라고 가정해보자. 주문 서버는 계속 신용카드 C 회사 서버의 응답을 기다리게 된다.
여기서 문제는 신용카드C의 결제에 대해서 주문 서버도 고객에게 응답을 주지 못하고 계속 대기하게 된다. 신용카드C 로 주문하는 고객이 누적 될 수록 주문 서버의 요청은 계속 쌓이게 되고, 신용카드 C 회사 서버의 응답을 기다리는 스레드도 점점 늘어난다. 결국 주문 서버에 너무 많은 사용자가 접속하게 되면서 주문 서버에 장애가 발생하게 된다.
결과적으로 신용카드C 때문에 신용카드A, 신용카드B를 사용하는 고객까지 모두 주문을 할 수 없는 사태가 벌어진다.
이런 장애는 신용카드 C 회사의 문제일까? 아니면 주문 서버 개발자의 문제일까?
만약 주문 서버에 연결, 소켓 타임아웃을 적절히 설정했다면, 신용카드 C 회사 서버가 연결이 오래 걸리거나 응답을 주지 않을 때 타임아웃으로 처리할 수 있다. 이렇게 되면 요청이 쌓이지 않기 때문에, 주문 서버에 장애가 발생하지 않는다. 타임아웃이 발생하는 신용카드 C 사용자에게는 현재 문제가 있다는 안내를 하면 된다. 나머지 신용카드A, 신용카드 B는 정상적으로 작동한다.
외부 서버와 통신을 하는 경우 반드시 연결 타임아웃과 소켓 타임아웃을 지정하자.
네트워크 예외3 - 정상 종료
TCP에는 2가지 종류의 종료가 있다.
정상 종료
강제 종료
정상 종료
TCP에서 A, B가 서로 통신한다고 가정해보자.
TCP 연결을 종료하려면 서로 FIN 메시지를 보내야 한다.
A (FIN) -> B : A가 B로 FIN 메시지를 보낸다.
A <- (FIN) B : FIN 메시지를 받은 B도 A에게 FIN 메시지를 보낸다.
socket.close() 를 호출하면 TCP에서 종료의 의미인 FIN 패킷을 상대방에게 전달한다.
FIN 패킷을 받으면 상대방도 socket.close() 를 호출해서 FIN 패킷을 상대방에게 전달해야 한다.
클라이언트와 서버가 연결되어 있다.
서버가 연결 종료를 위해 socket.close() 를 호출한다.
서버는 클라이언트에 FIN 패킷을 전달한다.
클라이언트는 FIN 패킷을 받는다.
클라이언트의 OS에서 FIN에 대한 ACK 패킷을 전달한다.
클라이언트도 종료를 위해 socket.close() 를 호출한다.
클라이언트는 서버에 FIN 패킷을 전달한다.
서버의 OS는 FIN 패킷에 대한 ACK 패킷을 전달한다.
예제를 통해 소켓의 정상 종료에 대해 알아보자.
package network.exception.close.nomal;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import static util.MyLogger.log;
public class NomalCloseServer {
public static void main(String[] args) throws IOException, InterruptedException {
ServerSocket serverSocket = new ServerSocket(12345);
Socket socket = serverSocket.accept();
log("소켓 연결 : " + socket);
Thread.sleep(1000);
socket.close();
log("소켓 종료");
}
}
FIN 패킷을 받은 클라이언트의 소켓은 더는 서버를 통해 읽을 데이터가 없다는 의미로 -1(EOF)를 반환한다.
여기서 각각의 상황에 따라 EOF를 해석하는 방법이 다르다.
read() -> -1
EOF의 의미를 숫자 -1로 반환한다.
BufferedReader().readLine() -> null
BufferedReader() 는 문자 String 을 반환한다. 따라서 -1을 표현할 수 없다. 대신에 null 을 반환 한다.
DataInputStream.readUTF() -> EOFException
DataInputStream 은 이 경우 EOFException 을 던진다.
예외를 통해서 연결을 종료할 수 있는 방법을 제공한다.
여기서 중요한 점은 EOF가 발생하면 상대방이 FIN 메시지를 보내면서 소켓 연결을 끊었다는 뜻이다.
이 경우 소켓에 다른 작업을 하면 안되고, FIN 메시지를 받은 클라이언트도 close() 를 호출해서 상대방에 FIN 메시지를 보내고 소켓 연결을 끊어야 한다.
이렇게 하면 서로 FIN 메시지를 주고 받으면서 TCP 연결이 정상 종료된다.
네트워크 예외4 - 강제 종료
강제 종료
TCP 연결 중에 문제가 발생하면 RST 라는 패킷이 발생한다. 이 경우 연결을 즉시 종료해야 한다.
package network.exception.close.reset;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import static util.MyLogger.log;
public class ResetCloseServer {
public static void main(String[] args) throws IOException {
ServerSocket serverSocket = new ServerSocket(12345);
Socket socket = serverSocket.accept();
log("소켓 연결 : " + socket);
socket.close();
serverSocket.close();
log("소켓 종료");
}
}
서버는 소켓이 연결되면 단순히 연결을 종료한다.
package network.exception.close.reset;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.SocketException;
import static util.MyLogger.log;
public class ResetCloseClient {
public static void main(String[] args) throws IOException, InterruptedException {
Socket socket = new Socket("localhost", 12345);
log("소켓 연결 : " + socket);
InputStream input = socket.getInputStream();
OutputStream output = socket.getOutputStream();
// client <- server : FIN
Thread.sleep(1000); // 서버가 close() 호출할 때 까지 잠시 대기
// client -> server : PUSH[1]
output.write(1);
// clinet <- server : RST
Thread.sleep(1000); // 클라이언트 OS 에서 FIN 에 대한 ACK 를 보냈는데, PUSH 패킷을 보냈다.
try {
// java.net.SocketException: Connection reset
int read = input.read();
System.out.println("read = " + read);
} catch (SocketException e) {
e.printStackTrace();
}
try {
// java.net.SocketException: Broken pipe
output.write(1);
} catch (SocketException e) {
e.printStackTrace();
}
}
}
클라이언트와 서버가 연결되어 있다.
서버는 종료를 위해서 socket.close() 를 호출한다.
서버는 클라이언트에게 FIN 패킷을 전달한다.
클라이언트는 FIN 패킷을 받는다.
클라이언트의 OS 에서 FIN 에 대한 ACK 패킷을 전달한다.
클라이언트는 output.write(1) 를 통해 서버에 메시지를 전달한다.
데이터를 전송하는 PUSH 패킷이 서버에 전달된다.
서버는 이미 FIN 으로 종료를 요청했는데, PUSH 패킷으로 데이터가 전송되었다.
서버가 기대하는 결과 값은 FIN 패킷이다.
서버는 TCP 연결에 문제가 있다고 판단하고 즉각 연결을 종료하라는 RST 패킷을 클라이언트에 전송한다.
RST 패킷이 도착했다는 것은 현재 TCP 연결에 심각한 문제가 있으므로 해당 연결을 더는 사용하면 안된다는 의미이다.
RST 패킷이 도착하면 자바는 read() 로 메시지를 읽을 때 다음 예외를 던진다.
MAC: java.net.SocketException: Connection reset
RST 패킷이 도착하면 자바는 write() 로 메시지를 전송할 때 다음 예외를 던진다.
MAC: java.net.SocketException: Broken pipe
정리
상대방이 연결을 종료한 경우 데이터를 읽으면 EOF가 발생한다.
-1, null , EOFException 등이 발생한다.
이 경우 연결을 끊어야 한다.
java.net.SocketException: Connection reset
RST 패킷을 받은 이후에 read() 호출
java.net.SocketException: Broken pipe
RST 패킷을 받은 이후에 write() 호출
java.net.SocketException: Socket is closed
자신이 소켓을 닫은 이후에 read() , write() 호출
네트워크 종료와 예외 처리
네트워크에서 이런 예외를 다 따로따로 이해하고 다루어야 할까? 사실 어떤 문제가 언제 발생할지 자세하게 다 구분해서
처리하기는 어렵다.
따라서 기본적으로 정상 종료, 강제 종료 모두 자원 정리하고 닫도록 설계하면 된다.
예를 들어서 SocketException , EOFException 은 모두 IOException 의 자식이다. 따라서 IOException 이 발생하면 자원을 정리하면 된다. 만약 더 자세히 분류해야 하는 경우가 발생하면 그때 예외를 구분해서 처리하면 된다.
