使用活动处理程序的事件驱动聊天

若要实现这些处理程序的逻辑，需要在机器人中重写这些方法，如以下示例活动处理程序部分中所示。 其中的每个处理程序没有基实现，因此，只需在重写中添加所需的逻辑。

在某些情况下，需要在轮次结束时重写基轮次处理程序，例如保存状态。 执行此操作时，请务必先调用 await base.OnTurnAsync(turnContext, cancellationToken);，以确保 OnTurnAsync 的基实现在其他代码之前运行。 除此之外，该基实现还负责调用剩余的活动处理程序，例如 OnMessageActivityAsync。

JavaScript ActivityHandler 使用事件发射器和侦听程序模式。 例如，使用 onMessage 方法为消息活动注册事件侦听器。 可以注册多个侦听器。 当机器人收到了某个消息活动时，活动处理程序将会看到该传入的活动，并将其发送到每个 onMessage 活动侦听器（按照其注册顺序）。

生成机器人时，用于处理和响应消息的机器人逻辑会进入 onMessage 侦听器。 同样，用于处理正在添加到聊天中的成员的逻辑会进入 onMembersAdded 侦听器。每次将成员添加到聊天时，都会调用该侦听器。 若要添加这些侦听器，需在机器人中注册它们，如下面的机器人逻辑部分所示。 对于每个侦听器，请包括机器人逻辑，并务必在最后调用 next() 。 调用 next() 可确保运行下一个侦听器。

确保在轮次结束之前保存状态。 为此，可以在父项的 run 方法完成后重写活动处理程序的 run 方法并保存状态。

只有在非常规的情况下才需要重写基轮次处理程序，因此，在尝试重写时请保持谨慎。 有一个称为 onDialog 的特殊处理程序。 onDialog 处理程序在剩余的处理程序运行之后才最后运行，与特定的活动类型无关。 与使用上述所有处理程序时一样，请务必调用 next() 来确保完成剩余的过程。

若要实现这些处理程序的逻辑，需要在机器人中重写这些方法，如以下示例活动处理程序部分中所示。 其中的每个处理程序没有基实现，因此，请在重写中添加所需的逻辑。

在某些情况下，需要在轮次结束时重写基轮次处理程序，例如保存状态。 执行此操作时，请务必先调用 super.onTurn(turnContext);，以确保 onTurn 的基实现在其他代码之前运行。 除此之外，该基实现还负责调用剩余的活动处理程序，例如 onMessageActivity。

生成机器人时，用于处理和响应消息的机器人逻辑将进入此 on_message_activity 处理程序。 同样，用于处理正在添加到聊天中的成员的逻辑将进入 on_members_added 处理程序，每次将成员添加到聊天时，都会调用该处理程序。

例如，如果机器人收到了某个消息活动，轮次处理程序将会看到该传入的活动，并将其发送到 on_message_activity 活动处理程序。

若要实现这些处理程序的逻辑，需要在机器人中重写这些方法，如以下示例活动处理程序部分中所示。 其中的每个处理程序没有基实现，因此，只需在重写中添加所需的逻辑。

在某些情况下，需要在轮次结束时重写基轮次处理程序，例如保存状态。 执行此操作时，请务必先调用 await super().on_turn(turnContext);，以确保 on_turn 的基实现在其他代码之前运行。 除此之外，该基实现还负责调用剩余的活动处理程序，例如 on_message_activity。

主要机器人逻辑在机器人代码中定义。 若要将机器人实现为活动处理程序，请从实现 IBot 接口的 ActivityHandler 派生 bot 类。 ActivityHandler 为不同类型的活动定义各种处理程序，例如 OnMessageActivityAsync 和 OnMembersAddedAsync。 这些方法受保护，但可将其重写，因为我们将从 ActivityHandler 派生。

ActivityHandler 中定义的处理程序为：

这些不同的处理程序具有一个 turnContext，用于提供有关对应于入站 HTTP 请求的传入活动的信息。 活动可以是各种类型，因此，每个处理程序在其轮次上下文参数中提供一个强类型化的活动，在大多数情况下，始终会处理 OnMessageActivityAsync。

与在此框架的 4.x 旧版中一样，还有一个选项可以实现公共方法 OnTurnAsync。 目前，此方法的基实现会处理错误检查，然后根据传入活动的类型调用每个特定的处理程序（例如本示例中定义的两个处理程序）。 在大多数情况下，可以不用理会该方法并使用单个处理程序，但如果你的情况要求使用 OnTurnAsync 的自定义实现，则仍可以考虑该方法。

主要机器人逻辑在机器人代码中定义。 若要将机器人实现为活动处理程序，请扩展 ActivityHandler。 ActivityHandler 为不同类型的活动定义各种事件，你可以使用特定方法（例如使用 onMessage 和 onConversationUpdate）通过注册事件侦听器来修改机器人的行为。

使用以下方法为每种类型的事件注册侦听器：

从每个处理程序调用 next 延续函数，这样就可以继续进行处理。 如果未调用 next，则活动处理结束。

主要机器人逻辑在机器人代码中定义。 若要将机器人实现为活动处理程序，请从实现 Bot 接口的 ActivityHandler 派生 bot 类。 ActivityHandler 为不同类型的活动定义各种处理程序，例如 onMessageActivity 和 onMembersAdded。 这些方法受保护，但可将其重写，因为我们将从 ActivityHandler 派生。

ActivityHandler 中定义的处理程序为：

这些不同的处理程序具有一个 turnContext，用于提供有关对应于入站 HTTP 请求的传入活动的信息。 活动可以是各种类型，因此，每个处理程序在其轮次上下文参数中提供一个强类型化的活动，在大多数情况下，始终会处理 onMessageActivity。

还可以选择实现公共方法 onTurn。 目前，此方法的基实现会处理错误检查，然后根据传入活动的类型调用每个特定的处理程序（例如本示例中定义的两个处理程序）。 在大多数情况下，可以不用理会该方法并使用单个处理程序，但如果你的情况要求使用 onTurn 的自定义实现，则仍可以考虑该方法。

主要机器人逻辑在机器人代码中定义。 若要将机器人实现为活动处理程序，请从 ActivityHandler 派生 bot 类，而后者又从抽象 Bot 类派生。 ActivityHandler 为不同类型的活动定义各种处理程序，例如 on_message_activity 和 on_members_added。 这些方法受保护，但可将其重写，因为我们将从 ActivityHandler 派生。

ActivityHandler 中定义的处理程序为：

这些不同的处理程序具有一个 turn_context，用于提供有关对应于入站 HTTP 请求的传入活动的信息。 活动可以是各种类型，因此，每个处理程序在其轮次上下文参数中提供一个强类型化的活动，在大多数情况下，始终会处理 on_message_activity。

与在此框架的 4.x 旧版中一样，还有一个选项可以实现公共方法 on_turn。 目前，此方法的基实现会处理错误检查，然后根据传入活动的类型调用每个特定的处理程序（例如本示例中定义的两个处理程序）。 在大多数情况下，可以不用理会该方法并使用单个处理程序，但如果你的情况要求使用 on_turn 的自定义实现，则仍可以考虑该方法。

public class EchoBot : ActivityHandler
{
    protected override async Task OnMessageActivityAsync(ITurnContext<IMessageActivity> turnContext, CancellationToken cancellationToken)
    {
        var replyText = $"Echo: {turnContext.Activity.Text}";
        await turnContext.SendActivityAsync(MessageFactory.Text(replyText, replyText), cancellationToken);
    }

    protected override async Task OnMembersAddedAsync(IList<ChannelAccount> membersAdded, ITurnContext<IConversationUpdateActivity> turnContext, CancellationToken cancellationToken)
    {
        var welcomeText = "Hello and welcome!";
        foreach (var member in membersAdded)
        {
            if (member.Id != turnContext.Activity.Recipient.Id)
            {
                await turnContext.SendActivityAsync(MessageFactory.Text(welcomeText, welcomeText), cancellationToken);
            }
        }
    }
}

class EchoBot extends ActivityHandler {
    constructor() {
        super();
        // See https://aka.ms/about-bot-activity-message to learn more about the message and other activity types.
        this.onMessage(async (context, next) => {
            const replyText = `Echo: ${ context.activity.text }`;
            await context.sendActivity(MessageFactory.text(replyText, replyText));
            // By calling next() you ensure that the next BotHandler is run.
            await next();
        });

        this.onMembersAdded(async (context, next) => {
            const membersAdded = context.activity.membersAdded;
            const welcomeText = 'Hello and welcome!';
            for (let cnt = 0; cnt < membersAdded.length; ++cnt) {
                if (membersAdded[cnt].id !== context.activity.recipient.id) {
                    await context.sendActivity(MessageFactory.text(welcomeText, welcomeText));
                }
            }
            // By calling next() you ensure that the next BotHandler is run.
            await next();
        });
    }
}

public class EchoBot extends ActivityHandler {

    @Override
    protected CompletableFuture<Void> onMessageActivity(TurnContext turnContext) {
        return turnContext.sendActivity(
            MessageFactory.text("Echo: " + turnContext.getActivity().getText())
        ).thenApply(sendResult -> null);
    }

    @Override
    protected CompletableFuture<Void> onMembersAdded(
        List<ChannelAccount> membersAdded,
        TurnContext turnContext
    ) {
        String welcomeText = "Hello and welcome!";
        return membersAdded.stream()
            .filter(
                member -> !StringUtils
                    .equals(member.getId(), turnContext.getActivity().getRecipient().getId())
            ).map(channel -> turnContext.sendActivity(MessageFactory.text(welcomeText, welcomeText, null)))
            .collect(CompletableFutures.toFutureList()).thenApply(resourceResponses -> null);
    }
}

class EchoBot(ActivityHandler):
    async def on_members_added_activity(
        self, members_added: [ChannelAccount], turn_context: TurnContext
    ):
        for member in members_added:
            if member.id != turn_context.activity.recipient.id:
                await turn_context.send_activity("Hello and welcome!")

    async def on_message_activity(self, turn_context: TurnContext):
        return await turn_context.send_activity(
            MessageFactory.text(f"Echo: {turn_context.activity.text}")
        )