늘 빠른 답변에 감사드립니다.

현재 사이트 사정상 클라이언트측 inactivity timeout을 10초로 변경해 두었는데 그런 상태에서 수백만건의 데이터를 쿼리할 경우에
(Quotas 상의 제약을 지켜도) 실제DB에서 데이터를 가져오는 동안 블러킹 되어서 인지 WCF채널이 faulted(inactivty timeout때문) 상태가
되는 듯(?) 합니다.

그래서 서비스 쪽에서 아래와 같이 비동기적으로 처리하도록 해보았는데 여전히 채널에서 문제를 발생시키더군요.
아시다시피 하나의 서비스 함수내 에서 결과를 리턴 해주고자 이벤트 방식보다는 폴링방식으로 시도해 보았는데 여전히 채널이 망가집니다.

sleep(0)를 주는 대신에 WCF 채널이 비활성되지 않도록 서비스쪽에서 취할수 있는 다른 방법이 없을까요?
제어권만 놓아주면 WCF 채널이 유지될 것으로 추측해 보았는데 그건 아닌듯하군요.

DAC
{
List<AlarmMessageHistoryT> logs = new List<AlarmMessageHistoryT>();
SqlDataReader reader = agent.asyncExecuteReader(query);
while (reader.Read())
{
AlarmMessageHistoryT item = new AlarmMessageHistoryT();
fromReader(item, reader);
logs.Add(item);
}
return logs;
}


public SqlDataReader asyncExecuteReader(string strQuery)
{
CreateConnection();
SqlDataReader reader = null;
try
{
SqlCommand cmd = new SqlCommand(strQuery, _connection);
...
_connection.Open();
IAsyncResult ar = cmd.BeginExecuteReader(CommandBehavior.CloseConnection);
while (!ar.IsCompleted)
{
System.Threading.Thread.Sleep(0);
//System.Windows.Forms.Application.DoEvents();
}
reader = cmd.EndExecuteReader(ar);
...
}
catch (Exception ex)
{
}
finally
{
CloseConnection();
}
return reader;
}

제가 기억하기로는 위에서 적은 DAC 코드가 실행되는 곳이 WCF 서버 측이죠?
그리고, 위의 DAC 코드가 실행되는 WCF메서드를 호출하는 곳이 별도로 클라이언트이고.

그런데, 클라이언트에서 그 WCF 메서드를 실행하면 InactivityTimeout 때문에 WCF 채널이 faulted 상태로 빠지는 것이죠?

위의 코드라면, 그렇게 되는 것이 맞습니다.
왜냐하면 위의 DAC 코드에서 사용한 BeginExecuteReader는 비동기 함수이긴 하지만, 그 이후에 while 문을 통해서 쓰레드를 여전히 점유하고 있기 때문에, WCF 메서드를 부른 클라이언트 측 역시 계속 블로킹 상태에 놓이게 됩니다.

while 문으로 받아서는 안되고 콜백함수를 통해서 처리를 하셔야 하는데요. 물론 그렇게 하면 클라이언트 측은 WCF 메서드를 부르고는 결과를 받지도 못하고 쓰레드가 진행되기 때문에 또한 문제가 발생합니다.

제 생각에는, 이런 경우 문제를 해결하기 위해서는 어쨌든 클라이언트 쓰레드를 최대한 자유롭게 해주어야 합니다.
이런식으로 우회해야 할 것 같습니다.

=== client ====
int cookie = wcf_channel.DoMethod(); // WCF 메서드를 호출

=== server ====
int DoMethod()
{
int random_cookie = ....; // 메서드 호출 구분을 위한 고유값을 구해놓고. (또는 Guid 로 한다든가.)
cmd.BeginExecuteReader(...); // 비동기 호출을 하고.
return cookie; // 곧바로 cookie 값만을 반환해서 클라이언트 측 쓰레드를 자유롭게 놓아주고.
}

void BeginExecuteReader_Callback_Result() // BeginExecuteReader 에 대한 비동기 콜백함수가 실행되고.
{
... // DB 쿼리 조회값을 구하고.
channel_Callback(cookie, logs); // 클라이언트 측에 WCF 콜백 메서드를 호출
}

==== client ====

void channel_Callback(int cookie, List logs)
{
// 이때, 최초 wcf_channel.DoMethod(); 호출 결과에 대한 값을 처리.
}

---

[이 토픽에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]

[최초 등록일: 6/10/2010]
[최종 수정일: 6/10/2010]