所以我有这个要求来启动在运行时提供给我的活动。为了促进这一点,我设置了一个 WorkflowService,它以 Xaml 的形式接收活动,为它们补充水分并启动它们。
听起来很简单...
...这是我在 Xaml 中的 WorkflowService
<Activity
x:Class="Workflow.Services.WorkflowService.WorkflowService"
...
xmlns:local1="clr-namespace:Workflow.Activities" >
<Sequence sap:VirtualizedContainerService.HintSize="277,272">
<Sequence.Variables>
<Variable x:TypeArguments="local:Workflow" Name="Workflow" />
</Sequence.Variables>
<sap:WorkflowViewStateService.ViewState>
<scg3:Dictionary x:TypeArguments="x:String, x:Object">
<x:Boolean x:Key="IsExpanded">True</x:Boolean>
</scg3:Dictionary>
</sap:WorkflowViewStateService.ViewState>
<p:Receive CanCreateInstance="True" DisplayName="ReceiveSubmitWorkflow" sap:VirtualizedContainerService.HintSize="255,86" OperationName="SubmitWorkflow" ServiceContractName="IWorkflowService">
<p:ReceiveParametersContent>
<OutArgument x:TypeArguments="local:Workflow" x:Key="workflow">[Workflow]</OutArgument>
</p:ReceiveParametersContent>
</p:Receive>
<local1:InvokeActivity Activity="[ActivityXamlServices.Load(New System.IO.StringReader(Workflow.Xaml))]" sap:VirtualizedContainerService.HintSize="255,22" />
</Sequence>
</Activity>
...除了重复使用“工作流程”之外,这非常简单。实际上,它只是一个Sequence
带有 aReceive
和 [当前] 一个名为InvokeActivity
. 稍等一下。
Receive
Activity 接受自定义类型,
[DataContract]
public class Workflow
{
[DataMember]
public string Xaml { get; set; }
}
其中包含一个字符串,其内容将被解释为 Xaml。您可以看到 VB 表达式,然后将该 Xaml 转换为 Activity 并将其传递。
现在第二点,习俗InvokeActivity
是我有问题的地方。
第一个问题:
1) 给定一个任意任务,在运行时提供 [如上所述] 是否可以使用 WF4RC 附带的活动来启动此活动,开箱即用?我是新手,我认为我在浏览 API 和现有文档方面做得很好,但不妨问一下 :)
第二:
2)我第一次尝试实现自定义InvokeActivity
看起来像这样
public sealed class InvokeActivity : NativeActivity
{
private static readonly ILog _log =
LogManager.GetLogger (typeof (InvokeActivity));
public InArgument<Activity> Activity { get; set; }
public InvokeActivity ()
{
_log.DebugFormat ("Instantiated.");
}
protected override void Execute (NativeActivityContext context)
{
Activity activity = Activity.Get (context);
_log.DebugFormat ("Scheduling activity [{0}]...", activity.DisplayName);
// throws exception to lack of metadata! :(
ActivityInstance instance =
context.ScheduleActivity (activity, OnComplete, OnFault);
_log.DebugFormat (
"Scheduled activity [{0}] with instance id [{1}].",
activity.DisplayName,
instance.Id);
}
protected override void CacheMetadata (NativeActivityMetadata metadata)
{
// how does one add InArgument<T> to metadata? not easily
// is my first guess
base.CacheMetadata (metadata);
}
// private methods
private void OnComplete (
NativeActivityContext context,
ActivityInstance instance)
{
_log.DebugFormat (
"Scheduled activity [{0}] with instance id [{1}] has [{2}].",
instance.Activity.DisplayName,
instance.Id,
instance.State);
}
private void OnFault (
NativeActivityFaultContext context,
Exception exception,
ActivityInstance instance)
{
_log.ErrorFormat (
@"Scheduled activity [{0}] with instance id [{1}] has faulted in state [{2}]
{3}",
instance.Activity.DisplayName,
instance.Id,
instance.State,
exception.ToStringFullStackTrace ());
}
}
它尝试在当前上下文中安排指定的活动。然而不幸的是,这失败了。当我尝试安排所述活动时,运行时返回并出现以下异常
在处理其元数据时,提供的活动不是此工作流定义的一部分。名为“DynamicActivity”的有问题的活动由名为“InvokeActivity”的活动提供。
对,所以运行时提供的“动态”Activity不是InvokeActivity
s元数据的成员。谷歌搜索并遇到了这个。无法理清如何指定InArgument<Activity>
元数据缓存,所以我的第二个问题自然是如何解决这个问题?不建议以context.ScheduleActivity (...)
这种方式使用吗?
第三次也是最后一次,
3)我暂时选择了这个[更简单的]解决方案,
public sealed class InvokeActivity : NativeActivity
{
private static readonly ILog _log =
LogManager.GetLogger (typeof (InvokeActivity));
public InArgument<Activity> Activity { get; set; }
public InvokeActivity ()
{
_log.DebugFormat ("Instantiated.");
}
protected override void Execute (NativeActivityContext context)
{
Activity activity = Activity.Get (context);
_log.DebugFormat ("Invoking activity [{0}] ...", activity.DisplayName);
// synchronous execution ... a little less than ideal, this
// seems heavy handed, and not entirely semantic-equivalent
// to what i want. i really want to invoke this runtime
// activity as if it were one of my own, not a separate
// process - wrong mentality?
WorkflowInvoker.Invoke (activity);
_log.DebugFormat ("Invoked activity [{0}].", activity.DisplayName);
}
}
它只是在自己的运行时实例中同步调用指定的任务 [使用 WF4 白话当然是有问题的]。最后,我想利用 WF 的跟踪和可能的持久性设施。所以我的第三个也是最后一个问题是,就我想做的[即启动从客户端应用程序入站的任意工作流]而言,这是首选方法吗?
好的,提前感谢您的时间和考虑:)