diff --git a/src/emqttd_ws_client.erl b/src/emqttd_ws_client.erl
index 13e013aa6..55fb14c0c 100644
--- a/src/emqttd_ws_client.erl
+++ b/src/emqttd_ws_client.erl
@@ -102,8 +102,7 @@ reset_parser(State = #wsocket_state{packet_opts = PktOpts}) ->
 
 init([WsPid, Req, ReplyChannel, PktOpts]) ->
     process_flag(trap_exit, true),
-    Socket = Req:get(socket),
-    {ok, Peername} = emqttd_net:peername(Socket),
+    {ok, Peername} = Req:get(peername),
     SendFun = fun(Payload) -> ReplyChannel({binary, Payload}) end,
     ProtoState = emqttd_protocol:init(Peername, SendFun, PktOpts),
     {ok, #client_state{ws_pid = WsPid, request = Req, proto_state = ProtoState}}.