diff --git a/apps/application/flow/step_node/__init__.py b/apps/application/flow/step_node/__init__.py
index f3602901aa5..0ce1d5fedd1 100644
--- a/apps/application/flow/step_node/__init__.py
+++ b/apps/application/flow/step_node/__init__.py
@@ -25,13 +25,14 @@
 from .start_node import *
 from .text_to_speech_step_node.impl.base_text_to_speech_node import BaseTextToSpeechNode
 from .variable_assign_node import BaseVariableAssignNode
+from .mcp_node import BaseMcpNode
 
 node_list = [BaseStartStepNode, BaseChatNode, BaseSearchDatasetNode, BaseQuestionNode,
              BaseConditionNode, BaseReplyNode,
              BaseFunctionNodeNode, BaseFunctionLibNodeNode, BaseRerankerNode, BaseApplicationNode,
              BaseDocumentExtractNode,
              BaseImageUnderstandNode, BaseFormNode, BaseSpeechToTextNode, BaseTextToSpeechNode,
-             BaseImageGenerateNode, BaseVariableAssignNode]
+             BaseImageGenerateNode, BaseVariableAssignNode, BaseMcpNode]
 
 
 def get_node(node_type):
diff --git a/apps/application/flow/step_node/ai_chat_step_node/i_chat_node.py b/apps/application/flow/step_node/ai_chat_step_node/i_chat_node.py
index 336753450fa..a83d2ef5771 100644
--- a/apps/application/flow/step_node/ai_chat_step_node/i_chat_node.py
+++ b/apps/application/flow/step_node/ai_chat_step_node/i_chat_node.py
@@ -33,6 +33,9 @@ class ChatNodeSerializer(serializers.Serializer):
                                           error_messages=ErrMessage.dict('Model settings'))
     dialogue_type = serializers.CharField(required=False, allow_blank=True, allow_null=True,
                                           error_messages=ErrMessage.char(_("Context Type")))
+    mcp_enable = serializers.BooleanField(required=False,
+                                         error_messages=ErrMessage.boolean(_("Whether to enable MCP")))
+    mcp_servers = serializers.JSONField(required=False, error_messages=ErrMessage.list(_("MCP Server")))
 
 
 class IChatNode(INode):
@@ -49,5 +52,7 @@ def execute(self, model_id, system, prompt, dialogue_number, history_chat_record
                 model_params_setting=None,
                 dialogue_type=None,
                 model_setting=None,
+                mcp_enable=False,
+                mcp_servers=None,
                 **kwargs) -> NodeResult:
         pass
diff --git a/apps/application/flow/step_node/ai_chat_step_node/impl/base_chat_node.py b/apps/application/flow/step_node/ai_chat_step_node/impl/base_chat_node.py
index 7da004822fe..ae84c4bbbd7 100644
--- a/apps/application/flow/step_node/ai_chat_step_node/impl/base_chat_node.py
+++ b/apps/application/flow/step_node/ai_chat_step_node/impl/base_chat_node.py
@@ -6,14 +6,19 @@
     @date：2024/6/4 14:30
     @desc:
 """
+import asyncio
+import json
 import re
 import time
 from functools import reduce
+from types import AsyncGeneratorType
 from typing import List, Dict
 
 from django.db.models import QuerySet
 from langchain.schema import HumanMessage, SystemMessage
-from langchain_core.messages import BaseMessage, AIMessage
+from langchain_core.messages import BaseMessage, AIMessage, AIMessageChunk, ToolMessage
+from langchain_mcp_adapters.client import MultiServerMCPClient
+from langgraph.prebuilt import create_react_agent
 
 from application.flow.i_step_node import NodeResult, INode
 from application.flow.step_node.ai_chat_step_node.i_chat_node import IChatNode
@@ -56,6 +61,7 @@ def write_context_stream(node_variable: Dict, workflow_variable: Dict, node: INo
     reasoning = Reasoning(model_setting.get('reasoning_content_start', '<think>'),
                           model_setting.get('reasoning_content_end', '</think>'))
     response_reasoning_content = False
+
     for chunk in response:
         reasoning_chunk = reasoning.get_reasoning_content(chunk)
         content_chunk = reasoning_chunk.get('content')
@@ -84,6 +90,47 @@ def write_context_stream(node_variable: Dict, workflow_variable: Dict, node: INo
     _write_context(node_variable, workflow_variable, node, workflow, answer, reasoning_content)
 
 
+
+async def _yield_mcp_response(chat_model, message_list, mcp_servers):
+    async with MultiServerMCPClient(json.loads(mcp_servers)) as client:
+        agent = create_react_agent(chat_model, client.get_tools())
+        response = agent.astream({"messages": message_list}, stream_mode='messages')
+        async for chunk in response:
+            # if isinstance(chunk[0], ToolMessage):
+            #     print(chunk[0])
+            if isinstance(chunk[0], AIMessageChunk):
+                yield chunk[0]
+
+def mcp_response_generator(chat_model, message_list, mcp_servers):
+    loop = asyncio.new_event_loop()
+    try:
+        async_gen = _yield_mcp_response(chat_model, message_list, mcp_servers)
+        while True:
+            try:
+                chunk = loop.run_until_complete(anext_async(async_gen))
+                yield chunk
+            except StopAsyncIteration:
+                break
+    except Exception as e:
+        print(f'exception: {e}')
+    finally:
+        loop.close()
+
+async def anext_async(agen):
+    return await agen.__anext__()
+
+async def _get_mcp_response(chat_model, message_list, mcp_servers):
+    async with MultiServerMCPClient(json.loads(mcp_servers)) as client:
+        agent = create_react_agent(chat_model, client.get_tools())
+        response = agent.astream({"messages": message_list}, stream_mode='messages')
+        result = []
+        async for chunk in response:
+            # if isinstance(chunk[0], ToolMessage):
+            #     print(chunk[0].content)
+            if isinstance(chunk[0], AIMessageChunk):
+                result.append(chunk[0])
+        return result
+
 def write_context(node_variable: Dict, workflow_variable: Dict, node: INode, workflow):
     """
     写入上下文数据
@@ -142,6 +189,8 @@ def execute(self, model_id, system, prompt, dialogue_number, history_chat_record
                 model_params_setting=None,
                 dialogue_type=None,
                 model_setting=None,
+                mcp_enable=False,
+                mcp_servers=None,
                 **kwargs) -> NodeResult:
         if dialogue_type is None:
             dialogue_type = 'WORKFLOW'
@@ -163,6 +212,14 @@ def execute(self, model_id, system, prompt, dialogue_number, history_chat_record
         self.context['system'] = system
         message_list = self.generate_message_list(system, prompt, history_message)
         self.context['message_list'] = message_list
+
+        if mcp_enable and mcp_servers is not None:
+            r = mcp_response_generator(chat_model, message_list, mcp_servers)
+            return NodeResult(
+                {'result': r, 'chat_model': chat_model, 'message_list': message_list,
+                 'history_message': history_message, 'question': question.content}, {},
+                _write_context=write_context_stream)
+
         if stream:
             r = chat_model.stream(message_list)
             return NodeResult({'result': r, 'chat_model': chat_model, 'message_list': message_list,
diff --git a/apps/application/flow/step_node/mcp_node/__init__.py b/apps/application/flow/step_node/mcp_node/__init__.py
new file mode 100644
index 00000000000..f3feecc9ce2
--- /dev/null
+++ b/apps/application/flow/step_node/mcp_node/__init__.py
@@ -0,0 +1,3 @@
+# coding=utf-8
+
+from .impl import *
diff --git a/apps/application/flow/step_node/mcp_node/i_mcp_node.py b/apps/application/flow/step_node/mcp_node/i_mcp_node.py
new file mode 100644
index 00000000000..94cb4da7729
--- /dev/null
+++ b/apps/application/flow/step_node/mcp_node/i_mcp_node.py
@@ -0,0 +1,35 @@
+# coding=utf-8
+
+from typing import Type
+
+from rest_framework import serializers
+
+from application.flow.i_step_node import INode, NodeResult
+from common.util.field_message import ErrMessage
+from django.utils.translation import gettext_lazy as _
+
+
+class McpNodeSerializer(serializers.Serializer):
+    mcp_servers = serializers.JSONField(required=True,
+                                        error_messages=ErrMessage.char(_("Mcp servers")))
+
+    mcp_server = serializers.CharField(required=True,
+                                       error_messages=ErrMessage.char(_("Mcp server")))
+
+    mcp_tool = serializers.CharField(required=True, error_messages=ErrMessage.char(_("Mcp tool")))
+
+    tool_params = serializers.DictField(required=True,
+                                        error_messages=ErrMessage.char(_("Tool parameters")))
+
+
+class IMcpNode(INode):
+    type = 'mcp-node'
+
+    def get_node_params_serializer_class(self) -> Type[serializers.Serializer]:
+        return McpNodeSerializer
+
+    def _run(self):
+        return self.execute(**self.node_params_serializer.data, **self.flow_params_serializer.data)
+
+    def execute(self, mcp_servers, mcp_server, mcp_tool, tool_params, **kwargs) -> NodeResult:
+        pass
diff --git a/apps/application/flow/step_node/mcp_node/impl/__init__.py b/apps/application/flow/step_node/mcp_node/impl/__init__.py
new file mode 100644
index 00000000000..8c9a5ee197c
--- /dev/null
+++ b/apps/application/flow/step_node/mcp_node/impl/__init__.py
@@ -0,0 +1,3 @@
+# coding=utf-8
+
+from .base_mcp_node import BaseMcpNode
diff --git a/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py b/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py
new file mode 100644
index 00000000000..b3c1f2d9bed
--- /dev/null
+++ b/apps/application/flow/step_node/mcp_node/impl/base_mcp_node.py
@@ -0,0 +1,56 @@
+# coding=utf-8
+import asyncio
+import json
+from typing import List
+
+from langchain_mcp_adapters.client import MultiServerMCPClient
+
+from application.flow.i_step_node import NodeResult
+from application.flow.step_node.mcp_node.i_mcp_node import IMcpNode
+
+
+class BaseMcpNode(IMcpNode):
+    def save_context(self, details, workflow_manage):
+        self.context['result'] = details.get('result')
+        self.context['tool_params'] = details.get('tool_params')
+        self.context['mcp_tool'] = details.get('mcp_tool')
+        self.answer_text = details.get('result')
+
+    def execute(self, mcp_servers, mcp_server, mcp_tool, tool_params, **kwargs) -> NodeResult:
+        servers = json.loads(mcp_servers)
+        params = self.handle_variables(tool_params)
+
+        async def call_tool(s, session, t, a):
+            async with MultiServerMCPClient(s) as client:
+                s = await client.sessions[session].call_tool(t, a)
+                return s
+
+        res = asyncio.run(call_tool(servers, mcp_server, mcp_tool, params))
+        return NodeResult({'result': [content.text for content in res.content], 'tool_params': params, 'mcp_tool': mcp_tool}, {})
+
+    def handle_variables(self, tool_params):
+        # 处理参数中的变量
+        for k, v in tool_params.items():
+            if type(v) == str:
+                tool_params[k] = self.workflow_manage.generate_prompt(tool_params[k])
+            if type(v) == dict:
+                self.handle_variables(v)
+        return tool_params
+
+    def get_reference_content(self, fields: List[str]):
+        return str(self.workflow_manage.get_reference_field(
+            fields[0],
+            fields[1:]))
+
+    def get_details(self, index: int, **kwargs):
+        return {
+            'name': self.node.properties.get('stepName'),
+            "index": index,
+            'run_time': self.context.get('run_time'),
+            'status': self.status,
+            'err_message': self.err_message,
+            'type': self.node.type,
+            'mcp_tool': self.context.get('mcp_tool'),
+            'tool_params': self.context.get('tool_params'),
+            'result': self.context.get('result'),
+        }
diff --git a/apps/application/serializers/application_serializers.py b/apps/application/serializers/application_serializers.py
index 69d518cfd1c..514a9e5f00a 100644
--- a/apps/application/serializers/application_serializers.py
+++ b/apps/application/serializers/application_serializers.py
@@ -6,6 +6,7 @@
     @date：2023/11/7 10:02
     @desc:
 """
+import asyncio
 import datetime
 import hashlib
 import json
@@ -23,6 +24,8 @@
 from django.db.models.expressions import RawSQL
 from django.http import HttpResponse
 from django.template import Template, Context
+from langchain_mcp_adapters.client import MultiServerMCPClient
+from mcp.client.sse import sse_client
 from rest_framework import serializers, status
 from rest_framework.utils.formatting import lazy_format
 
@@ -1305,3 +1308,28 @@ def edit(self, instance, with_valid=True):
                 application_api_key.save()
                 # 写入缓存
                 get_application_api_key(application_api_key.secret_key, False)
+
+    class McpServers(serializers.Serializer):
+        mcp_servers = serializers.JSONField(required=True)
+
+        def get_mcp_servers(self, with_valid=True):
+            if with_valid:
+                self.is_valid(raise_exception=True)
+            servers = json.loads(self.data.get('mcp_servers'))
+
+            async def get_mcp_tools(servers):
+                async with MultiServerMCPClient(servers) as client:
+                    return client.get_tools()
+
+            tools = []
+            for server in servers:
+                tools += [
+                    {
+                        'server': server,
+                        'name': tool.name,
+                        'description': tool.description,
+                        'args_schema': tool.args_schema,
+                    }
+                    for tool in asyncio.run(get_mcp_tools({server: servers[server]}))]
+            return tools
+
diff --git a/apps/application/urls.py b/apps/application/urls.py
index 6dc2ae5af63..b294289541e 100644
--- a/apps/application/urls.py
+++ b/apps/application/urls.py
@@ -9,6 +9,7 @@
     path('application/profile', views.Application.Profile.as_view(), name='application/profile'),
     path('application/embed', views.Application.Embed.as_view()),
     path('application/authentication', views.Application.Authentication.as_view()),
+    path('application/mcp_servers', views.Application.McpServers.as_view()),
     path('application/<str:application_id>/publish', views.Application.Publish.as_view()),
     path('application/<str:application_id>/edit_icon', views.Application.EditIcon.as_view()),
     path('application/<str:application_id>/export', views.Application.Export.as_view()),
diff --git a/apps/application/views/application_views.py b/apps/application/views/application_views.py
index ab97de6262e..991a6f4d5dc 100644
--- a/apps/application/views/application_views.py
+++ b/apps/application/views/application_views.py
@@ -700,3 +700,13 @@ def post(self, request: Request, application_id: str):
                 data={'application_id': application_id, 'user_id': request.user.id}).play_demo_text(request.data)
             return HttpResponse(byte_data, status=200, headers={'Content-Type': 'audio/mp3',
                                                                 'Content-Disposition': 'attachment; filename="abc.mp3"'})
+
+    class McpServers(APIView):
+        authentication_classes = [TokenAuth]
+
+        @action(methods=['GET'], detail=False)
+        @has_permissions(PermissionConstants.APPLICATION_READ, compare=CompareConstants.AND)
+        @log(menu='Application', operate="Get the MCP server tools")
+        def get(self, request: Request):
+            return result.success(ApplicationSerializer.McpServers(
+                data={'mcp_servers': request.query_params.get('mcp_servers')}).get_mcp_servers())
diff --git a/ui/src/api/application.ts b/ui/src/api/application.ts
index a85b031c00f..efd4a4985a8 100644
--- a/ui/src/api/application.ts
+++ b/ui/src/api/application.ts
@@ -350,6 +350,13 @@ const getFunctionLib: (
   return get(`${prefix}/${application_id}/function_lib/${function_lib_id}`, undefined, loading)
 }
 
+const getMcpTools: (
+  data: any,
+  loading?: Ref<boolean>
+) => Promise<Result<any>> = (data, loading) => {
+  return get(`${prefix}/mcp_servers`, data, loading)
+}
+
 const getApplicationById: (
   application_id: String,
   app_id: String,
@@ -576,5 +583,6 @@ export default {
   uploadFile,
   exportApplication,
   importApplication,
-  getApplicationById
+  getApplicationById,
+  getMcpTools
 }
diff --git a/ui/src/components/ai-chat/ExecutionDetailDialog.vue b/ui/src/components/ai-chat/ExecutionDetailDialog.vue
index cfb6f54d0ae..c36e36e52c6 100644
--- a/ui/src/components/ai-chat/ExecutionDetailDialog.vue
+++ b/ui/src/components/ai-chat/ExecutionDetailDialog.vue
@@ -639,6 +639,40 @@
                       </div>
                     </div>
                   </template>
+
+                  <!-- MCP 节点 -->
+                  <template v-if="item.type === WorkflowType.McpNode">
+                    <div class="card-never border-r-4">
+                      <h5 class="p-8-12">
+                        {{ $t('views.applicationWorkflow.nodes.mcpNode.tool') }}
+                      </h5>
+                      <div class="p-8-12 border-t-dashed lighter">
+                        <div class="mb-8">
+                          <span class="color-secondary"> {{ $t('views.applicationWorkflow.nodes.mcpNode.tool') }}: </span> {{ item.mcp_tool }}
+                        </div>
+                      </div>
+                    </div>
+                    <div class="card-never border-r-4">
+                      <h5 class="p-8-12">
+                        {{ $t('views.applicationWorkflow.nodes.mcpNode.toolParam') }}
+                      </h5>
+                      <div class="p-8-12 border-t-dashed lighter">
+                        <div v-for="(value, name) in item.tool_params" :key="name" class="mb-8">
+                          <span class="color-secondary">{{ name }}:</span> {{ value }}
+                        </div>
+                      </div>
+                    </div>
+                    <div class="card-never border-r-4">
+                      <h5 class="p-8-12">
+                        {{ $t('common.param.outputParam') }}
+                      </h5>
+                      <div class="p-8-12 border-t-dashed lighter">
+                        <div v-for="(f, i) in item.result" :key="i" class="mb-8">
+                          <span class="color-secondary">result:</span> {{ f }}
+                        </div>
+                      </div>
+                    </div>
+                  </template>
                 </template>
                 <template v-else>
                   <div class="card-never border-r-4">
diff --git a/ui/src/enums/workflow.ts b/ui/src/enums/workflow.ts
index bcd83a05929..f3e6649a0b3 100644
--- a/ui/src/enums/workflow.ts
+++ b/ui/src/enums/workflow.ts
@@ -16,5 +16,6 @@ export enum WorkflowType {
   FormNode = 'form-node',
   TextToSpeechNode = 'text-to-speech-node',
   SpeechToTextNode = 'speech-to-text-node',
-  ImageGenerateNode = 'image-generate-node'
+  ImageGenerateNode = 'image-generate-node',
+  McpNode = 'mcp-node',
 }
diff --git a/ui/src/locales/lang/en-US/views/application-workflow.ts b/ui/src/locales/lang/en-US/views/application-workflow.ts
index 6e1aa8c673c..d0aae1b58e8 100644
--- a/ui/src/locales/lang/en-US/views/application-workflow.ts
+++ b/ui/src/locales/lang/en-US/views/application-workflow.ts
@@ -220,6 +220,14 @@ export default {
       text: 'Update the value of the global variable',
       assign: 'Set Value'
     },
+    mcpNode: {
+      label: 'MCP Server',
+      text: 'Call MCP Tools',
+      getToolsSuccess: 'Get Tools Successfully',
+      getTool: 'Get Tools',
+      tool: 'Tool',
+      toolParam: 'Tool Params'
+    },
     imageGenerateNode: {
       label: 'Image Generation',
       text: 'Generate images based on provided text content',
diff --git a/ui/src/locales/lang/zh-CN/views/application-workflow.ts b/ui/src/locales/lang/zh-CN/views/application-workflow.ts
index 010964bb004..5427c6df08b 100644
--- a/ui/src/locales/lang/zh-CN/views/application-workflow.ts
+++ b/ui/src/locales/lang/zh-CN/views/application-workflow.ts
@@ -220,6 +220,14 @@ export default {
       text: '更新全局变量的值',
       assign: '赋值'
     },
+    mcpNode: {
+      label: 'MCP 节点',
+      text: '调用 MCP 工具',
+      getToolsSuccess: '获取工具成功',
+      getTool: '获取工具',
+      tool: '工具',
+      toolParam: '工具参数'
+    },
     imageGenerateNode: {
       label: '图片生成',
       text: '根据提供的文本内容生成图片',
diff --git a/ui/src/locales/lang/zh-Hant/views/application-workflow.ts b/ui/src/locales/lang/zh-Hant/views/application-workflow.ts
index b8cf464693a..71bf93b2763 100644
--- a/ui/src/locales/lang/zh-Hant/views/application-workflow.ts
+++ b/ui/src/locales/lang/zh-Hant/views/application-workflow.ts
@@ -220,6 +220,14 @@ export default {
       text: '更新全域變數的值',
       assign: '賦值'
     },
+    mcpNode: {
+      label: 'MCP 節點',
+      text: '呼叫 MCP 工具',
+      getToolsSuccess: '獲取工具成功',
+      getTool: '獲取工具',
+      tool: '工具',
+      toolParam: '工具變數'
+    },
     imageGenerateNode: {
       label: '圖片生成',
       text: '根據提供的文本內容生成圖片',
diff --git a/ui/src/views/application/component/McpServersDialog.vue b/ui/src/views/application/component/McpServersDialog.vue
new file mode 100644
index 00000000000..ac7f9c7d1e1
--- /dev/null
+++ b/ui/src/views/application/component/McpServersDialog.vue
@@ -0,0 +1,98 @@
+<template>
+  <el-dialog
+    align-center
+    :title="$t('common.setting')"
+    class="param-dialog"
+    v-model="dialogVisible"
+    style="width: 550px"
+    append-to-body
+    :close-on-click-modal="false"
+    :close-on-press-escape="false"
+  >
+    <el-form label-position="top" ref="paramFormRef" :model="form"
+             require-asterisk-position="right">
+      <el-form-item label="MCP" prop="mcp_enable">
+        <el-switch v-model="form.mcp_enable" />
+      </el-form-item>
+      <el-form-item label="MCP Server Config" prop="mcp_servers"
+                    :rules="[{ required: true, message: $t('common.required') }]">
+        <el-input
+          v-model="form.mcp_servers"
+          :rows="6"
+          type="textarea"
+        />
+      </el-form-item>
+    </el-form>
+
+    <template #footer>
+      <span class="dialog-footer p-16">
+        <el-button @click.prevent="dialogVisible = false">{{ $t('common.cancel') }}</el-button>
+        <el-button type="primary" @click="submit()" :loading="loading">
+          {{ $t('common.save') }}
+        </el-button>
+      </span>
+    </template>
+  </el-dialog>
+</template>
+<script setup lang="ts">
+import { ref, watch } from 'vue'
+
+const emit = defineEmits(['refresh'])
+
+const paramFormRef = ref()
+
+const form = ref<any>({
+  mcp_servers: '',
+  mcp_enable: false
+})
+
+const dialogVisible = ref<boolean>(false)
+const loading = ref(false)
+watch(dialogVisible, (bool) => {
+  if (!bool) {
+    form.value = {
+      mcp_servers: '',
+      mcp_enable: false
+    }
+  }
+})
+
+const open = (data: any) => {
+  form.value = { ...form.value, ...data }
+  dialogVisible.value = true
+}
+
+const submit = () => {
+  paramFormRef.value.validate().then((valid: any) => {
+    if (valid) {
+      emit('refresh', form.value)
+      dialogVisible.value = false
+    }
+  })
+}
+
+defineExpose({ open })
+</script>
+<style lang="scss" scoped>
+.param-dialog {
+  padding: 8px 8px 24px 8px;
+
+  .el-dialog__header {
+    padding: 16px 16px 0 16px;
+  }
+
+  .el-dialog__body {
+    padding: 0 !important;
+  }
+
+  .dialog-max-height {
+    height: 560px;
+  }
+
+  .custom-slider {
+    .el-input-number.is-without-controls .el-input__wrapper {
+      padding: 0 !important;
+    }
+  }
+}
+</style>
diff --git a/ui/src/workflow/common/data.ts b/ui/src/workflow/common/data.ts
index 6554c9b7db4..a30c6ffbb54 100644
--- a/ui/src/workflow/common/data.ts
+++ b/ui/src/workflow/common/data.ts
@@ -263,6 +263,24 @@ export const variableAssignNode = {
   }
 }
 
+export const mcpNode = {
+  type: WorkflowType.McpNode,
+  text: t('views.applicationWorkflow.nodes.mcpNode.text'),
+  label: t('views.applicationWorkflow.nodes.mcpNode.label'),
+  height: 252,
+  properties: {
+    stepName: t('views.applicationWorkflow.nodes.mcpNode.label'),
+    config: {
+      fields:[
+        {
+          label: t('common.result'),
+          value: 'result'
+        }
+      ]
+    }
+  }
+}
+
 export const imageGenerateNode = {
   type: WorkflowType.ImageGenerateNode,
   text: t('views.applicationWorkflow.nodes.imageGenerateNode.text'),
@@ -332,7 +350,8 @@ export const menuNodes = [
   documentExtractNode,
   speechToTextNode,
   textToSpeechNode,
-  variableAssignNode
+  variableAssignNode,
+  mcpNode
 ]
 
 /**
@@ -426,7 +445,8 @@ export const nodeDict: any = {
   [WorkflowType.TextToSpeechNode]: textToSpeechNode,
   [WorkflowType.SpeechToTextNode]: speechToTextNode,
   [WorkflowType.ImageGenerateNode]: imageGenerateNode,
-  [WorkflowType.VariableAssignNode]: variableAssignNode
+  [WorkflowType.VariableAssignNode]: variableAssignNode,
+  [WorkflowType.McpNode]: mcpNode,
 }
 export function isWorkFlow(type: string | undefined) {
   return type === 'WORK_FLOW'
diff --git a/ui/src/workflow/icons/mcp-node-icon.vue b/ui/src/workflow/icons/mcp-node-icon.vue
new file mode 100644
index 00000000000..a7b580ff3d1
--- /dev/null
+++ b/ui/src/workflow/icons/mcp-node-icon.vue
@@ -0,0 +1,6 @@
+<template>
+  <AppAvatar shape="square" class="avatar-blue">
+    <img src="@/assets/icon_assigner.svg" style="width: 65%" alt="" />
+  </AppAvatar>
+</template>
+<script setup lang="ts"></script>
diff --git a/ui/src/workflow/nodes/ai-chat-node/index.vue b/ui/src/workflow/nodes/ai-chat-node/index.vue
index e1951071229..9ab41294aa7 100644
--- a/ui/src/workflow/nodes/ai-chat-node/index.vue
+++ b/ui/src/workflow/nodes/ai-chat-node/index.vue
@@ -116,6 +116,22 @@
           />
         </el-form-item>
 
+        <el-form-item>
+          <template #label>
+            <div class="flex-between">
+              <div>{{ $t('views.applicationWorkflow.nodes.mcpNode.tool') }}</div>
+              <el-button
+                type="primary"
+                link
+                @click="openMcpServersDialog"
+                @refreshForm="refreshParam"
+              >
+                <el-icon><Setting /></el-icon>
+              </el-button>
+            </div>
+          </template>
+        </el-form-item>
+
         <el-form-item @click.prevent>
           <template #label>
             <div class="flex align-center">
@@ -163,6 +179,7 @@
       ref="ReasoningParamSettingDialogRef"
       @refresh="submitReasoningDialog"
     />
+    <McpServersDialog ref="mcpServersDialogRef" @refresh="submitMcpServersDialog" />
   </NodeContainer>
 </template>
 <script setup lang="ts">
@@ -177,6 +194,7 @@ import { isLastNode } from '@/workflow/common/data'
 import AIModeParamSettingDialog from '@/views/application/component/AIModeParamSettingDialog.vue'
 import { t } from '@/locales'
 import ReasoningParamSettingDialog from '@/views/application/component/ReasoningParamSettingDialog.vue'
+import McpServersDialog from '@/views/application/component/McpServersDialog.vue'
 const { model } = useStore()
 
 const wheel = (e: any) => {
@@ -300,6 +318,20 @@ function submitReasoningDialog(val: any) {
   set(props.nodeModel.properties.node_data, 'model_setting', model_setting)
 }
 
+const mcpServersDialogRef = ref()
+function openMcpServersDialog() {
+  const config = {
+    mcp_servers: chat_data.value.mcp_servers,
+    mcp_enable: chat_data.value.mcp_enable
+  }
+  mcpServersDialogRef.value.open(config)
+}
+
+function submitMcpServersDialog(config: any) {
+  set(props.nodeModel.properties.node_data, 'mcp_servers', config.mcp_servers)
+  set(props.nodeModel.properties.node_data, 'mcp_enable', config.mcp_enable)
+}
+
 onMounted(() => {
   getModel()
   if (typeof props.nodeModel.properties.node_data?.is_result === 'undefined') {
diff --git a/ui/src/workflow/nodes/mcp-node/index.ts b/ui/src/workflow/nodes/mcp-node/index.ts
new file mode 100644
index 00000000000..d626b0c6257
--- /dev/null
+++ b/ui/src/workflow/nodes/mcp-node/index.ts
@@ -0,0 +1,14 @@
+import McpNodeVue from './index.vue'
+import { AppNode, AppNodeModel } from '@/workflow/common/app-node'
+
+class McpNode extends AppNode {
+  constructor(props: any) {
+    super(props, McpNodeVue)
+  }
+}
+
+export default {
+  type: 'mcp-node',
+  model: AppNodeModel,
+  view: McpNode
+}
diff --git a/ui/src/workflow/nodes/mcp-node/index.vue b/ui/src/workflow/nodes/mcp-node/index.vue
new file mode 100644
index 00000000000..81110f94b62
--- /dev/null
+++ b/ui/src/workflow/nodes/mcp-node/index.vue
@@ -0,0 +1,239 @@
+<template>
+  <NodeContainer :nodeModel="nodeModel">
+    <h5 class="title-decoration-1 mb-8">{{ $t('views.applicationWorkflow.nodeSetting') }}</h5>
+    <div class="border-r-4 p-8-12 mb-8 layout-bg lighter">
+      <el-form
+        @submit.prevent
+        :model="form_data"
+        label-position="top"
+        require-asterisk-position="right"
+        label-width="auto"
+        ref="replyNodeFormRef"
+        hide-required-asterisk
+      >
+        <el-form-item label="MCP Server Config">
+          <MdEditorMagnify
+            @wheel="wheel"
+            title="MCP Server Config"
+            v-model="form_data.mcp_servers"
+            style="height: 150px"
+            @submitDialog="submitDialog"
+          />
+        </el-form-item>
+        <el-form-item>
+          <template v-slot:label>
+            <div class="flex-between">
+              <span>{{ $t('views.applicationWorkflow.nodes.mcpNode.tool') }}</span>
+              <el-button type="primary" link @click="getTools()">
+                {{ $t('views.applicationWorkflow.nodes.mcpNode.getTool') }}
+              </el-button>
+            </div>
+          </template>
+          <el-select
+            v-model="form_data.mcp_tool"
+            @change="changeTool"
+          >
+            <el-option
+              v-for="item in form_data.mcp_tools"
+              :key="item.value"
+              :label="item.name"
+              :value="item.name"
+            >
+              <el-tooltip
+                class="box-item"
+                effect="dark"
+                :content="item.description"
+                placement="top-start"
+              >
+                <AppIcon iconName="app-warning" class="app-warning-icon"></AppIcon>
+              </el-tooltip>
+
+              <span>{{ item.name }}</span>
+            </el-option>
+          </el-select>
+        </el-form-item>
+      </el-form>
+    </div>
+    <h5 class="title-decoration-1 mb-8">
+      {{ $t('views.applicationWorkflow.nodes.mcpNode.toolParam') }}</h5>
+    <div class="border-r-4 p-8-12 mb-8 layout-bg lighter" v-if="form_data.tool_params[form_data.params_nested]">
+      <DynamicsForm
+        v-if="form_data.mcp_tool"
+        v-model="form_data.tool_params[form_data.params_nested]"
+        :model="form_data.tool_params[form_data.params_nested]"
+        label-position="top"
+        require-asterisk-position="right"
+        :render_data="form_data.tool_form_field"
+        ref="dynamicsFormRef"
+      >
+      </DynamicsForm>
+    </div>
+    <div class="border-r-4 p-8-12 mb-8 layout-bg lighter" v-else>
+      <DynamicsForm
+        v-if="form_data.mcp_tool"
+        v-model="form_data.tool_params"
+        :model="form_data.tool_params"
+        label-position="top"
+        require-asterisk-position="right"
+        :render_data="form_data.tool_form_field"
+        ref="dynamicsFormRef"
+      >
+      </DynamicsForm>
+    </div>
+  </NodeContainer>
+</template>
+<script setup lang="ts">
+import { cloneDeep, set } from 'lodash'
+import NodeContainer from '@/workflow/common/NodeContainer.vue'
+import { computed, onMounted, ref } from 'vue'
+import { isLastNode } from '@/workflow/common/data'
+import applicationApi from '@/api/application'
+import { t } from '@/locales'
+import DynamicsForm from '@/components/dynamics-form/index.vue'
+import { MsgSuccess } from '@/utils/message'
+
+const props = defineProps<{ nodeModel: any }>()
+
+const dynamicsFormRef = ref()
+
+
+const wheel = (e: any) => {
+  if (e.ctrlKey === true) {
+    e.preventDefault()
+    return true
+  } else {
+    e.stopPropagation()
+    return true
+  }
+}
+const form = {
+  mcp_tool: '',
+  mcp_tools: [],
+  mcp_servers: '',
+  mcp_server: '',
+  tool_params: {},
+  tool_form_field: [],
+  params_nested: ''
+}
+
+
+function submitDialog(val: string) {
+  set(props.nodeModel.properties.node_data, 'mcp_servers', val)
+}
+
+function getTools() {
+  applicationApi.getMcpTools({ mcp_servers: form_data.value.mcp_servers }).then((res: any) => {
+    form_data.value.mcp_tools = res.data
+    MsgSuccess(t('views.applicationWorkflow.nodes.mcpNode.getToolsSuccess'))
+  })
+}
+
+function changeTool() {
+  form_data.value.mcp_server = form_data.value.mcp_tools.filter((item: any) => item.name === form_data.value.mcp_tool)[0].server
+  // console.log(form_data.value.mcp_server)
+
+  const args_schema = form_data.value.mcp_tools.filter((item: any) => item.name === form_data.value.mcp_tool)[0].args_schema
+  form_data.value.tool_form_field = []
+  for (const item in args_schema.properties) {
+    let params = args_schema.properties[item].properties
+    if (params) {
+      form_data.value.params_nested = item
+      for (const item2 in params) {
+        form_data.value.tool_form_field.push({
+          field: item2,
+          label: {
+            input_type: 'TooltipLabel',
+            label: item2,
+            attrs: { tooltip: params[item2].description },
+            props_info: {}
+          },
+          input_type: 'TextInput',
+          required: args_schema.properties[item].required?.indexOf(item2) !== -1,
+          default_value: '',
+          show_default_value: false,
+          props_info: {
+            rules: [
+              {
+                required: args_schema.properties[item].required?.indexOf(item2) !== -1,
+                message: t('dynamicsForm.tip.requiredMessage'),
+                trigger: 'blur'
+              }
+            ]
+          }
+        })
+      }
+    } else {
+      form_data.value.params_nested = ''
+      form_data.value.tool_form_field.push({
+        field: item,
+        label: {
+          input_type: 'TooltipLabel',
+          label: item,
+          attrs: { tooltip: args_schema.properties[item].description },
+          props_info: {}
+        },
+        input_type: 'TextInput',
+        required: args_schema.required?.indexOf(item) !== -1,
+        default_value: '',
+        show_default_value: false,
+        props_info: {
+          rules: [
+            {
+              required: args_schema.required?.indexOf(item) !== -1,
+              message: t('dynamicsForm.tip.requiredMessage'),
+              trigger: 'blur'
+            }
+          ]
+        }
+      })
+    }
+  }
+  //
+  if (form_data.value.params_nested) {
+    form_data.value.tool_params = { [form_data.value.params_nested]: {} }
+    dynamicsFormRef.value?.render(form_data.value.tool_form_field, form_data.value.tool_params[form_data.value.params_nested])
+  } else {
+    form_data.value.tool_params = {}
+    dynamicsFormRef.value?.render(form_data.value.tool_form_field, form_data.value.tool_params)
+  }
+  console.log(form_data.value.tool_params)
+}
+
+const form_data = computed({
+  get: () => {
+    if (props.nodeModel.properties.node_data) {
+      return props.nodeModel.properties.node_data
+    } else {
+      set(props.nodeModel.properties, 'node_data', form)
+    }
+    return props.nodeModel.properties.node_data
+  },
+  set: (value) => {
+    set(props.nodeModel.properties, 'node_data', value)
+  }
+})
+
+
+const replyNodeFormRef = ref()
+
+const validate = async () => {
+  let ps = [
+    replyNodeFormRef.value?.validate(),
+    dynamicsFormRef.value?.validate()
+  ]
+  return Promise.all(ps).catch((err: any) => {
+    return Promise.reject({ node: props.nodeModel, errMessage: err })
+  })
+}
+
+onMounted(() => {
+  if (typeof props.nodeModel.properties.node_data?.is_result === 'undefined') {
+    if (isLastNode(props.nodeModel)) {
+      set(props.nodeModel.properties.node_data, 'is_result', true)
+    }
+  }
+
+  set(props.nodeModel, 'validate', validate)
+})
+</script>
+<style lang="scss" scoped></style>