Microsoft MVP성태의 닷넷 이야기
.NET Framework: 96. WCF - PerSession에서의 클라이언트 연결 관리 [링크 복사], [링크+제목 복사],
조회: 31009
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 
(연관된 글이 2개 있습니다.)

WCF - PerSession에서의 클라이언트 연결 관리


일단, 오늘의 주제는 아마도 많은 분들이 관심있으신 사항이었을 거라 봅니다. PerCall 모드에서야 별로 관심 없을 사항이겠지만, PerSession에서는 클라이언트 연결 관리가 꽤나 중요한 요구 사항으로 대두됩니다. 일례로, PerSession에서 "Callback"을 쓰려고 해도 현재 제대로 연결된 클라이언트를 알아야만 효율적인 콜백 호출을 할 수가 있기 때문입니다.

어디... 코드와 함께 조금씩 문제를 파헤쳐 볼까요? ^^

대개의 경우, WCF (세션 가능한) 서비스 코드는 다음과 같은 구조를 이룹니다.


///// 서버 측 코드 //////

[ServiceContract(SessionMode = SessionMode.Required)]
public interface IService1
{
  [OperationContract]
  void StarDust();
}

[ServiceBehavior(InstanceContextMode=InstanceContextMode.PerSession)]
public class Service1 : IService1
{
  public void StarDust()
  {
  }
}

클라이언트는, 다음과 같이 인스턴스 변수로 관리를 할 테지요!

Service1Client svc;

private void Form1_Load(object sender, EventArgs e)
{
  svc = new Service1Client("NetTcpBinding_IService1");
}

private void Form1_Close(object sender, EventArgs e)
{
  svc.Close();
}

뭐... 대충, 위와 같은 선에서 서비스가 제작될 것입니다. 여기까지는 별다른 이상이 없어 보입니다. 하지만, 여기서 콜백이 들어가면 상황이 달라집니다.

우선, 서버 측 코드는 다음과 같이 바뀔 테고.

// 콜백 인터페이스
public interface IMyServiceCallback
{
  [OperationContract(IsOneWay = true)]
  void FallingStar();
}

// 콜백 인터페이스를 지정
[ServiceContract( SessionMode = SessionMode.Required, CallbackContract=typeof(IMyServiceCallback))]
public interface IService1
{
  [OperationContract]
  void StarDust();
}

// 콜백을 추가
[ServiceBehavior(InstanceContextMode=InstanceContextMode.PerSession)]
public class Service1 : IService1, IDisposable
{
  static Dictionary<string, IMyServiceCallback> callbacks 
  = new Dictionary<string, IMyServiceCallback>();
  public void StarDust()
  {
    string id = OperationContext.Current.SessionId;
    IMyServiceCallback callback = OperationContext.Current.GetCallbackChannel<IMyServiceCallback>();

    if (Service1.callbacks.ContainsKey(id) == false)
    {
      // 새로 연결된 세션의 콜백을 추가
      Service1.callbacks.Add(id, callback);
    }
  }
}

클라이언트 측에서는 콜백 인터페이스 구현 및 관련 메서드를 호출하도록 구성합니다.

public partial class Form1 : Form
     , IService1Callback 
     // 프록시 코드 생성 시, 서버 측의 IMyServiceCallback 이름이 
     // [서비스 이름] + "Callback" 형태로 바뀝니다.
{
  Service1Client svc;

  private void Form1_Load(object sender, EventArgs e)
  {
    InstanceContext instance = new InstanceContext(this);
    svc = new Service1Client(instance, "NetTcpBinding_IService1");
    try
    {
      svc.Open();
      svc.StarDust();
    }
    catch (Exception ex)
    {
      Console.WriteLine(ex.Message);
    }
  }
}

public void FallingStar()
{
  Debug.WriteLine("To Become an woman.");
}

서비스 측 코드를 보시면, ... 뭔가 이상한 것을 발견할 수 있습니다. 서버 측의 콜백 관리가 Add만 있을 뿐, Remove가 없습니다. ^^;

그렇습니다. 문제는, 해당 콜백의 remove를 언제 하느냐는 것입니다.

개인적으로, 이 부분에 고민을 하면서 ... 예상했던 것과는 달리 그와 관련된 자료가 거의 없다는 것을 알았습니다. 어떤 토픽을 읽어보니, 콜백 함수 호출 시에 명시적으로 오류가 발생하면, 그것을 연결이 끊겼다고 판단하고 콜백에서 지우는 것을 보았습니다.... 음... ^^; 언뜻 봐도 그것은 비이성적인 방법이라고 밖에는 볼 수 없습니다.

그러다가, 아래의 토픽에서 좀 더 나은 방법을 발견했습니다.

2006년 12월호 닷넷 칼럼 ::  WCF Instance Management 
; http://www.simpleisbest.net/articles/1731.aspx

위의 토픽에는, 아래와 같이 아주 "기본"적인 내용의 해결책이 담겨져 있었습니다. (역시, 기본에 충실해야 합니다. ^^)

[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerSession)]
public class PerSessionService : IEchoService, IDisposable
{
  private int _CallCount = 0;

  public PerSessionService()
  {
    Console.WriteLine("PerSessionService Created...");
  }

  public void Dispose()
  {
    Console.WriteLine("PerSessionService Disposing...");
  }
}

처음엔, 위의 코드를 발견하고 굉장히 ^^ 좋아했습니다. 하지만, 조금 있다가 이것도 뭔가 부족하다는 것을 알게 되었습니다. 예를 들어, 현재의 연결이 "비정상 종료"인지, Close를 통한 정상적인 종료인지를 알 방법이 없다는 것입니다. 또는 현재 Dispose가 실행되는 연결 상태의 정보를 알 수가 없다는 것입니다. (물론, 적절한 인스턴스 변수를 보관해 두면 가능하지만.)

그래도 왠지... ^^ 이거 말고 다른 방법이 없을까... 하는 의문이 들었습니다.

검색을 제법 하다가,,, 드디어 그럴싸한 방법을 하나 발견했습니다.

Recover from Abort on ServiceChannel 
; http://forums.microsoft.com/MSDN/ShowPost.aspx?PostID=1667130&SiteID=1

와... ^^ 꼭꼭 숨겨져 있는 기능을 찾은 기분입니다.

방법은, 간단합니다. OperationContext.Current.Channel.Faulted 이벤트와 OperationContext.Current.Channel.Closed 이벤트를 이용하는 것입니다. 이를 이용해서 서비스 측 코드를 다음과 같이 개선할 수 있습니다. (가만히 생각해 보면, 이것 역시 기본에 충실했으면 자연스럽게 알 수 있었을 내용이죠!)

public void StarDust()
{
  IMyServiceCallback callback = OperationContext.Current.GetCallbackChannel<IMyServiceCallback>();
  string id = OperationContext.Current.SessionId;

  OperationContext.Current.Channel.Faulted += new EventHandler(Channel_Faulted);
  OperationContext.Current.Channel.Closed += new EventHandler(Channel_Closed);

  lock (Service1.callbacks)
  {
    if (Service1.callbacks.ContainsKey(id) == false)
    {
      Service1.callbacks.Add(id, callback);
    }
  }
}

void Channel_Closed(object sender, EventArgs e)
{
  UnregistCallback(sender as IClientChannel, true);
}

void Channel_Faulted(object sender, EventArgs e)
{
  UnregistCallback(sender as IClientChannel, false);
}

void UnregistCallback(IClientChannel channel, bool closedGracefully)
{
  string txt = channel.SessionId;

  lock (Service1.callbacks)
  {
    if (Service1.callbacks.ContainsKey(txt) == true)
    {
      Service1.callbacks.Remove(txt);
      Console.WriteLine(txt + " : removed");
    }
  }
}

아쉽게도, Faulted/Closed 이벤트 핸들러에서의 OperationContext.Current는 null 값이지만, sender 값을 형변환해서 channel 정보를 받을 수 있기 때문에 해당 세션에 대한 다양한 정보를 구할 수가 있습니다. 또한, 비정상 종료를 하는 클라이언트 연결 개체까지도 모니터링 할 수 있기 때문에 경우에 따라서 클라이언트 측의 연결 중에 정상적으로 Close로 닫히지 않는 경우도 알아낼 수 있습니다.

참고로, 순서상으로 보면, Dispose 메서드가 먼저 실행되고 Closed/Faulted 이벤트 핸들러가 실행이 됩니다.

뭐... 이 정도면 되겠지요! ^^



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

[연관 글]






[최초 등록일: ]
[최종 수정일: 7/10/2021]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 작성자
 



2009-01-03 03시32분
[초보^^] 감사합니다!! 많은 도움이 되었습니다^^
[guest]
2009-01-03 07시59분
^^
kevin25
2009-11-05 12시48분
[초보] 안녕하세요 ^^

이글에 대한 질문이 있는데요..

클라이언트의 프로세스가 비정상적으로(예를 들면 프로세스가 죽어 버리는) 종료 되면

Closed, Faulted 이벤트 핸들러에도 안들어 오더라구요..

혹시 이런 상황에서 callback channl를 관리 하는 방법은 없나요 ???
[guest]
2009-11-05 01시15분
말씀하신 그런 부분은 모든 소켓 관련 로직에서 고민되는 부분입니다.
물론, WCF에서는 이에 대한 고려가 되어 있고 관련해서는 다음의 글을 참고하십시오.

netTcpBinding에서의 각종 Timeout 값 설명
; http://www.sysnet.pe.kr/2/0/536

위의 설명에서 receiveTimeout, inactivityTimeout 등의 설정이 "초보" 님이 원하시는 답입니다.
kevin25
2009-11-05 04시57분
[방금그초보] 답변 감사 합니다..

열심히 공부 해야 겠네요 ^^;;
[guest]

... 136  137  138  139  [140]  141  142  143  144  145  146  147  148  149  150  ...
NoWriterDateCnt.TitleFile(s)
1588정성태1/14/201431044Windows: 84. 윈도우 7/8 - 메뉴 항목이 잔상으로 남는 문제
1587정성태1/14/201427036디버깅 기술: 60. NT 서비스가 시작하자마자 디버거를 연결시키는 방법 (2)
1586정성태1/14/201428673디버깅 기술: 59. NT 서비스가 시작하자마자 디버거를 연결시키는 방법 (1) [1]
1585정성태1/14/201431614VS.NET IDE: 84. Visual Studio를 이용한 파일 비교(diff)
1584정성태1/13/201433679Windows: 83. 윈도우 8 - UI가 있는 프로그램을 Local SYSTEM 권한의 세션 0 데스크톱에서 실행하는 방법
1583정성태1/13/201432023Windows: 82. 윈도우 8 - "Interactive Services Detection" 서비스 시작하는 방법 [1]
1582정성태1/12/201430333개발 환경 구성: 210. 원격 데스크톱(RDP) 접속 프로그램 - Royal TS [1]
1581정성태1/12/201431691.NET Framework: 408. 자바와 닷넷의 제네릭 차이점 - 중간 언어 및 공변/반공변 처리 [8]
1580정성태1/12/201441730.NET Framework: 407. 닷넷 사용자 정의 예외 클래스의 최소 구현 코드 [1]
1579정성태1/12/201423578오류 유형: 207. System.ArgumentException was unhandled - Message=[net_WebHeaderInvalidControlChars]
1578정성태1/11/201435378개발 환경 구성: 209. Fiddler에서 WebSocket 통신을 모니터링하는 방법 [1]
1577정성태1/11/201425358오류 유형: 206. WriteFile Win32API 사용 시 비정상 종료 현상 [3]
1576정성태1/11/201443378Windows: 81. 긴 이름의 파일/폴더 삭제하는 법 [5]
1575정성태1/11/201423409오류 유형: 205. Exception calling "Provision" with "0" argument(s): "The timer job did not complete running within the allotted time."
1574정성태1/11/201425701오류 유형: 204. An unhandled exception ('System.Security.Cryptography.CryptographicException') occurred in OWSTIMER.EXE
1573정성태1/11/201423607오류 유형: 203. 이벤트 로그 에러 - MsiInstaller에서 Chart Controls 설치 관련 오류 발생
1572정성태1/9/201427111.NET Framework: 406. CoreLab - OraDirect .NET 사용법
1571정성태1/9/201423159.NET Framework: 405. override 메서드가 정의된 타입의 인스턴스로 base 메서드를 호출하는 방법 - 두 번째 이야기
1570정성태1/9/201426735Math: 11. C# 시뮬레이션 - 몬티홀 게임파일 다운로드1
1569정성태1/8/201423755Windows: 80. 윈도우 서버 백업의 복원하는 옵션 설명
1568정성태1/8/201424514오류 유형: 202. Hyper-V 서비스 시작 오류 - Not enough storage is available to complete this operation.
1567정성태1/8/201493950기타: 40. 오피스 2013 라이선스 리셋하는 방법 [5]
1566정성태1/7/201424821Windows: 79. 윈도우 8 - 스카이드라이브(skydrive)의 Online/Offline 동기화 방식 [1]
1565정성태1/3/201423324.NET Framework: 404. 리플렉션을 이용해 닷넷 LicenseManager를 우회할 수 있는 사례
1564정성태1/3/201423830.NET Framework: 403. override 메서드가 정의된 타입의 인스턴스로 base 메서드를 호출하는 방법파일 다운로드1
1563정성태1/3/201429592오류 유형: 201. ASP.NET 웹 사이트를 IIS 7 이상의 환경에서 호스팅할 때 500 오류 발생
... 136  137  138  139  [140]  141  142  143  144  145  146  147  148  149  150  ...