在数据流组件中引发和定义事件

调用 EventInfos 集合的 Add 方法可创建自定义事件。此集合由数据流任务设置，并作为属性通过 PipelineComponent 基类提供给组件开发人员。此类包含调用 RegisterEvents 方法的过程中由数据流任务定义的自定义事件和组件定义的自定义事件。

组件的自定义事件不会持久保留在包 XML 中。因此，在设计和执行过程中都调用 RegisterEvents 方法，以允许组件定义所引发的事件。

Add 方法的 allowEventHandlers 参数指定组件是否允许为事件创建 DtsEventHandler 对象。请注意，DtsEventHandlers 是同步的。因此，直到附加到自定义事件的 DtsEventHandler 执行完毕后，组件才会继续执行。如果 allowEventHandlers 参数为 true，则任何 DtsEventHandler 对象都可以通过由 SQL Server Integration Services 运行时自动创建和填充的变量使用事件的每个参数。

通过调用 FireCustomEvent 方法并提供事件的名称、文本和参数，组件可引发自定义事件。如果 allowEventHandlers 参数为 true，则为自定义事件创建的所有 DtsEventHandlers 都由 SSIS 运行时引擎执行。

下面的代码示例演示了在 RegisterEvents 方法中定义自定义事件，然后通过调用 FireCustomEvent 方法在运行时引发该事件的组件。

public override void RegisterEvents()
{
    string [] parameterNames = new string[2]{"RowCount", "StartTime"};
    ushort [] parameterTypes = new ushort[2]{ DtsConvert.VarTypeFromTypeCode(TypeCode.Int32), DtsConvert.VarTypeFromTypeCode(TypeCode.DateTime)};
    string [] parameterDescriptions = new string[2]{"The number of rows to sort.", "The start time of the Sort operation."};
    EventInfos.Add("StartingSort","Fires when the component begins sorting the rows.",false,ref parameterNames, ref paramterTypes, ref parameterDescriptions);
}
public override void ProcessInput(int inputID, PipelineBuffer buffer)
{
    while (buffer.NextRow())
    {
       // Process buffer rows.
    }

    IDTSEventInfo100 eventInfo = EventInfos["StartingSort"];
    object []arguments = new object[2]{buffer.RowCount, DateTime.Now };
    ComponentMetaData.FireCustomEvent("StartingSort", "Beginning sort operation.", ref arguments, ComponentMetaData.Name, ref FireSortEventAgain);
}

Public  Overrides Sub RegisterEvents() 
  Dim parameterNames As String() = New String(2) {"RowCount", "StartTime"} 
  Dim parameterTypes As System.UInt16() = New System.UInt16(2) {DtsConvert.VarTypeFromTypeCode(TypeCode.Int32), DtsConvert.VarTypeFromTypeCode(TypeCode.DateTime)} 
  Dim parameterDescriptions As String() = New String(2) {"The number of rows to sort.", "The start time of the Sort operation."} 
  EventInfos.Add("StartingSort", "Fires when the component begins sorting the rows.", False, parameterNames, paramterTypes, parameterDescriptions) 
End Sub 

Public  Overrides Sub ProcessInput(ByVal inputID As Integer, ByVal buffer As PipelineBuffer) 
  While buffer.NextRow 
  End While 
  Dim eventInfo As IDTSEventInfo100 = EventInfos("StartingSort") 
  Dim arguments As Object() = New Object(2) {buffer.RowCount, DateTime.Now} 
  ComponentMetaData.FireCustomEvent("StartingSort", _
    "Beginning sort operation.", arguments, _
    ComponentMetaData.Name, FireSortEventAgain) 
End Sub