工作流程：
1.客户端发起gettask请求。
2.服务端从数据库中得到任务后调用回调sendtask把任务送到客户端。
问题：
正常情况下该流程没有问题，但如果我把服务端关掉后再打开（网线拔了再插上也一样），第1步调用没问题，第2步总是报如下错“http://schemas.microsoft.com/2005/12/ServiceModel/Addressing/Anonymous 的请求操作在配置的超时(00:02:00)内未收到回复。分配给该操作的时间可能是更长超时的一部分。这可能由于服务仍在处理操作或服务无法发送回复消息。请考虑增加操作超时(将通道/代理转换为 IContextChannel 并设置 OperationTimeout 属性)并确保服务能够连接到客户端。”---感觉回调被阻塞一样。
服务端相关代码：
[ServiceContract(CallbackContract = typeof(ITaskCallback), SessionMode = SessionMode.Required)]
public interface ITasksService
{
[OperationContract(IsOneWay = true)]
void getTask(Task task);
}
//回调
public interface ITaskCallback
{
[OperationContract]
bool SendTask(Task task);
}
[ServiceBehavior(InstanceContextMode = InstanceContextMode.PerSession, ConcurrencyMode = ConcurrencyMode.Multiple)]
// NOTE: If you change the class name "TasksService" here, you must also update the reference to "TasksService" in App.config.
public class TasksService : ITasksService
{
private string IP = "";
public void getTask(Task task)
{
Business.addLog(">>getTask", task.OperID, 2);
Business bs = new Business();
task.TaskXml = "";
string taskXML = bs.getTaskXML(ref task);
if (taskXML.Length > 0)
{
bs.saveToRECOperWorkInfo(task.OperID, task.ID, task.SkillID, task.BatchID);
}
Business.addLog("<<getTask", task.OperID, 2);
try
{
if (callback.SendTask(task))
Business.addLog("发送任务成功" + task.ID, task.OperID, 1);
else
{
if (taskXML.Length > 0)
workMoveBack(task.OperID, task.WorkID, task.BatchID, 'M');
}
}
catch (System.Exception e)
{
Business.addLog("发送任务失败:" + task.ID + e.Message, task.OperID, 1);
if (taskXML.Length > 0)
workMoveBack(task.OperID, task.WorkID, task.BatchID, 'M');
}
}
#region WCF回调接口:
ITaskCallback callback
{
get { return OperationContext.Current.GetCallbackChannel<ITaskCallback>(); }
}
#endregion
}
客户端回调代码：
public class CallbackHandler : ITasksServiceCallback
{
public bool SendTask(InputTest.Test.Task task)
{
try
{
if (Form1.nBaseID != task.BaseID)
{
Business.addLog("BaseID不相等：" + task.ID + " Form1.nBaseID=" + Form1.nBaseID.ToString() + " task.BaseID=" + task.BaseID.ToString(),1,0);
return false;
}
else
{
Form1.m_NewTask = task;
Business.addLog("引擎送来任务：" + task.ID + " nBaseID=" + task.BaseID.ToString(), 1, 0);
Form1.getTaskEvent.Set();
return true;
}
}
catch (Exception e)
{
Business.addLog("回调异常：" + e.Message, 1, 0);
return false;
}
}
}
