private UserEndpointSettings CreateUserSetting()
{
UserEndpointSettings userSetting = null;
try
{
userSetting = new UserEndpointSettings(this._strUserURI, this._strServerFQDN);
userSetting.Credential = new NetworkCredential(this._strUserName, this._strUserPassword, this._strUserDomain);
}
catch (InvalidOperationException ex)
{
userSetting = null;
LogUtility.GetInstance().Error(MethodBase.GetCurrentMethod(), "UserEndpointSettings初始化错误。");
LogUtility.GetInstance().Debug(MethodBase.GetCurrentMethod(), "UserEndpointSettings初始化错误:\r\n" + ex.ToString());
}
return userSetting;
}
创建UserEndpoint
private UserEndpoint CreateUserEndpoint(UserEndpointSettings userEndpointSettings)
{
try
{
ClientPlatformSettings clientPlatformSettings = new ClientPlatformSettings(ConstInfo.SERVICE_NAME, _transportType);
this._collabPlatform = new CollaborationPlatform(clientPlatformSettings);
this._collabPlatform.InstantMessagingSettings.SupportedFormats = InstantMessagingFormat.HtmlText;
this._userEndpoint = new UserEndpoint(_collabPlatform, userEndpointSettings);
}
catch (Exception ex)
{
_userEndpoint = null;
LogUtility.GetInstance().Error(MethodBase.GetCurrentMethod(), "创建UserEndpoint错误。");
LogUtility.GetInstance().Debug(MethodBase.GetCurrentMethod(), "创建UserEndpoint错误:\r\n" + ex.ToString());
}
return _userEndpoint;
}
private void EstablishUserEndpoint(UserEndpoint userEndpoint)
{
try
{
// Startup the platform
userEndpoint.Platform.BeginStartup(this.EndPlatformStartup, userEndpoint.Platform);
// Again, just for sync. reasons.
_platformStartupCompleted.WaitOne();
// Establish the user endpoint
userEndpoint.BeginEstablish(EndEndpointEstablish, userEndpoint);
// Sync; wait for the registration to complete.
_endpointInitCompletedEvent.WaitOne();
}
catch (Exception ex)
{
LogUtility.GetInstance().Error(MethodBase.GetCurrentMethod(), "EstablishUserEndpoint错误。");
LogUtility.GetInstance().Debug(MethodBase.GetCurrentMethod(), "EstablishUserEndpoint错误:\r\n" + ex.ToString());
}
}
private void EndPlatformStartup(IAsyncResult ar)
{
CollaborationPlatform collabPlatform = ar.AsyncState as CollaborationPlatform;
try
{
// The platform should now be started.
collabPlatform.EndStartup(ar);
}
catch (Exception ex)
{
LogUtility.GetInstance().Error(MethodBase.GetCurrentMethod(), "EndStartup调用异常。");
LogUtility.GetInstance().Debug(MethodBase.GetCurrentMethod(), "EndStartup调用异常:\r\n" + ex.ToString());
}
finally
{
// Again, just for sync. reasons.
_platformStartupCompleted.Set();
}
}
private void EndEndpointEstablish(IAsyncResult ar)
{
LocalEndpoint currentEndpoint = ar.AsyncState as LocalEndpoint;
try
{
currentEndpoint.EndEstablish(ar);
}
catch (Exception ex)
{
LogUtility.GetInstance().Error(MethodBase.GetCurrentMethod(), "EndEstablish调用异常。");
LogUtility.GetInstance().Debug(MethodBase.GetCurrentMethod(), "EndEstablish调用异常:\r\n" + ex.ToString());
}
finally
{
// Again, just for sync. reasons.
_endpointInitCompletedEvent.Set();
}
}
建立对话并捕获对话状态，根据状态发送消息。
//Init Conversation and InstantMessagingCall
Conversation conversation = new Conversation(_userEndpoint, _convSettings);
_instantMessagingCall = new InstantMessagingCall(conversation);
//Binding Event
_instantMessagingCall.InstantMessagingFlowConfigurationRequested +=
this.InstantMessagingCall_FlowConfigurationRequested;
//Establish instantMessagingCall
_instantMessagingCall.BeginEstablish(string.Format(ConstInfo.FORMAT_SIP_USER, strUser), null,
CallEstablishCompleted, _instantMessagingCall);
//Wait for Sending message
_conversationCompletedEvent.WaitOne();
//Wait for establishing InstantMessagingCall;
_establishCompletedEvent.WaitOne();
private void InstantMessagingCall_FlowConfigurationRequested(object sender,
InstantMessagingFlowConfigurationRequestedEventArgs e)
{
try
{
_instantMessagingFlow = e.Flow;
// Now that the flow is non-null, bind the event handlers for State
// Changed and Message Received. When the flow goes active,
// (as indicated by the state changed event) the program will send
// the IM in the event handler.
_instantMessagingFlow.StateChanged += this.InstantMessagingFlow_StateChanged;
}
catch (Exception ex)
{
try
{
if (_drInstantMessage != null)
{
DBProxy.InsertExceptionInfo(_drInstantMessage);
_drInstantMessage = null;
}
}
catch (Exception dbEx)
{
}
}
}
private void InstantMessagingFlow_StateChanged(object sender, MediaFlowStateChangedEventArgs e)
{
try
{
// When flow is active, media operations (here, sending an IM)
// may begin.
if (e.State == MediaFlowState.Active)
{
// Send the message on the InstantMessagingFlow.
if (_strContent.Contains(ConstInfo.HTML_TEXT_FLAG))
{
byte[] htmlByte = Encoding.UTF8.GetBytes(_strContent.Replace(ConstInfo.HTML_TEXT_FLAG, string.Empty));
_instantMessagingFlow.BeginSendInstantMessage(new System.Net.Mime.ContentType("text/html"), htmlByte,
SendMessageCompleted, _instantMessagingFlow);
}
else
{
_instantMessagingFlow.BeginSendInstantMessage(_strContent, SendMessageCompleted,
_instantMessagingFlow);
}
}
else if (e.State == MediaFlowState.Terminated)
{
_conversationCompletedEvent.Set();
}
}
catch (Exception ex)
{
if (e.State == MediaFlowState.Active)
{
_conversationCompletedEvent.Set();
}
else if (e.State == MediaFlowState.Terminated)
{
_conversationCompletedEvent.Set();
}
}
}
本人可以做lync开发兼职，QQ106888270