diff --git a/modules/njet-http-wasm-module/config b/modules/njet-http-wasm-module/config
new file mode 100644
index 0000000000000000000000000000000000000000..29a19388c192c9b62763bd430728ab5a8933cafb
--- /dev/null
+++ b/modules/njet-http-wasm-module/config
@@ -0,0 +1,20 @@
+njt_addon_name=njt_http_wasm_module
+njt_module_type=HTTP
+njt_module_name=$njt_addon_name
+njt_module_incs=" \
+$njt_addon_dir/include \
+"
+njt_module_deps=" \
+$njt_addon_dir/include/njt_http_wasm_module.h \
+"
+njt_module_srcs=" \
+  $njt_addon_dir/src/njt_http_wasm_module.c \
+"
+
+njt_module_libs=""  #-lpthread 
+
+ have=NJT_HTTP_HELLO_MODULE . auto/have
+
+. auto/module
+
+
diff --git a/modules/njet-http-wasm-module/include/njt_http_wasm_module.h b/modules/njet-http-wasm-module/include/njt_http_wasm_module.h
new file mode 100644
index 0000000000000000000000000000000000000000..b98ea6eecf25761c8fc9ac8c2ef29806459bffd2
--- /dev/null
+++ b/modules/njet-http-wasm-module/include/njt_http_wasm_module.h
@@ -0,0 +1,32 @@
+#ifndef NJT_HTTP_HELLO_MODULE_H
+#define NJT_HTTP_HELLO_MODULE_H
+
+#include <njt_config.h>
+#include <njt_core.h>
+#include <njt_http.h>
+#include <njt_stream.h>
+#include <njt_json_api.h>
+#include <math.h>
+#include <njt_http_kv_module.h>
+
+typedef struct njt_http_wasm_main_conf_s
+{
+    njt_http_request_t **reqs;
+    njt_int_t size;
+} njt_http_wasm_main_conf_t;
+
+typedef struct
+{
+    njt_http_request_t *req;
+    njt_int_t index;
+    njt_http_wasm_main_conf_t *dlmcf;
+} njt_http_wasm_rpc_ctx_t;
+
+typedef struct njt_http_wasm_loc_conf_s
+{
+    njt_flag_t wasm_enable;
+    njt_str_t runtime;
+    njt_str_t plugin_path;
+} njt_http_wasm_loc_conf_t;
+
+#endif
diff --git a/modules/njet-http-wasm-module/src/njt_http_wasm_module.c b/modules/njet-http-wasm-module/src/njt_http_wasm_module.c
new file mode 100644
index 0000000000000000000000000000000000000000..52fd5bdeb026e3ce8ed7cb362669c033e8682781
--- /dev/null
+++ b/modules/njet-http-wasm-module/src/njt_http_wasm_module.c
@@ -0,0 +1,415 @@
+#include <njt_config.h>
+#include <njt_core.h>
+#include <njt_http.h>
+#include <njt_stream.h>
+#include <njt_json_api.h>
+#include <math.h>
+#include <njt_http_kv_module.h>
+#include <njt_http_wasm_module.h>
+#include <njt_http_util.h>
+#include <njt_str_util.h>
+#include "njt_http_api_register_module.h"
+#include <njt_log.h>
+
+#include "njt_string.h"
+
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <errno.h>
+#include <unistd.h>
+#include <string.h>
+#include <netdb.h>
+#include <netinet/in.h>
+
+static void
+njt_http_wasm_read_data(njt_http_request_t *r);
+static njt_str_t
+send_and_recv_data(char *message, njt_http_request_t *r);
+
+static njt_int_t
+njt_http_wasm_handler(njt_http_request_t *r);
+
+static njt_int_t
+njt_http_wasm_init_worker(njt_cycle_t *cycle);
+
+static void *
+njt_http_wasm_create_loc_conf(njt_conf_t *cf);
+
+static char *njt_http_wasm_merge_loc_conf(njt_conf_t *cf,
+                                          void *parent, void *child);
+
+static void *
+njt_http_wasm_create_main_conf(njt_conf_t *cf);
+
+static njt_int_t
+njt_http_wasm_init(njt_conf_t *cf);
+
+static char *
+njt_http_wasm_plugin(njt_conf_t *cf, njt_command_t *cmd, void *conf);
+
+static njt_command_t njt_http_wasm_commands[] = {
+    {njt_string("wasm_plugin"),
+     NJT_HTTP_MAIN_CONF | NJT_HTTP_SRV_CONF | NJT_HTTP_LOC_CONF | NJT_CONF_ANY,
+     njt_http_wasm_plugin,
+     NJT_HTTP_LOC_CONF_OFFSET,
+     offsetof(njt_http_wasm_loc_conf_t, wasm_enable),
+     NULL},
+    {njt_string("wasm_runtime"),
+     NJT_HTTP_MAIN_CONF | NJT_HTTP_SRV_CONF | NJT_HTTP_LOC_CONF | NJT_CONF_ANY,
+     njt_conf_set_str_slot,
+     NJT_HTTP_LOC_CONF_OFFSET,
+     offsetof(njt_http_wasm_loc_conf_t, runtime),
+     NULL},
+    {njt_string("wasm_plugin_path"),
+     NJT_HTTP_MAIN_CONF | NJT_HTTP_SRV_CONF | NJT_HTTP_LOC_CONF | NJT_CONF_ANY,
+     njt_conf_set_str_slot,
+     NJT_HTTP_LOC_CONF_OFFSET,
+     offsetof(njt_http_wasm_loc_conf_t, plugin_path),
+     NULL},
+    njt_null_command};
+
+static njt_http_module_t njt_http_wasm_module_ctx = {
+    NULL,
+    njt_http_wasm_init,
+    njt_http_wasm_create_main_conf,
+    NULL,
+    NULL,
+    NULL,
+    njt_http_wasm_create_loc_conf,
+    njt_http_wasm_merge_loc_conf};
+
+njt_module_t njt_http_wasm_module = {
+    NJT_MODULE_V1,
+    &njt_http_wasm_module_ctx,
+    njt_http_wasm_commands,
+    NJT_HTTP_MODULE,
+    NULL,
+    NULL,
+    njt_http_wasm_init_worker,
+    NULL,
+    NULL,
+    NULL,
+    NULL,
+    NJT_MODULE_V1_PADDING};
+
+static char *
+njt_http_wasm_plugin(njt_conf_t *cf, njt_command_t *cmd, void *conf)
+{
+
+    njt_http_wasm_loc_conf_t *clcf = conf;
+    clcf->wasm_enable = 1;
+    return NJT_CONF_OK;
+}
+
+static njt_int_t
+njt_http_wasm_init(njt_conf_t *cf)
+{
+    njt_http_core_main_conf_t *cmcf;
+    njt_http_handler_pt *h;
+    njt_http_wasm_main_conf_t *dlmcf;
+
+    dlmcf = njt_http_conf_get_module_main_conf(cf, njt_http_wasm_module);
+    if (dlmcf->size == NJT_CONF_UNSET)
+    {
+        dlmcf->size = 500;
+    }
+    dlmcf->reqs = njt_pcalloc(cf->pool, sizeof(njt_http_request_t *) * dlmcf->size);
+    if (dlmcf->reqs == NULL)
+    {
+        njt_log_error(NJT_LOG_EMERG, njt_cycle->log, 0, "njt_http_wasm_postconfiguration alloc mem error");
+        return NJT_ERROR;
+    }
+
+    cmcf = njt_http_conf_get_module_main_conf(cf, njt_http_core_module);
+    if (cmcf == NULL)
+    {
+        return NJT_ERROR;
+    }
+    h = njt_array_push(&cmcf->phases[NJT_HTTP_CONTENT_PHASE].handlers);
+    if (h == NULL)
+    {
+        return NJT_ERROR;
+    }
+
+    *h = njt_http_wasm_handler;
+    return NJT_OK;
+}
+static void *
+njt_http_wasm_create_loc_conf(njt_conf_t *cf)
+{
+    njt_http_wasm_loc_conf_t *uclcf;
+    uclcf = njt_pcalloc(cf->pool, sizeof(njt_http_wasm_loc_conf_t));
+    if (uclcf == NULL)
+    {
+        njt_log_error(NJT_LOG_ERR, cf->log, 0, "malloc uclcf eror");
+        return NULL;
+    }
+    uclcf->wasm_enable = NJT_CONF_UNSET;
+    uclcf->runtime.len = 0;
+    uclcf->runtime.data = NULL;
+    uclcf->plugin_path.len = 0;
+    uclcf->plugin_path.data = NULL;
+    return uclcf;
+}
+
+static void *
+njt_http_wasm_create_main_conf(njt_conf_t *cf)
+{
+    njt_http_wasm_main_conf_t *uclcf;
+
+    uclcf = njt_pcalloc(cf->pool, sizeof(njt_http_wasm_main_conf_t));
+    if (uclcf == NULL)
+    {
+        njt_log_error(NJT_LOG_ERR, cf->log, 0, "malloc njt_http_wasm_main_conf_t eror");
+        return NULL;
+    }
+    uclcf->size = NJT_CONF_UNSET;
+    return uclcf;
+}
+static char *njt_http_wasm_merge_loc_conf(njt_conf_t *cf,
+                                          void *parent, void *child)
+{
+    njt_http_wasm_loc_conf_t *prev = parent;
+    njt_http_wasm_loc_conf_t *conf = child;
+
+    njt_conf_merge_value(conf->wasm_enable, prev->wasm_enable, 0);
+    njt_conf_merge_str_value(conf->runtime, prev->runtime, "");
+    njt_conf_merge_str_value(conf->plugin_path, prev->plugin_path, "");
+    return NJT_CONF_OK;
+}
+
+static njt_int_t
+njt_http_wasm_handler(njt_http_request_t *r)
+{
+    njt_int_t rc = NJT_OK;
+
+    njt_http_core_loc_conf_t *loc;
+    njt_http_wasm_loc_conf_t *wasm_clcf;
+
+    loc = njt_http_get_module_loc_conf(r, njt_http_core_module);
+    wasm_clcf = njt_http_get_module_loc_conf(r, njt_http_wasm_module);
+    if (wasm_clcf && wasm_clcf->wasm_enable && loc)
+    {
+    }
+    else
+    {
+        return NJT_DECLINED;
+    }
+
+    njt_log_debug0(NJT_LOG_DEBUG_ALLOC, r->pool->log, 0, "1 read_client_request_body start +++++++++++++++");
+    rc = njt_http_read_client_request_body(r, njt_http_wasm_read_data);
+    if (rc >= NJT_HTTP_SPECIAL_RESPONSE)
+    {
+        /* error */
+        return rc;
+    }
+
+    return NJT_DONE;
+}
+
+static njt_int_t
+njt_http_wasm_init_worker(njt_cycle_t *cycle)
+{
+
+    return NJT_OK;
+}
+
+static int njt_http_wasm_request_output(njt_http_request_t *r, njt_int_t code, njt_str_t *msg)
+{
+    njt_int_t rc;
+    njt_buf_t *buf;
+    njt_chain_t out;
+
+    if (code == NJT_OK)
+    {
+        if (msg == NULL || msg->len == 0)
+        {
+            r->headers_out.status = NJT_HTTP_NO_CONTENT;
+        }
+        else
+        {
+            r->headers_out.status = NJT_HTTP_OK;
+        }
+    }
+    else
+    {
+        r->headers_out.status = code;
+    }
+    r->headers_out.content_length_n = 0;
+    if (msg != NULL && msg->len > 0)
+    {
+        njt_str_t type = njt_string("application/json");
+        r->headers_out.content_type = type;
+        r->headers_out.content_length_n = msg->len;
+    }
+    if (r->headers_out.content_length)
+    {
+        r->headers_out.content_length->hash = 0;
+        r->headers_out.content_length = NULL;
+    }
+    rc = njt_http_send_header(r);
+    if (rc == NJT_ERROR || rc > NJT_OK || r->header_only || msg == NULL || msg->len < 1)
+    {
+        return rc;
+    }
+    buf = njt_create_temp_buf(r->pool, msg->len);
+    if (buf == NULL)
+    {
+        return NJT_ERROR;
+    }
+    njt_memcpy(buf->pos, msg->data, msg->len);
+    buf->last = buf->pos + msg->len;
+    buf->last_buf = 1;
+    out.buf = buf;
+    out.next = NULL;
+    return njt_http_output_filter(r, &out);
+}
+
+static void add_obj_to_json(char *str, char *key, char *value)
+{
+    strcat(str, ",\"");
+    strcat(str, key);
+    strcat(str, "\":\"");
+    strcat(str, value);
+    strcat(str, "\"");
+}
+
+static char *loop_headers(njt_http_request_t *r)
+{
+
+    char *res = njt_palloc(r->pool, 1000);
+    strcat(res, "{\"headers\": ");
+    njt_str_t host = r->headers_in.host->value;
+    strcat(res, "{\"host\":\"");
+
+    strcat(res, (char *)(char *)host.data);
+    strcat(res, "\"");
+
+    if (r->headers_in.connection)
+    {
+        njt_str_t connection = r->headers_in.connection->value;
+        add_obj_to_json(res, "connection", (char *)(char *)connection.data);
+    }
+    
+    if (r->headers_in.authorization)
+    {
+        njt_str_t authorization = r->headers_in.authorization->value;
+        add_obj_to_json(res, "authorization", (char *)(char *)authorization.data);
+    }
+    strcat(res, "}");
+    return res;
+}
+
+static void
+njt_http_wasm_read_data(njt_http_request_t *r)
+{
+
+    njt_str_t response_data = njt_string("wasm world!");
+    njt_str_t no_json_body = njt_string("no body content");
+    njt_str_t json_str;
+    njt_int_t rc = njt_http_util_read_request_body(r, &json_str, 2, 5242880);
+    if (rc != NJT_OK)
+    {
+        json_str = no_json_body;
+    }
+
+    if (rc == NJT_OK)
+    {
+        response_data = json_str;
+    }
+
+    char *headerStr = loop_headers(r);
+
+    strcat(headerStr, ",\"body\": ");
+    strcat(headerStr, (char *)(char *)json_str.data);
+    strcat(headerStr, "}");
+
+    njt_str_t res = send_and_recv_data(headerStr, r);
+
+    response_data = res;
+    rc = njt_http_wasm_request_output(r, NJT_HTTP_OK, &response_data);
+    njt_http_finalize_request(r, rc);
+    return;
+}
+
+static njt_str_t send_and_recv_data(char *message, njt_http_request_t *r)
+{
+    FILE *fp;
+    njt_http_wasm_loc_conf_t *wasm_clcf;
+    wasm_clcf = njt_http_get_module_loc_conf(r, njt_http_wasm_module);
+
+    size_t total_len;
+    char *command;
+
+    total_len = wasm_clcf->runtime.len + 1 + wasm_clcf->plugin_path.len + 2 + njt_strlen(message) + 2;
+    command = njt_palloc(r->pool, total_len);
+    njt_snprintf((u_char *)command, total_len, "%V %V '%s'", &wasm_clcf->runtime, &wasm_clcf->plugin_path, message);
+
+    fp = popen(command, "r");
+    if (fp == NULL)
+    {
+        printf("Failed to run command\n");
+        exit(1);
+    }
+
+    njt_str_t res = njt_string("error: read wasm excute result error, nread != 1");
+    int nread;
+    u_char get_buf[10240];
+
+    nread = read(fileno(fp), get_buf, 10240);
+    u_char *tmp_point, *data_point, *last_point, *first_point;
+    njt_str_t tmp_str;
+
+    if (nread > 1)
+    {
+        data_point = &get_buf[0];
+        tmp_point = data_point + nread - 1;
+        while (tmp_point > data_point)
+        {
+            if (*tmp_point != '\n')
+            {
+                break;
+            }
+
+            last_point = tmp_point;
+            tmp_point--;
+            if (tmp_point == data_point)
+            {
+                first_point = tmp_point;
+                tmp_str.data = first_point;
+                tmp_str.len = last_point - first_point;
+                break;
+            }
+
+            while (tmp_point > data_point)
+            {
+                if (*tmp_point == '\n')
+                {
+                    break;
+                }
+
+                tmp_point--;
+            }
+            if (tmp_point == data_point)
+            {
+                first_point = data_point;
+                tmp_str.data = first_point;
+                tmp_str.len = last_point - first_point;
+                break;
+            }
+            else
+            {
+                first_point = tmp_point + 1;
+                tmp_str.data = first_point;
+                tmp_str.len = last_point - first_point;
+            }
+        }
+        res = tmp_str;
+    }
+
+    njt_int_t rc2 = njt_http_wasm_request_output(r, NJT_HTTP_OK, &res);
+    njt_http_finalize_request(r, rc2);
+    return res;
+}
\ No newline at end of file