[질문] 포트 리다이렉션에 대해

서버를 하나 작성을 했습니다.

그런데 이 서버와 통신하는 외부 모듈이 포트를 수정할 수가 없는 상태에서

그 서버와 통신을 해야할 내부 모듈이 두개 이상 생겼습니다.

내부 서버 모듈 #1, 2... <---> fixed 포트만을 사용하는 외부 통신 인터페이스

포트를 공유해서 서버를 만들수는 없어서 고민을 하다가 device IP를 두개이상을 주었습니다. fixed port를 사용하는 외부에서 내부로 커넥트 시에 두개 이상의 서로 다른 IP를 할당을 했지요. 물론 이 IP는 가상이 아니고 실제 할당된 IP구요.

그래서 간단한 프록시를 작성을 했는데요..

근데 여기서 문제가 생겼습니다.

우선 외부 모듈과 통신을 할 포트를 열어두고요(예를들어 4000, 4001, 4002 ~ 4008번이라고 하고) 그리고 내부 서버에서는 리슨한 포트에 대해 루프를 돌면서 계속 accept합니다. 그리고 getsockname으로 연결요청한 IP를 보고 판단해서 내부적으로는 다른 포트로 리다이렉션을 하지요.

테스트 할때 한 포트에 대해서만 우선 테스트를 했었는데요, 4000을 리슨하고 있다가 3000과 5000으로 각기 다른 IP를 가지고 온 클라이언트를 다른 포트로 리다이렉션을 하는데는 별 무리가 없었는데요.. 여러 포트를 리슨하고 그것을 루프돌면서 accept를 하니까.. 클라이언트에서는 broken 현상이 나타나게 된 것입니다.

서버의 구성은 다음과 같습니다.

우선 main에서 특정 포트에 대해 listen을 하고 listenfd를 반환합니다.
물론 이 서버는 물리적인 IP를 두개이상 가지고 있기 때문에 INADDR_ANY로 다 받아들이지요.

    srvr_addr.sin_family = AF_INET;
    srvr_addr.sin_port = htons(port);

    if(((long)(ptr_pcol = getprotobyname("tcp"))) == 0) {
        trace(LOG_CRT, "cannot map \"tcp\" to protocol number");
        exit(0);
    }

    do {
        srvr_sd = socket(PF_INET, SOCK_STREAM, ptr_pcol->p_proto);
        if(srvr_sd < 0) {
            trace(LOG_CRT, "socket create failed");
            rc = srvr_sd;
            continue;
        }
        setsockopt(srvr_sd, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(int));
        srvr_addr.sin_addr.s_addr = htons(INADDR_ANY);
        if((rc = bind(srvr_sd, (struct sockaddr *)&srvr_addr, sizeof(struct sockaddr_in))) < 0) {
            trace(LOG_INF, "bind failed\n");
            close(srvr_sd);
            exit(0);
        }
    } while(rc < 0);

    if(listen(srvr_sd, LISTENQ) != 0) {
        trace(LOG_CRT, "listen error");
    }

    return srvr_sd;

여기서 리턴받은 listenfd를 루프를 돌면서 accept 하지요.

for(;;) {
   connfd = accept(listenfd, (struct sockaddr *)&client_addr, &client_addr_len);
   getsockname(connfd, (struct sockaddr *)&client_addr, &client_addr_len);
   if(!(memcmp(inet_ntoa(client_addr.sin_addr), SERVICE_ADDR, 12))) {
      if(pthread_create(&ptConnection[0], NULL, proxy, (void *)ptr) != 0) {

      }
   } else if(!(memcmp(inet_ntoa(client_addr.sin_addr), OTHER_ADDR, 12))) {
      if(pthread_create(&ptConnection[1], NULL, proxy, (void *)ptr) != 0) {

      }
   } else {
      fprintf(stderr, "Unknown ip address");
   }
}

이런식으로 서버를 분리해서 리다이렉션을 합니다.
그리고 그 처리는 thread에서 하게되죠. 포트 하나를 열고 테스트할때는 전혀 이상없는 코드였는데 다중의 포트를 listen하도록 하고 그 listenfd를 가지고 accept를 하니 이상이 발생합니다.(socket broken)

그리고 thread 내부에서 하는 일은 간단합니다.
내부 모듈로 Connect를 하고 서로 전송받은 내용을 read하고 write해주는 것 뿐이죠.

    for(;;) {
        FD_SET(sd, &rset);
        FD_SET(sdOut, &rset);
        selectval = select(iMaxSocket, &rset, NULL, NULL, NULL);
        if(selectval == -1) {
            perror("select(): ");
            break;
        }

        memset(buf, 0, TRANSFER_BUFFER_SIZE);
        if(FD_ISSET(sd, &rset)) {
            nbytes = read(sd, &buf, TRANSFER_BUFFER_SIZE);
            if(nbytes <= 0) {
                Close(sdOut);
                Close(sd);
                break;
            }

            if(write(sdOut, &buf, nbytes) != nbytes) {
                trace(LOG_CRT, "write() failed");
            }

            nbytes -= nbytes;
        }

        if(FD_ISSET(sdOut, &rset)) {
            nbytes = read(sdOut, &buf, TRANSFER_BUFFER_SIZE);
            if(nbytes <= 0) {
                Close(sdOut);
                Close(sd);
                break;
            }

            if(write(sd, &buf, nbytes) != nbytes) {
                trace(LOG_CRT, "write() failed");
            }

            nbytes -= nbytes;
        }

    }

그래서 포트를 열어야 할 갯수대로 프로세스를 따로 만들어서 동작도 시켜봤는데 같은 현상이 일어납니다. 그리고 무엇보다 너무 느리구요..

아래 그림은 프로시 전체 밑그림입니다.
C1과 C2가 두개의 클라이언트고 S가 포트를 열고 대기하는 프록시 입니다.
그리고 그 프록시는 C1과 C2를 구분해서 M1과 M2 두군데와 서로 통신하도록 연결해주는 역할을 하구요..

[/code]