first commit
diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..5717c99
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,18 @@
+_*
+.eunit
+*.o
+*.beam
+*.plt
+*.swp
+*.swo
+.erlang.cookie
+ebin
+log
+erl_crash.dump
+.rebar
+logs
+_build
+.idea
+.rebar
+target
+*.iml
diff --git a/Developer.md b/Developer.md
new file mode 100644
index 0000000..7fb83d3
--- /dev/null
+++ b/Developer.md
@@ -0,0 +1,45 @@
+## 开发
+
+```
+ ./rebar3 eunit -m dubbo_zookeeper_tests
+
+ dubbo_zookeeper:register_consumer(<<"com.ifcoder.demo.facade.User">>,[]).
+
+ iProcessData:call_object().
+
+
+ scherdule:call_object().
+
+
+ ./rebar3 shell --apps "testdubboerl"
+ dubboerl:init().
+
+```
+### eunit Test
+ ./rebar3 eunit -m dubbo_zookeeper_tests
+ ./rebar3 eunit -m de_codec_tests
+
+## 服务注册流程
+
+### 消费者注册
+
+
+
+### 生产者注册
+
+
+
+### 消费者调用
+
+```
+ Option=[
+ sync,
+ {timeout,5000}
+ {attachments,[{<<"a">>,<<"b">>}]}
+ ]
+```
+
+
+
+
+## Develop Log
diff --git a/LICENSE b/LICENSE
new file mode 100644
index 0000000..63002bc
--- /dev/null
+++ b/LICENSE
@@ -0,0 +1,21 @@
+MIT License
+
+Copyright (c) 2018 Dlive
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.
diff --git a/README.md b/README.md
new file mode 100644
index 0000000..6099b6b
--- /dev/null
+++ b/README.md
@@ -0,0 +1,67 @@
+dubboerl
+=====
+A Erlang framework for dubbo.
+
+Feature
+-----
+
+* 支持Zookeeper注册中心
+* 支持Hession serialize
+* 支持Consumer
+* 支持Provider
+* sync invoker
+* async invoker
+
+Start
+-----
+
+参考demo [dubboerl_demo](https://github.com/DLive/dubboerl_demo)
+
+#### Step1
+Transfer java facede t
+o erlang lib and add to you project dir.
+
+#### Step2
+
+configure dubbo refernce
+
+```
+{dubboerl,[
+ {zookeeper_list,[{"127.0.0.1",2181}]},
+ {application,<<"testdubboerl">>},
+ {consumer,[
+ {<<"me.dlive.dubboservice.service.IProcessData">>,[]}
+ ]},
+ {provider,[
+ {scherdule_impl,scherdule_behaviour,<<"me.dlive.dubboservice.service.Scherdule">>,[]}
+ ]}
+
+]}
+```
+#### Step4
+Init dubboerl application context
+
+ dubboerl:init().
+
+#### Step5
+Do your interface method invoker.
+
+```
+RequestPara = #testReq{name = <<"nameinfo">>,nick = <<"nickinfo">>,age = 10},
+iProcessData:queryinfo(Info,[]).
+```
+
+
+
+Build
+-----
+
+ $ rebar3 compile
+
+
+release
+
+ $ ./rebar3 as dubboerl release -n dubboerl
+
+
+
diff --git a/config/sys.config b/config/sys.config
new file mode 100644
index 0000000..8d62088
--- /dev/null
+++ b/config/sys.config
@@ -0,0 +1,34 @@
+[
+ %% SASL config {file, "log/sasl-error.log"}
+ {sasl, [
+ {sasl_error_logger, false},
+ {errlog_type, error},
+ {error_logger_mf_dir, "log/sasl-error.log"}, % Log directory
+ {error_logger_mf_maxbytes, 104857600}, % 100 MB max file size
+ {error_logger_mf_maxfiles, 5} % 5 files max
+ ]},
+ {emysql,[
+ {lock_timeout,900000},
+ {default_timeout, 900000}
+
+ ]},
+ {lager, [
+ {log_root, "./logs"},
+ {handlers, [
+ {lager_console_backend, debug},
+ {lager_file_backend, [{file, "error.log"}, {level, error}]},
+ {lager_file_backend, [{file, "console.log"}, {level, info}]}
+ ]}
+ ]},
+ {dubboerl,[
+ {zookeeper_list,[{"127.0.0.1",2181}]},
+ {application,<<"testdubboerl">>},
+ {consumer,[
+ {<<"com.ifcoder.demo.facade.User">>,[]}
+ ]},
+ {provider,[
+ {user_impl,user_behaviour,<<"com.ifcoder.demo.facade.User">>,[]}
+ ]}
+
+ ]}
+].
diff --git a/config/vm.args b/config/vm.args
new file mode 100644
index 0000000..7134fa4
--- /dev/null
+++ b/config/vm.args
@@ -0,0 +1,36 @@
+## Name of the node
+##需要定义 -name android_connecion_1@logic1.mpush.paf
+-name dubboerl@127.0.0.1
+
+## Cookie for distributed erlang
+-setcookie fb65338cf25a2d68a2da5207f718cdfa
+
+## Heartbeat management; auto-restarts VM if it dies or becomes unresponsive
+## (Disabled by default..use with caution!)
+##-heart
+
+## Enable kernel poll and a few async threads
++K true
+##+A 5
+
+## Increase number of concurrent ports/sockets
+-env ERL_MAX_PORTS 10240000
+
+## too many db tables
+-env ERL_MAX_ETS_TABLES 125535
+
++P 3000000
+
+## Tweak GC to run more often
+-env ERL_FULLSWEEP_AFTER 30000
+
+
+## +S 2
+
+## erlang 端口上退 默认65535
++Q 2000000
+
+-kernel inet_dist_listen_min 4370 inet_dist_listen_max 4388
+
+## 调度类型
+-sub true
\ No newline at end of file
diff --git a/include/common.hrl b/include/common.hrl
new file mode 100644
index 0000000..70768b7
--- /dev/null
+++ b/include/common.hrl
@@ -0,0 +1,15 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 14. 十月 2016 下午4:29
+%%%-------------------------------------------------------------------
+-author("dlive").
+
+-ifdef(DEBUG).
+-define(RELOADER,true).
+-else.
+-define(RELOADER,false).
+-endif.
\ No newline at end of file
diff --git a/include/dubbo.hrl b/include/dubbo.hrl
new file mode 100644
index 0000000..016a7a0
--- /dev/null
+++ b/include/dubbo.hrl
@@ -0,0 +1,98 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 16. 十月 2016 下午11:38
+%%%-------------------------------------------------------------------
+-author("dlive").
+
+-include("hessian.hrl").
+
+-define(DUBBO_VERSION,<<"2.6.0">>).
+-define(DUBBO_MEGIC, -9541). %% new version 16#dabb
+-define(DUBBO_MEGIC_HIGH, 16#da). %% new version 16#da
+-define(DUBBO_MEGIC_LOW, 16#bb). %% new version 16#bb
+
+%% 序列化类型
+-define(SERIALIZATION_HESSIAN,2).
+-define(SERIALIZATION_FASTJSON,6).
+-define(SERIALIZATION_KRYO,8).
+
+-define(RESPONSE_WITH_EXCEPTION,0).
+-define(RESPONSE_VALUE,1).
+-define(RESPONSE_NULL_VALUE,2).
+
+
+-define(RESPONSE_STATE_OK,20).
+
+-define(REQUEST_TIME_OUT,5000).
+
+-define(LINE_SEPERATOR,<<"\n"/utf8>>).
+
+-record(dubbo_request,{
+ serialize_type = 2 ::integer(),
+ is_event = true ::boolean(),
+ is_twoway = false ::boolean(),
+ data ::null|dubbo_rpc_invocation,
+ mid ::integer(),
+ mversion ::string(),
+ error_msg ::string(),
+ state ::byte(),
+ decode_state
+}).
+
+-record(dubbo_response,{
+ serialize_type = 2 ::integer(),
+ is_event = true ::boolean(),
+ is_twoway = false ::boolean(),
+ data ::null|dubbo_rpc_invocation,
+ mid ::integer(),
+ mversion ::string(),
+ error_msg ::string(),
+ state ::byte(),
+ decode_state
+}).
+
+-record(dubbo_rpc_invocation,{
+ serialVersionUID = -4355285085441097045,
+ className ::string(),
+ classVersion ::string(),
+ methodName ::string(),
+ parameterDesc ::string(),
+ parameterTypes=[] ::[#type_def{}],
+ parameters=[] ::[term()],
+ attachments=[] ::[term()]
+}).
+
+-record(consumer_config,{
+ interface,
+ application = <<"NoName">> ::binary(),
+ category = <<"consumers">> ::binary(),
+ check=false ::boolean(),
+ default_timeout=500 ::integer(),
+ dubbo_version= <<"2.5.3">> ::binary(),
+ methods=[] ::list(),
+ revision= <<"">> ::binary(),
+ side= <<"consumers">> ::binary()
+}).
+
+-record(provider_config,{
+ protocol,
+ host,
+ port,
+ interface,
+ anyhost=true,
+ executes=1,
+ application,
+ dubbo= <<"2.5.3">>,
+ methods=[],
+ side= <<"provider">>
+}).
+
+
+
+-record(interface_list,{interface,pid,connection_info}).
+-record(provider_node_list,{host_flag,connection_info}).
+-record(connection_info,{connection_id,pid,weight,host_flag}).
\ No newline at end of file
diff --git a/include/dubbo_type.hrl b/include/dubbo_type.hrl
new file mode 100644
index 0000000..f01d969
--- /dev/null
+++ b/include/dubbo_type.hrl
@@ -0,0 +1,12 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 15. Apr 2018 9:10 PM
+%%%-------------------------------------------------------------------
+-author("dlive").
+
+
+-type response_content() :: binary().
\ No newline at end of file
diff --git a/include/dubboerl.hrl b/include/dubboerl.hrl
new file mode 100644
index 0000000..baf4c25
--- /dev/null
+++ b/include/dubboerl.hrl
@@ -0,0 +1,16 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 22. Mar 2018 6:53 PM
+%%%-------------------------------------------------------------------
+-author("dlive").
+
+
+-define(PROVIDER_IMPL_TABLE,provider_impl_table).
+
+-define(PROVIDER_WORKER,provider_worker).
+
+-define(TRAFFIC_CONTROL,traffic_control).
\ No newline at end of file
diff --git a/include/hessian.hrl b/include/hessian.hrl
new file mode 100755
index 0000000..46ea79e
--- /dev/null
+++ b/include/hessian.hrl
@@ -0,0 +1,46 @@
+-ifndef(HESSIAN_H).
+-define(HESSIAN_H,1).
+
+-define(M, 2).
+-define(m, 0).
+
+-define(CHUNK_SIZE, 1024).
+
+-define(MegaSeconds, 1000000000).
+-define(Seconds, 1000).
+-define(MicroSeconds, 1000).
+-define(UnixEpoch, 62167219200).
+
+%% Equivalents: type_def and class
+-record(type_def,{defineNo=-1,native_type, foreign_type, fieldnames}).
+-record(class, {typeNo=-1, encoded=false, name=[], fields=[]}).
+
+-record(list, {refNo=-1, len=-1, type=untyped, values=[]}).
+-record(map, {refNo=-1, type=untyped, dict=dict:new()}).
+-record(object, {refNo=-1, typeRef=-1, class=auto, values=[]}).
+
+-record(set, {ref=-1, value=[]}).
+
+-ifdef(DEBUG).
+% Application Logging
+-define(LOG(Msg), io:format("{~p:~p}: ~p~n", [?MODULE, ?LINE, Msg])).
+-define(ERROR(Error,Reason), io:format("Error @ ~p:~p: ~p (Reason: ~p)~n", [?MODULE, ?LINE,Error,Reason])).
+% Protocol Logging
+-define(START(Msg,Value), io:format("~s -> ~p~n", [Msg,Value])).
+-define(METHOD(Value), io:format("\tMethod -> ~p~n", [ binary_to_list(Value) ] )).
+-define(VALUE(Value), io:format("\t\tValue -> ~p~n", [ Value ] )).
+-define(TYPEDEF(Value), io:format("\t\tTypeDef -> ~p~n", [ Value ] )).
+-define(INSTANCE(Value), io:format("\t\tInstance -> ~p~n", [ Value ] )).
+-else.
+% Application Logging
+-define(LOG(Msg), true).
+-define(ERROR(Msg), true).
+% Protocol Logging
+-define(START(Msg,Value), true).
+-define(METHOD(Value), true).
+-define(VALUE(Value), true).
+-define(TYPEDEF(Value), true).
+-define(INSTANCE(Value), true).
+-endif.
+
+-endif.
\ No newline at end of file
diff --git a/include/hessian_test.hrl b/include/hessian_test.hrl
new file mode 100644
index 0000000..ed6b8cb
--- /dev/null
+++ b/include/hessian_test.hrl
@@ -0,0 +1,34 @@
+% ---------------------------------------------------------------------------
+% Copyright (C) 2008 0x6e6562
+%
+% Licensed under the Apache License, Version 2.0 (the "License");
+% you may not use this file except in compliance with the License.
+% You may obtain a copy of the License at
+%
+% http://www.apache.org/licenses/LICENSE-2.0
+%
+% Unless required by applicable law or agreed to in writing, software
+% distributed under the License is distributed on an "AS IS" BASIS,
+% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+% See the License for the specific language governing permissions and
+% limitations under the License.
+% ---------------------------------------------------------------------------
+
+% This is for simple tests
+-record(pair, {first, second}).
+
+% These are used in the kitchen sink tests
+-record(kitchen_sink, {color,
+ plug_hole,
+ delivery_date,
+ cost,
+ type,
+ deluxe}).
+-record(plug_hole, {diameter}).
+-record(specification, {customer_name,
+ plug_hole,
+ color,
+ total,
+ type,
+ order_date,
+ deluxe}).
\ No newline at end of file
diff --git a/include/java_type.hrl b/include/java_type.hrl
new file mode 100644
index 0000000..e85e3a7
--- /dev/null
+++ b/include/java_type.hrl
@@ -0,0 +1,13 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 09. Mar 2018 11:10 PM
+%%%-------------------------------------------------------------------
+-author("dlive").
+
+-record(null_pointer_exception,{detailMessage,cause,stackTrace,suppressedExceptions}).
+
+-record(stack_stack_trace_element,{declaringClass,methodName,fileName,lineNumber}).
\ No newline at end of file
diff --git a/rebar.config b/rebar.config
new file mode 100644
index 0000000..81b3d5f
--- /dev/null
+++ b/rebar.config
@@ -0,0 +1,19 @@
+{erl_opts, [debug_info,
+ {parse_transform, lager_transform}
+ ]}.
+
+{lib_dirs, []}.
+{base_dir, "_build"}.
+{root_dir, "."}.
+{project_app_dirs, ["."]}.
+{extra_src_dirs, ["test"]}.
+{ct_opts, []}.
+
+
+{deps, [
+ {erlzk, ".*", {git, "git@github.com:huaban/erlzk.git", {tag, "v0.6.2"}}},
+ {lager, ".*", {git, "git@github.com:basho/lager.git", {tag, "3.2.4"}}},
+ {ranch, ".*", {git, "https://github.com/ninenines/ranch.git", {tag, "1.4.0"}}},
+ {poolboy, ".*", {git, "https://github.com/devinus/poolboy.git", {tag, "1.5.1"}}},
+ {jiffy, "0.15.1"}
+]}.
\ No newline at end of file
diff --git a/rebar3 b/rebar3
new file mode 100755
index 0000000..9463ef6
--- /dev/null
+++ b/rebar3
Binary files differ
diff --git a/src/de_codec.erl b/src/de_codec.erl
new file mode 100644
index 0000000..8cc4136
--- /dev/null
+++ b/src/de_codec.erl
@@ -0,0 +1,284 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 20. 十月 2016 下午6:21
+%%%-------------------------------------------------------------------
+-module(de_codec).
+-author("dlive").
+
+-include("dubbo.hrl").
+-include("hessian.hrl").
+
+-ifdef(TEST).
+-compile(export_all).
+-endif.
+%% API
+-export([encode_request/1,encode_response/1]).
+
+-export([decode_header/1]).
+-export([decode_response/2]).
+-export([decode_request/2]).
+
+
+
+-spec encode_request(#dubbo_request{})->{ok,binary()} | {error,term()}.
+encode_request(Request)->
+%% lager:debug("encode request ~p",[Request]),
+ {ok,RequestData} = encode_request_data(Request#dubbo_request.serialize_type,Request),
+ Size = byte_size(RequestData),
+ Header = encode_header(Request,Size,0),
+ RequestContent = <<Header/binary,RequestData/binary>>,
+ {ok,RequestContent}.
+
+encode_header(Request,DataLen,RequestState)->
+ Header2=-128 bor Request#dubbo_request.serialize_type,
+ Header21=case Request#dubbo_request.is_twoway of
+ true -> Header2 bor 64;
+ false-> Header2
+ end,
+ Header22=case Request#dubbo_request.is_event of
+ true -> Header21 bor 32;
+ false-> Header21
+ end,
+ RequestId = Request#dubbo_request.mid,
+ Header = << ?DUBBO_MEGIC:16,Header22:8,RequestState:8,RequestId:64,DataLen:32>>,
+ Header.
+encode_request_data(?SERIALIZATION_FASTJSON,Request)->
+ dubbo_serializa_fastjson:encode_request_data(Request);
+
+encode_request_data(?SERIALIZATION_HESSIAN,Request)->
+ State=type_encoding:init(),
+ DataType =case Request#dubbo_request.is_event of
+ true->
+ dubbo_event;
+ false->
+ case Request#dubbo_request.data of
+ #dubbo_rpc_invocation{} ->
+ dubbo_rpc_invocation;
+ _ ->
+ unknow
+ end
+ end,
+ {ok,Bin} = encode_request_data(DataType,Request,Request#dubbo_request.data,State),
+ {ok,Bin}.
+
+encode_request_data(dubbo_event,Request,Data,State) ->
+ Bin = hessianEncode:encode(Data,State),
+ {ok,Bin};
+encode_request_data(dubbo_rpc_invocation,Request,Data,State) ->
+ METHOD_NAME = Data#dubbo_rpc_invocation.methodName,
+ METHOD_ARGS_TYPES = Data#dubbo_rpc_invocation.parameterDesc,
+ RequestList = [
+ hessianEncode:encode(?DUBBO_VERSION, State), %% dubbo version
+ hessianEncode:encode(Data#dubbo_rpc_invocation.className, State),
+ hessianEncode:encode(Data#dubbo_rpc_invocation.classVersion, State),
+ hessianEncode:encode(METHOD_NAME, State),
+ hessianEncode:encode(METHOD_ARGS_TYPES, State)
+ ],
+ {ArgsBin,State2} = encode_arguments(Data,State),
+ AttachDict = dict:from_list(Data#dubbo_rpc_invocation.attachments),
+ AttachMaps = #map{dict = AttachDict },
+ {AttachBinay,_} = hessianEncode:encode(AttachMaps, State2),
+ RequestData = erlang:iolist_to_binary(RequestList ++ [ArgsBin,AttachBinay]),
+ {ok,RequestData}.
+
+-spec encode_response(#dubbo_response{})-> {ok,term()}.
+encode_response(Response)->
+ {ok,ResponseData} = encode_response_data(Response),
+ Size = byte_size(ResponseData),
+ Header = encode_response_header(Response,Size,?RESPONSE_STATE_OK),
+ ResponseContent = <<Header/binary,ResponseData/binary>>,
+ {ok, ResponseContent}.
+
+encode_response_data(Response)->
+ State=type_encoding:init(),
+ DataType =case Response#dubbo_response.is_event of
+ true->
+ dubbo_event;
+ false->
+ case Response#dubbo_response.data of
+ #dubbo_rpc_invocation{} ->
+ dubbo_rpc_invocation;
+ _ ->
+ unknow
+ end
+ end,
+ {ok,Bin} = encode_response_data(DataType,Response,Response#dubbo_response.data,State),
+ {ok,Bin}.
+encode_response_data(dubbo_event,Response,Data,State) ->
+ Bin = hessianEncode:encode(Data,State),
+ {ok,Bin};
+encode_response_data(dubbo_rpc_invocation,Response,Data,State) ->
+ Result = case Data of
+ null ->
+ [
+ hessianEncode:encode(?RESPONSE_NULL_VALUE, State)
+ ];
+ _ ->
+ {ArgsBin,_State2} = encode_arguments(Data,State),
+ [
+ hessianEncode:encode(?RESPONSE_VALUE, State),
+ ArgsBin
+ ]
+ end,
+ ResponseData = erlang:iolist_to_binary(Result),
+ {ok,ResponseData}.
+
+encode_response_header(Response,DataLen, ResponseState)->
+ Header2= Response#dubbo_response.serialize_type,
+ Header21=case Response#dubbo_response.is_twoway of
+ true -> Header2 bor 64;
+ false-> Header2
+ end,
+ Header22=case Response#dubbo_response.is_event of
+ true -> Header21 bor 32;
+ false-> Header21
+ end,
+ RequestId = Response#dubbo_response.mid,
+ Header = << ?DUBBO_MEGIC:16,Header22:8, ResponseState:8,RequestId:64,DataLen:32>>,
+ Header.
+encode_arguments(Data,State)->
+ {StateNew} = lists:foldl(fun(X,{StateTmp})->
+ StateTmpNew = type_encoding:enlist(X,StateTmp),
+ {StateTmpNew} end,
+ {State},Data#dubbo_rpc_invocation.parameterTypes),
+ {Bin,State2} = lists:foldl(fun(X,{BinTmp,StateTmp2})->
+ case hessianEncode:encode(X, StateTmp2) of
+ {ArgsBin,StateTmpNew} ->
+ {<<BinTmp/binary,ArgsBin/binary>>, StateTmpNew};
+ ArgsBin2 ->
+ {<<BinTmp/binary,ArgsBin2/binary>>, StateTmp2}
+ end end,
+ {<<>>,StateNew},Data#dubbo_rpc_invocation.parameters),
+ {Bin,State2}.
+
+-spec decode_header(binary())-> {State::ok|error,Type::request|response,Data::#dubbo_response{}|#dubbo_request{}}.
+decode_header(Header)->
+ <<?DUBBO_MEGIC_HIGH,?DUBBO_MEGIC_LOW,Flag:8,State:8,Mid:64,DataLen:32>> = Header,
+ if
+ (Flag band 16#80) == 0 ->
+ {DecodeState,Res} = decode_header(response,Flag,State,Mid,DataLen),
+ {DecodeState,response,Res};
+ true ->
+ {DecodeState,Req} = decode_header(request,Flag,State,Mid,DataLen),
+ {DecodeState,request,Req}
+ end.
+decode_header(request,Flag,State,Mid,DataLen)->
+ SerializeType = Flag band 16#1f,
+ IsTwoWay = if
+ (Flag band 16#40) /=0 -> true;
+ true -> false
+ end,
+ IsEvent = if
+ (Flag band 16#20) /=0 -> true;
+ true -> false
+ end,
+ Req = #dubbo_request{
+ is_event = IsEvent,
+ is_twoway = IsTwoWay,
+ mid = Mid,
+ mversion = <<"2.0.0">>,
+ serialize_type = SerializeType
+ },
+ {ok,Req};
+decode_header(response,Flag,State,Mid,DataLen)->
+ SerializeType = Flag band 16#1f,
+ IsEvent = if
+ (Flag band 16#20) /= 0 -> true;
+ true -> false
+ end,
+ Res = #dubbo_response{is_event = IsEvent,
+ serialize_type = SerializeType,
+ state = State,
+ mid = Mid
+ },
+ {ok,Res}.
+
+-spec decode_response(#dubbo_response{},binary())-> {ok,#dubbo_response{}}.
+decode_response(Res,Data)->
+ case Res#dubbo_response.serialize_type of
+ ?SERIALIZATION_FASTJSON ->
+ dubbo_serializa_fastjson:decode_response(Res,Data);
+ ?SERIALIZATION_HESSIAN ->
+ dubbo_serializa_hession:decode_response(Res,Data)
+ end.
+
+%%decode_response(?SERIALIZATION_FASTJSON,dubbo_rpc_invocation,Res,Data)->
+%% dubbo_serializa_fastjson:decode_response(dubbo_rpc_invocation,Res,Data);
+%%
+%%decode_response(?SERIALIZATION_HESSIAN,dubbo_rpc_invocation,Res,Data)->
+%% {Rest,Type,State} = hessianDecode2:decode(Data,hessianDecode2:init()),
+%% case Type of
+%% 1 ->
+%% {_,Object,DecodeState} = hessianDecode2:decode(Rest,State),
+%% {ok,Res#dubbo_response{data = Object,decode_state = DecodeState}};
+%% 2 ->
+%% {ok,Res#dubbo_response{data = null,decode_state = State}};
+%% _->
+%% lager:warning("decode unkonw type ~p ~p",[Type,Rest]),
+%% {Rest2,Object2,DecodeState2} = hessianDecode2:decode(Rest,State),
+%% lager:warning("decode unkonw type2 ~p ~p",[Object2,Rest2]),
+%% {ok,Res#dubbo_response{data = Object2,decode_state = DecodeState2}}
+%% end;
+%%decode_response(?SERIALIZATION_HESSIAN,dubbo_event,Res,Data)->
+%% {_Rest,undefined,_NewState} = hessianDecode2:decode(Data,hessianDecode2:init()),
+%% {ok,Res#dubbo_response{data = undefined}}.
+
+-spec decode_request(#dubbo_request{},binary())-> {ok,#dubbo_request{}}.
+decode_request(Req,Data)->
+ case Req#dubbo_request.serialize_type of
+ ?SERIALIZATION_FASTJSON ->
+ dubbo_serializa_fastjson:decode_request(Req,Data);
+ ?SERIALIZATION_HESSIAN ->
+ dubbo_serializa_hession:decode_request(Req,Data)
+ end.
+
+%%decode_request(dubbo_rpc_invocation,Req,Data)->
+%% {ResultList,NewState,RestData} = decode_request_body(Data,hessianDecode2:init(),[dubbo,path,version,method_name,desc_and_args,attachments]),
+%% [DubboVersion,Path,Version,MethodName,Desc,ArgsObj,Attachments]=ResultList,
+%% RpcData = #dubbo_rpc_invocation{className = Path,classVersion = Version,methodName = MethodName,parameterDesc = Data,parameters = ArgsObj,attachments = Attachments},
+%% Req2 = Req#dubbo_request{data = RpcData},
+%% {ok,Req2};
+%%
+%%decode_request(dubbo_event,Req,Data)->
+%% {_Rest,undefined,_NewState} = hessianDecode2:decode(Data,hessianDecode2:init()),
+%% {ok,Req#dubbo_request{data = undefined}}.
+%%
+%%decode_request_body(Data,State,List)->
+%% {ResultList,NewState,RestData} = decode_request_body(List,Data,State,[]),
+%% {lists:reverse(ResultList),NewState,RestData}.
+%%decode_request_body([ParseType|List],Data,State,ResultList)
+%% when ParseType==dubbo;ParseType==path;ParseType==version;ParseType==method_name ->
+%% {Rest,Result,NewState } = hessianDecode2:decode(Data,State),
+%% decode_request_body(List,Rest,NewState, [Result] ++ ResultList);
+%%decode_request_body([desc_and_args| List],Data,State,ResultList)->
+%% {Rest,ParameterDesc,State1 } = hessianDecode2:decode(Data,State),
+%% if
+%% size(ParameterDesc) == 0 ->
+%% decode_request_body(List,Rest,State1, [ [],[] ]++ ResultList);
+%% true ->
+%% ParameterDescArray = binary:split(ParameterDesc,<<";">>),
+%% {ArgsObjList,NewState,RestData} = decode_request_body_args(ParameterDescArray,Rest,State1,[]),
+%% decode_request_body(List,RestData,NewState, [ArgsObjList,ParameterDesc]++ ResultList)
+%% end;
+%%decode_request_body([attachments|List],Data,State,ResultList)->
+%% {Rest,Attachments,State1 } = hessianDecode2:decode(Data,State),
+%% AttachmentsList = dict:to_list(Attachments#map.dict),
+%% decode_request_body(List,Rest,State1,[AttachmentsList] ++ ResultList);
+%%decode_request_body([_Type1|List],Data,State,ResultList)->
+%% lager:warning("decode_request_body unknow type"),
+%% decode_request_body(List,Data,State, ResultList);
+%%decode_request_body([],Data,State,ResultList)->
+%% {ResultList,State,Data}.
+%%
+%%decode_request_body_args([],Data,State,ArgsObjList)->
+%% {ArgsObjList,State,Data};
+%%decode_request_body_args([ArgsType|RestList],Data,State,ArgsObjList) when ArgsType== <<>> ->
+%% decode_request_body_args(RestList,Data,State,ArgsObjList);
+%%decode_request_body_args([_ArgsType|RestList],Data,State,ArgsObjList) ->
+%% {Rest,ArgObj,NewState } = hessianDecode2:decode(Data,State),
+%% ArgObj2 = de_type_transfer:classobj_to_native(ArgObj,NewState),
+%% decode_request_body_args(RestList,Rest,NewState,ArgsObjList++[ArgObj2]).
\ No newline at end of file
diff --git a/src/de_common_fun.erl b/src/de_common_fun.erl
new file mode 100644
index 0000000..31eb143
--- /dev/null
+++ b/src/de_common_fun.erl
@@ -0,0 +1,24 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2017, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 27. Dec 2017 3:01 PM
+%%%-------------------------------------------------------------------
+-module(de_common_fun).
+-author("dlive").
+
+%% API
+-export([local_ip_v4/0,local_ip_v4_str/0]).
+
+local_ip_v4() ->
+ {ok, Addrs} = inet:getifaddrs(),
+ hd([
+ Addr || {_, Opts} <- Addrs, {addr, Addr} <- Opts,
+ size(Addr) == 4, Addr =/= {127,0,0,1}
+ ]).
+
+local_ip_v4_str()->
+ {V1,V2,V3,V4} =local_ip_v4(),
+ list_to_binary(io_lib:format("~p.~p.~p.~p",[V1,V2,V3,V4])).
diff --git a/src/de_heartbeat.erl b/src/de_heartbeat.erl
new file mode 100644
index 0000000..b6da7cb
--- /dev/null
+++ b/src/de_heartbeat.erl
@@ -0,0 +1,21 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 20. 十月 2016 下午5:55
+%%%-------------------------------------------------------------------
+-module(de_heartbeat).
+-author("dlive").
+
+-include("dubbo.hrl").
+%% API
+-export([generate_request/2]).
+generate_request(undefined,NeedResponse)->
+ RequestId = de_id_count:gen_id(),
+ generate_request(RequestId,NeedResponse);
+generate_request(RequestId,NeedResponse)->
+ Req = #dubbo_request{is_event = true,is_twoway = true,mid = RequestId,data = undefined,mversion= <<"2.0.0">>},
+ {ok,Bin} = de_codec:encode_request(Req),
+ {ok,Bin}.
\ No newline at end of file
diff --git a/src/de_id_count.erl b/src/de_id_count.erl
new file mode 100644
index 0000000..be07d1b
--- /dev/null
+++ b/src/de_id_count.erl
@@ -0,0 +1,177 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 17. 十月 2016 上午11:12
+%%%-------------------------------------------------------------------
+-module(de_id_count).
+-author("dlive").
+
+-behaviour(gen_server).
+
+%% API
+-export([start_link/0]).
+
+%% gen_server callbacks
+-export([init/1,
+ handle_call/3,
+ handle_cast/2,
+ handle_info/2,
+ terminate/2,
+ code_change/3]).
+-export([gen_id/0,get_index/2]).
+
+-define(SERVER, ?MODULE).
+-define(INDEX_ETS_TABLE,de_id_count_table).
+-define(MAX_NUM,9223372036854775807).
+-record(state, {}).
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @doc
+%% Starts the server
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(start_link() ->
+ {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link() ->
+ gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).
+
+%%%===================================================================
+%%% gen_server callbacks
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Initializes the server
+%%
+%% @spec init(Args) -> {ok, State} |
+%% {ok, State, Timeout} |
+%% ignore |
+%% {stop, Reason}
+%% @end
+%%--------------------------------------------------------------------
+-spec(init(Args :: term()) ->
+ {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term()} | ignore).
+init([]) ->
+ init_table(),
+ {ok, #state{}}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling call messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()},
+ State :: #state{}) ->
+ {reply, Reply :: term(), NewState :: #state{}} |
+ {reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} |
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_call(_Request, _From, State) ->
+ {reply, ok, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling cast messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_cast(Request :: term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_cast(_Request, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling all non call/cast messages
+%%
+%% @spec handle_info(Info, State) -> {noreply, State} |
+%% {noreply, State, Timeout} |
+%% {stop, Reason, State}
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_info(Info :: timeout() | term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_info(_Info, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% This function is called by a gen_server when it is about to
+%% terminate. It should be the opposite of Module:init/1 and do any
+%% necessary cleaning up. When it returns, the gen_server terminates
+%% with Reason. The return value is ignored.
+%%
+%% @spec terminate(Reason, State) -> void()
+%% @end
+%%--------------------------------------------------------------------
+-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
+ State :: #state{}) -> term()).
+terminate(_Reason, _State) ->
+ ok.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Convert process state when code is changed
+%%
+%% @spec code_change(OldVsn, State, Extra) -> {ok, NewState}
+%% @end
+%%--------------------------------------------------------------------
+-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{},
+ Extra :: term()) ->
+ {ok, NewState :: #state{}} | {error, Reason :: term()}).
+code_change(_OldVsn, State, _Extra) ->
+ {ok, State}.
+
+gen_id()->
+ try ets:update_counter(?INDEX_ETS_TABLE,cur_index,{2,1,?MAX_NUM,1}) of
+ NewCount ->
+ NewCount
+ catch
+ _Type:_Reason ->
+ (catch ets:insert(?INDEX_ETS_TABLE,{cur_index,1})),
+ ets:update_counter(?INDEX_ETS_TABLE,cur_index,{2,1,?MAX_NUM,1})
+ end.
+
+get_index(Type,Max)->
+ try ets:update_counter(?INDEX_ETS_TABLE,Type,{2,1,Max,1}) of
+ NewCount ->
+ NewCount
+ catch
+ _Type:_Reason ->
+ (catch ets:insert(?INDEX_ETS_TABLE,{Type,1})),
+ ets:update_counter(?INDEX_ETS_TABLE,Type,{2,1,Max,1})
+ end.
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
+init_table()->
+ try ets:new(de_id_count_table, [public,named_table]) of
+ de_id_count_table ->
+ ets:insert(?INDEX_ETS_TABLE,{cur_index,1}),
+ ok
+ catch
+ _Type:Reason ->
+ io:format("error init auto inc table reason:~p~n",[Reason])
+ end.
\ No newline at end of file
diff --git a/src/de_network_tools.erl b/src/de_network_tools.erl
new file mode 100644
index 0000000..7527885
--- /dev/null
+++ b/src/de_network_tools.erl
@@ -0,0 +1,28 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 21. Mar 2018 4:07 PM
+%%%-------------------------------------------------------------------
+-module(de_network_tools).
+-author("dlive").
+
+%% API
+-export([local_ip_v4/0,local_ipv4/0,local_ipv4_binary/0]).
+
+
+local_ip_v4() ->
+ {ok, Addrs} = inet:getifaddrs(),
+ hd([
+ Addr || {_, Opts} <- Addrs, {addr, Addr} <- Opts,
+ size(Addr) == 4, Addr =/= {127,0,0,1}
+ ]).
+
+local_ipv4_binary()->
+ {I1,I2,I3,I4}=local_ip_v4(),
+ list_to_binary(io_lib:format("~p.~p.~p.~p",[I1,I2,I3,I4])).
+local_ipv4()->
+ {I1,I2,I3,I4}=local_ip_v4(),
+ lists:flatten(io_lib:format("~p.~p.~p.~p",[I1,I2,I3,I4])).
diff --git a/src/de_type_transfer.erl b/src/de_type_transfer.erl
new file mode 100644
index 0000000..5d89dcc
--- /dev/null
+++ b/src/de_type_transfer.erl
@@ -0,0 +1,104 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 27. 十月 2016 下午8:28
+%%%-------------------------------------------------------------------
+-module(de_type_transfer).
+-author("dlive").
+
+-include("hessian.hrl").
+-include("dubbo.hrl").
+
+%% API
+-export([java_to_native/2,pre_process_typedef/3,response_to_native/1,classobj_to_native/2]).
+
+
+response_to_native(Response)->
+ java_to_native(Response#dubbo_response.data,Response#dubbo_response.decode_state).
+
+
+classobj_to_native(Data,DecodeState)->
+ java_to_native(Data,DecodeState).
+
+java_to_native(#object{values = ForeignData}=Data,State)->
+ ForeignDataNew = [java_to_native(ValueItem,State) || ValueItem <-ForeignData ],
+
+ case hessianDecode2:get_deftype(Data#object.typeRef,State) of
+ #type_def{fieldnames = ObjectFields,foreign_type = ForeignType } ->
+ case get_deftype(ForeignType) of
+ false->
+ error;
+ #type_def{fieldnames = NativeFields,native_type = NativeTupeName}->
+ AsDict = dict:from_list(lists:zip(ObjectFields,ForeignDataNew)),
+ NativeData = [dict:fetch(atom_to_binary(Key,utf8),AsDict) || Key <- NativeFields],
+ list_to_tuple( [NativeTupeName] ++ NativeData)
+ end;
+ Info ->
+ lager:warning("java_to_native error:~p",[Info]),
+ error
+ end;
+java_to_native(#list{values = ForeignData}=Data,State)->
+ ForeignDataNew = [java_to_native(ValueItem,State) || ValueItem <-ForeignData ],
+ ForeignDataNew;
+%% case hessianDecode2:get_deftype(Data#list.refNo,State) of
+%% #type_def{fieldnames = ObjectFields,foreign_type = ForeignType } ->
+%% case get_deftype(ForeignType) of
+%% false->
+%% error;
+%% #type_def{fieldnames = NativeFields,native_type = NativeTupeName}->
+%% lager:debug("test ForeignType ~p NativeTupeName ~p",[ForeignType,NativeTupeName]),
+%%%% AsDict = dict:from_list(lists:zip(ObjectFields,ForeignDataNew)),
+%%%% NativeData = [dict:fetch(atom_to_binary(Key,utf8),AsDict) || Key <- NativeFields],
+%%%% list_to_tuple( [NativeTupeName] ++ NativeData)
+%% ForeignDataNew
+%% end;
+%% Info ->
+%% lager:warning("java_to_native list error:~p",[Info]),
+%% error
+%% end;
+java_to_native(Data,_)->
+ lager:debug("java_to_native unkonw type ~p",[Data]),
+ Data.
+
+%%get_deftype([Item |DefTypeList],ForeignType)->
+%% if
+%% Item#type_def.foreign_type == ForeignType -> Item;
+%% true ->
+%% get_deftype(DefTypeList,ForeignType)
+%% end;
+%%get_deftype([],_ForeignType)->
+%% false.
+
+get_deftype(ForeignType)->
+
+ case type_register:lookup_foreign_type(ForeignType) of
+ undefined->
+ lager:debug("get deftype undefined ~p",[ForeignType]),
+ false;
+ #type_def{}=TypeDef->
+ lager:debug("get deftype success ~p",[ForeignType]),
+ TypeDef;
+ _->
+ lager:debug("get deftype undefined ~p",[ForeignType]),
+ false
+ end.
+
+pre_process_typedef(NativeType,ForeignType,FieldsNames)->
+ Type = #type_def{native_type = NativeType,foreign_type = ForeignType,fieldnames = FieldsNames},
+%% Type2=type_decoding:hash_store(Type),
+ type_register:regiest_foreign_native(Type),
+ lager:debug("pre_process_typedef ~p,~p",[NativeType,ForeignType]).
+%% case type_decoding:resolve_native_type(ForeignType) of
+%% undefined ->
+%%%% Type = #type_def{native_type = NativeType, foreign_type = ForeignType, fieldnames = record_info(fields,NativeType)},
+%% Type = #type_def{native_type = NativeType,foreign_type = ForeignType,fieldnames = FieldsNames},
+%% Type2=type_decoding:hash_store(Type),
+%%
+%% lager:debug("pre_process_typedef ~p,~p",[NativeType,ForeignType]);
+%% type_decoding:store_typepool(Type2);
+%% _->
+%% ok
+%% end.
\ No newline at end of file
diff --git a/src/dubbo_agent.erl b/src/dubbo_agent.erl
new file mode 100644
index 0000000..15e557a
--- /dev/null
+++ b/src/dubbo_agent.erl
@@ -0,0 +1,20 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 11. May 2018 12:15 AM
+%%%-------------------------------------------------------------------
+-module(dubbo_agent).
+-author("dlive").
+
+%% API
+-export([register_consumer/1]).
+
+register_consumer(Interface)->
+ ProviderList=[
+ "dubbo%3a%2f%2f127.0.0.1%3a20880%2fcom.alibaba.dubbo.performance.demo.provider.IHelloService%3fanyhost%3dtrue%26application%3dmesh-provider%26dubbo%3d2.6%26executes%3d30%26interface%3dcom.alibaba.dubbo.performance.demo.provider.IHelloService%26methods%3dhash%26pid%3d26029%26side%3dprovider%26timestamp%3d1514615143388"
+ ],
+ dubbo_consumer_pool:start_consumer(Interface,ProviderList),
+ ok.
diff --git a/src/dubbo_common.erl b/src/dubbo_common.erl
new file mode 100644
index 0000000..11abb42
--- /dev/null
+++ b/src/dubbo_common.erl
@@ -0,0 +1,13 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 17. 十月 2016 上午12:23
+%%%-------------------------------------------------------------------
+-module(dubbo_common).
+-author("dlive").
+
+%% API
+-export([]).
diff --git a/src/dubbo_config_util.erl b/src/dubbo_config_util.erl
new file mode 100644
index 0000000..c27f694
--- /dev/null
+++ b/src/dubbo_config_util.erl
@@ -0,0 +1,43 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 05. Jan 2018 12:21 AM
+%%%-------------------------------------------------------------------
+-module(dubbo_config_util).
+-author("dlive").
+
+-include("dubbo.hrl").
+%% API
+-export([gen_consumer/3,gen_provider/5]).
+
+
+gen_consumer(Application,Interface,Option)->
+ #consumer_config{
+ interface = Interface,
+ application = Application,
+ category = <<"consumers">> ,
+ check=false,
+ default_timeout = proplists:get_value(default_timeout,Option,500),
+ dubbo_version= proplists:get_value(dubbo_version,Option,?DUBBO_VERSION),
+ methods=[],
+ revision= <<"">>,
+ side= <<"consumers">>
+ }.
+
+gen_provider(Application,Port,Interface,MethodList,Option)->
+ Host = de_network_tools:local_ipv4_binary(),
+ MethodList2= [atom_to_binary(Item,utf8) || Item <- MethodList ],
+ #provider_config{
+ protocol= <<"dubbo">>,
+ host= Host,
+ port = Port,
+ interface=Interface,
+ anyhost=true,
+ executes=10,
+ application=Application,
+ methods = MethodList2,
+ side= <<"provider">>
+ }.
\ No newline at end of file
diff --git a/src/dubbo_consumer_pool.erl b/src/dubbo_consumer_pool.erl
new file mode 100644
index 0000000..70e4538
--- /dev/null
+++ b/src/dubbo_consumer_pool.erl
@@ -0,0 +1,287 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2017, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 28. Dec 2017 7:34 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_consumer_pool).
+-author("dlive").
+
+-behaviour(gen_server).
+
+%% API
+-export([start_link/0, start_consumer/2]).
+
+%% gen_server callbacks
+-export([init/1,
+ handle_call/3,
+ handle_cast/2,
+ handle_info/2,
+ terminate/2,
+ code_change/3]).
+
+-export([select_connection/1,select_connection/2]).
+
+-include("dubbo.hrl").
+-define(SERVER, ?MODULE).
+
+-define(INTERFCE_LIST_TABLE,interface_list).
+-define(PROVIDER_NODE_LIST_TABLE,provider_node_list).
+
+-record(state, {}).
+
+
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @doc
+%% Starts the server
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(start_link() ->
+ {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link() ->
+ gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).
+
+%%%===================================================================
+%%% gen_server callbacks
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Initializes the server
+%%
+%% @spec init(Args) -> {ok, State} |
+%% {ok, State, Timeout} |
+%% ignore |
+%% {stop, Reason}
+%% @end
+%%--------------------------------------------------------------------
+-spec(init(Args :: term()) ->
+ {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term()} | ignore).
+init([]) ->
+ init_ets_table(),
+ {ok, #state{}}.
+init_ets_table()->
+ try ets:new(?INTERFCE_LIST_TABLE, [bag,public,named_table,{keypos,2}]) of
+ ?INTERFCE_LIST_TABLE ->
+ ok
+ catch
+ _Type:Reason ->
+ lager:error("new ets table error ~p",[Reason]),
+ error
+ end,
+ try ets:new(?PROVIDER_NODE_LIST_TABLE, [bag,public,named_table,{keypos,2}]) of
+ ?PROVIDER_NODE_LIST_TABLE ->
+ ok
+ catch
+ _Type1:Reason1 ->
+ lager:error("new ets table error ~p",[Reason1]),
+ error
+ end,
+ ok.
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling call messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()},
+ State :: #state{}) ->
+ {reply, Reply :: term(), NewState :: #state{}} |
+ {reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} |
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+
+handle_call({add_consumer,Interface,ProviderNodeList}, _From, State) ->
+
+ OldProviderList = get_interface_provider_node(Interface),
+ NewProviderList = add_consumer(ProviderNodeList,[]),
+ DeleteProverList = OldProviderList -- NewProviderList,
+ clean_invalid_provider(DeleteProverList),
+ {reply, ok, State};
+handle_call(_Request, _From, State) ->
+ {reply, ok, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling cast messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_cast(Request :: term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_cast(_Request, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling all non call/cast messages
+%%
+%% @spec handle_info(Info, State) -> {noreply, State} |
+%% {noreply, State, Timeout} |
+%% {stop, Reason, State}
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_info(Info :: timeout() | term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_info(_Info, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% This function is called by a gen_se rver when it is about to
+%% terminate. It should be the opposite of Module:init/1 and do any
+%% necessary cleaning up. When it returns, the gen_server terminates
+%% with Reason. The return value is ignored.
+%%
+%% @spec terminate(Reason, State) -> void()
+%% @end
+%%--------------------------------------------------------------------
+-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
+ State :: #state{}) -> term()).
+terminate(_Reason, _State) ->
+ ok.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Convert process state when code is changed
+%%
+%% @spec code_change(OldVsn, State, Extra) -> {ok, NewState}
+%% @end
+%%--------------------------------------------------------------------
+-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{},
+ Extra :: term()) ->
+ {ok, NewState :: #state{}} | {error, Reason :: term()}).
+code_change(_OldVsn, State, _Extra) ->
+ {ok, State}.
+
+start_consumer(Interface,ProviderNodeInfo)->
+ gen_server:call(?SERVER,{add_consumer,Interface,ProviderNodeInfo}).
+
+
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
+add_consumer([],RegisterList)->
+ RegisterList;
+add_consumer([ProviderNodeInfo|ProviderList],RegisterList)->
+ case dubbo_node_config_util:parse_provider_info(ProviderNodeInfo) of
+ {ok,ProviderConfig} ->
+ HostFlag=get_host_flag(ProviderConfig),
+ case ets:lookup(?PROVIDER_NODE_LIST_TABLE,HostFlag) of
+ []->
+ ConnectionList = start_provider_process(HostFlag,30,ProviderConfig),
+ ok = update_connection_info(ProviderConfig#provider_config.interface,HostFlag,ConnectionList,true),
+ ok;
+ List ->
+ List2 = lists:map(fun(#provider_node_list{connection_info = ConnectionItem })->
+ ConnectionItem
+ end,List),
+ ok = update_connection_info(ProviderConfig#provider_config.interface,HostFlag,List2,false),
+ ok
+ end,
+ add_consumer(ProviderList,[HostFlag]++RegisterList);
+ {error,R1} ->
+ lager:error("parse provider info error reason ~p",[R1]),
+ add_consumer(ProviderList,RegisterList)
+ end.
+
+start_provider_process(HostFlag,Weight,ProviderConfig) ->
+ ExecutesList=lists:seq(1,ProviderConfig#provider_config.executes),
+ ConnectionList= lists:map(fun(Item) ->
+ ConnectionFlag= << HostFlag/binary,(integer_to_binary(Item))/binary >>,
+ ConnectionFlagTerm= binary_to_atom(ConnectionFlag,utf8),
+ AChild = {ConnectionFlagTerm,{dubbo_netty_client, start_link, [ConnectionFlagTerm,HostFlag,ProviderConfig,Item]}, permanent, 2000, worker, [dubbo_netty_client]},
+ {ok,Pid} = dubbo_consumer_pool_sup:add_children(AChild),
+ lager:info("start provider ~p pid info ~p~n",[HostFlag,Pid]),
+ #connection_info{connection_id = ConnectionFlagTerm,pid = Pid,weight = Weight,host_flag = HostFlag}
+ end,ExecutesList),
+ ConnectionList.
+get_host_flag(ProviderConfig)->
+ HostFlag= << (list_to_binary(ProviderConfig#provider_config.host))/binary,<<"_">>/binary,(integer_to_binary(ProviderConfig#provider_config.port))/binary>>,
+ HostFlag.
+
+update_connection_info(Interface,HostFlag,ConnectionList,IsUpdateProvideNode)->
+ lists:map(fun(Item) ->
+ I1 = ets:insert(?INTERFCE_LIST_TABLE,#interface_list{interface = Interface,connection_info = Item}),
+ lager:debug("save INTERFCE_LIST_TABLE ~p info:~p",[Interface,I1]),
+ case IsUpdateProvideNode of
+ true->
+ I2 = ets:insert(?PROVIDER_NODE_LIST_TABLE,#provider_node_list{host_flag = HostFlag,connection_info = Item }),
+ lager:debug("save PROVIDER_NODE_LIST_TABLE ~p info:~p",[HostFlag,I2]);
+ false->
+ ok
+ end,
+ ok
+ end,ConnectionList),
+ ok.
+
+get_interface_provider_node(Interface)->
+ case ets:lookup(?INTERFCE_LIST_TABLE,Interface) of
+ []->
+ [];
+ List->
+ ListRet = [Item#interface_list.connection_info#connection_info.host_flag || Item <- List],
+ lists_util:del_duplicate(ListRet)
+ end.
+
+select_connection(Interface)->
+ RandNum = rand:uniform(2048),
+ select_connection(Interface,RandNum).
+select_connection(Interface,RandNum)->
+ case ets:lookup(?INTERFCE_LIST_TABLE,Interface) of
+ []->
+ {error,none};
+ List->
+ Len = length(List),
+ RemNum = (RandNum rem Len)+1,
+%% RandNum2 = if
+%% RandNum==Len -> RandNum-1;
+%% true->RandNum
+%% end,
+ InterfaceListItem = lists:nth(RemNum,List),
+ {ok,InterfaceListItem#interface_list.connection_info}
+ end.
+
+clean_invalid_provider([])->
+ ok;
+clean_invalid_provider([HostFlag | DeleteProverList])->
+ case ets:lookup(?PROVIDER_NODE_LIST_TABLE,HostFlag) of
+ []->
+ ok;
+ ProviderNodeList->
+ io:format("ConnectionList ~p~n",[ProviderNodeList]),
+ ProviderNodeList1 = lists_util:del_duplicate(ProviderNodeList),
+ clean_connection_info(ProviderNodeList1)
+ end,
+ clean_invalid_provider(DeleteProverList).
+
+clean_connection_info(ProviderNodeList)->
+ lists:map(fun(Item)->
+ Pid=Item#provider_node_list.connection_info#connection_info.pid,
+ ConnectionId=Item#provider_node_list.connection_info#connection_info.connection_id,
+ Pattern=#interface_list{pid=Pid,_='_'},
+ ets:delete_object(?INTERFCE_LIST_TABLE,Pattern),
+ dubbo_consumer_pool_sup:stop_children(ConnectionId)
+ end,ProviderNodeList),
+ ok.
\ No newline at end of file
diff --git a/src/dubbo_consumer_pool_sup.erl b/src/dubbo_consumer_pool_sup.erl
new file mode 100644
index 0000000..a1ce87e
--- /dev/null
+++ b/src/dubbo_consumer_pool_sup.erl
@@ -0,0 +1,80 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2017, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 30. Dec 2017 9:58 AM
+%%%-------------------------------------------------------------------
+-module(dubbo_consumer_pool_sup).
+-author("dlive").
+
+-behaviour(supervisor).
+
+%% API
+-export([start_link/0,add_children/1,stop_children/1]).
+
+%% Supervisor callbacks
+-export([init/1]).
+
+-define(SERVER, ?MODULE).
+
+%%%===================================================================
+%%% API functions
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @doc
+%% Starts the supervisor
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(start_link() ->
+ {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link() ->
+ supervisor:start_link({local, ?SERVER}, ?MODULE, []).
+
+%%%===================================================================
+%%% Supervisor callbacks
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Whenever a supervisor is started using supervisor:start_link/[2,3],
+%% this function is called by the new process to find out about
+%% restart strategy, maximum restart frequency and child
+%% specifications.
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(init(Args :: term()) ->
+ {ok, {SupFlags :: {RestartStrategy :: supervisor:strategy(),
+ MaxR :: non_neg_integer(), MaxT :: non_neg_integer()},
+ [ChildSpec :: supervisor:child_spec()]
+ }} |
+ ignore |
+ {error, Reason :: term()}).
+init([]) ->
+ RestartStrategy = one_for_one,
+ MaxRestarts = 1000,
+ MaxSecondsBetweenRestarts = 3600,
+
+ SupFlags = {RestartStrategy, MaxRestarts, MaxSecondsBetweenRestarts},
+
+ Restart = permanent,
+ Shutdown = 2000,
+ Type = worker,
+
+%% AChild = {'AName', {'AModule', start_link, []}, Restart, Shutdown, Type, ['AModule']},
+
+ {ok, {SupFlags, []}}.
+
+
+add_children(ChildSpec)->
+ supervisor:start_child(?SERVER,ChildSpec).
+stop_children(ChildID)->
+ supervisor:terminate_child(?SERVER,ChildID).
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
diff --git a/src/dubbo_directory.erl b/src/dubbo_directory.erl
new file mode 100644
index 0000000..7551d2f
--- /dev/null
+++ b/src/dubbo_directory.erl
@@ -0,0 +1,146 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2017, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 26. Feb 2017 10:27 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_directory).
+-author("dlive").
+
+-behaviour(gen_server).
+
+%% API
+-export([start_link/0]).
+
+%% gen_server callbacks
+-export([init/1,
+ handle_call/3,
+ handle_cast/2,
+ handle_info/2,
+ terminate/2,
+ code_change/3]).
+
+-define(SERVER, ?MODULE).
+
+-record(state, {}).
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @doc
+%% Starts the server
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(start_link() ->
+ {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link() ->
+ gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).
+
+%%%===================================================================
+%%% gen_server callbacks
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Initializes the server
+%%
+%% @spec init(Args) -> {ok, State} |
+%% {ok, State, Timeout} |
+%% ignore |
+%% {stop, Reason}
+%% @end
+%%--------------------------------------------------------------------
+-spec(init(Args :: term()) ->
+ {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term()} | ignore).
+init([]) ->
+ {ok, #state{}}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling call messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()},
+ State :: #state{}) ->
+ {reply, Reply :: term(), NewState :: #state{}} |
+ {reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} |
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_call(_Request, _From, State) ->
+ {reply, ok, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling cast messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_cast(Request :: term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_cast(_Request, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling all non call/cast messages
+%%
+%% @spec handle_info(Info, State) -> {noreply, State} |
+%% {noreply, State, Timeout} |
+%% {stop, Reason, State}
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_info(Info :: timeout() | term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_info(_Info, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% This function is called by a gen_server when it is about to
+%% terminate. It should be the opposite of Module:init/1 and do any
+%% necessary cleaning up. When it returns, the gen_server terminates
+%% with Reason. The return value is ignored.
+%%
+%% @spec terminate(Reason, State) -> void()
+%% @end
+%%--------------------------------------------------------------------
+-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
+ State :: #state{}) -> term()).
+terminate(_Reason, _State) ->
+ ok.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Convert process state when code is changed
+%%
+%% @spec code_change(OldVsn, State, Extra) -> {ok, NewState}
+%% @end
+%%--------------------------------------------------------------------
+-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{},
+ Extra :: term()) ->
+ {ok, NewState :: #state{}} | {error, Reason :: term()}).
+code_change(_OldVsn, State, _Extra) ->
+ {ok, State}.
+
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
diff --git a/src/dubbo_invoker.erl b/src/dubbo_invoker.erl
new file mode 100644
index 0000000..fa4821a
--- /dev/null
+++ b/src/dubbo_invoker.erl
@@ -0,0 +1,96 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 06. Mar 2018 12:17 AM
+%%%-------------------------------------------------------------------
+-module(dubbo_invoker).
+-author("dlive").
+
+-include("dubbo.hrl").
+%% API
+-export([invoke_request/2,invoke_request/5]).
+
+-spec invoke_request(Interface::binary(),Request::#dubbo_request{})->
+ {ok,reference()}|
+ {ok,reference(),Data::any(),RpcContent::list()}|
+ {error,Reason::timeout|no_provider|any()}.
+invoke_request(Interface,Request)->
+ invoke_request(Interface,Request,[],#{},self()).
+
+-spec invoke_request(Interface::binary(),Request::#dubbo_request{},RpcContext::list(),RequestState::map(),CallBackPid::pid())->
+ {ok,reference()}|
+ {ok,reference(),Data::any(),RpcContent::list()}|
+ {error,Reason::timeout|no_provider|request_full|any()}.
+invoke_request(Interface,Request,RpcContext,RequestState,CallBackPid)->
+ case dubbo_consumer_pool:select_connection(Interface,Request#dubbo_request.mid) of
+ {ok,#connection_info{pid=Pid,host_flag = HostFlag}} ->
+ case dubbo_traffic_control:check_goon(HostFlag,199) of
+ ok ->
+ Request2 = merge_attachments(Request,RpcContext),
+ {ok,RequestData} = de_codec:encode_request(Request2),
+ Ref=get_ref(RequestState),
+ RequestState2 = request_context:update(<<"t_agent_e">>,RequestState),
+ gen_server:cast(Pid,{send_request,Ref,Request2,RequestData,CallBackPid,RequestState2}),
+ case is_sync(RequestState) of
+ true->
+ sync_receive(Ref,get_timeout(RequestState));
+ false-> {ok, Ref}
+ end;
+ full ->
+ {error,request_full}
+ end;
+ {error,none}->
+ lager:error("[INVOKE] ~p error Reason no_provider",[Interface]),
+ {error,no_provider};
+ {error,R1}->
+ lager:error("[INVOKE] ~p error Reason ~p",[Interface,R1]),
+ {error,R1}
+ end.
+
+
+is_sync(Option)->
+ maps:is_key(sync,Option).
+%% lists:member(sync,Option).
+get_ref(Option)->
+ maps:get(ref,Option,make_ref()).
+%% case maps:is_key(ref,Option) of
+%% true->
+%%
+%% end,
+%% case proplists:get_value(ref,Option) of
+%% undefined->
+%% make_ref();
+%% Ref->
+%% Ref
+%% end.
+
+get_timeout(Option)->
+ maps:get(timeout,Option,?REQUEST_TIME_OUT).
+
+
+sync_receive(Ref,TimeOut)->
+ receive
+ {'$gen_cast',{msg_back,Ref,Response,RpcContent}}->
+ {ok,Ref,Response,RpcContent}
+ after
+ TimeOut ->
+ {error,timeout}
+ end.
+
+merge_attachments(Request,Option)->
+ Attachements= Request#dubbo_request.data#dubbo_rpc_invocation.attachments,
+ case lists:keyfind(attachments,1,Option) of
+ false->OptionAttachments=[];
+ {attachments,OptionAttachments}->
+ OptionAttachments
+ end,
+ List=[
+ {<<"version">>, <<"0.0.0">>},
+ {<<"timeout">>, <<"500">>}
+ ],
+ Attachements2= lists:merge3(Attachements,OptionAttachments,List),
+ Data2=Request#dubbo_request.data#dubbo_rpc_invocation{attachments = Attachements2},
+ Request#dubbo_request{data = Data2}.
diff --git a/src/dubbo_netty_client.erl b/src/dubbo_netty_client.erl
new file mode 100644
index 0000000..d5ba464
--- /dev/null
+++ b/src/dubbo_netty_client.erl
@@ -0,0 +1,452 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 14. 十月 2016 下午3:31
+%%%-------------------------------------------------------------------
+-module(dubbo_netty_client).
+-author("dlive").
+
+-behaviour(gen_server).
+
+-include("dubbo.hrl").
+%% API
+-export([start_link/4]).
+
+%% gen_server callbacks
+-export([init/1,
+ handle_call/3,
+ handle_cast/2,
+ handle_info/2,
+ terminate/2,
+ code_change/3]).
+-export([check_recv_data/2]).
+
+-define(SERVER, ?MODULE).
+
+-record(heartbeat,{last_write=0,last_read=0,timeout=60000,max_timeout=61000}).
+-record(state, {provider_config,socket =undefined,
+ heartbeat=#heartbeat{},
+ recv_buffer= <<>> , %%从服务端接收的数据
+ host_flag
+}).
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @doc
+%% Starts the server
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(start_link(Name::binary(),HostFlag::binary(),ProviderConfig::#provider_config{},integer()) ->
+ {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link(Name,HostFlag,ProviderConfig,Index) ->
+ gen_server:start_link({local, Name}, ?MODULE, [HostFlag,ProviderConfig,Index], []).
+
+%%%===================================================================
+%%% gen_server callbacks
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Initializes the server
+%%
+%% @spec init(Args) -> {ok, State} |
+%% {ok, State, Timeout} |
+%% ignore |
+%% {stop, Reason}
+%% @end
+%%--------------------------------------------------------------------
+-spec(init(Args :: term()) ->
+ {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term()} | ignore).
+init([HostFlag,ProviderConfig,Index]) ->
+ erlang:process_flag(min_bin_vheap_size, 1024*1024),
+%% erlang:process_flag(min_heap_size, 1024*1024),
+%% BindScheduler = (Index rem erlang:system_info(schedulers_online))+1,
+%% lager:info("will bind to scheduler ~p",[BindScheduler]),
+%% erlang:process_flag(scheduler, BindScheduler),
+%% erlang:process_flag(priority, high),
+
+ #provider_config{host = Host,port = Port}=ProviderConfig,
+ State = case open(Host,Port) of
+ {ok,Socket} ->
+ #state{socket = Socket};
+ {error}->
+ #state{}
+ end,
+ NowStamp = time_util:timestamp_ms(),
+ HeartBeatInfo = #heartbeat{last_read = NowStamp,last_write = NowStamp},
+ lager:info("netty client start ~p",[HostFlag]),
+%% start_heartbeat_timer(HeartBeatInfo),
+ {ok, State#state{provider_config=ProviderConfig,heartbeat=HeartBeatInfo,host_flag = HostFlag}}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling call messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()},
+ State :: #state{}) ->
+ {reply, Reply :: term(), NewState :: #state{}} |
+ {reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} |
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_call(_Request, _From, State) ->
+ {reply, ok, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling cast messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_cast(Request :: term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+
+handle_cast({send_request,Ref,Request,Data,SourcePid,RequestState}, State) ->
+ RequestState2 = request_context:update(<<"t_net_b">>,RequestState),
+ lager:debug("[send_request begin] send data to provider consumer mid ~p pid ~p sourcePid ~p",[Request#dubbo_request.mid,self(),SourcePid]),
+ NewState = case send_msg(Data,State) of
+ ok->
+ save_request_info(Request,SourcePid,Ref,RequestState2),
+ lager:debug("[send_request end] send data to provider consumer pid ~p state ok",[self()]),
+ State;
+ {error,closed}->
+ State2 = reconnect(State),
+ State2;
+ {error,R1}->
+ lager:error("[send_request end] send data to provider consumer pid error ~p ~p",[self(),R1]),
+ State
+ end,
+ HeartbeatInfo =update_heartbeat(write,NewState#state.heartbeat),
+ {noreply, NewState#state{heartbeat = HeartbeatInfo}};
+
+handle_cast(_Request, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling all non call/cast messages
+%%
+%% @spec handle_info(Info, State) -> {noreply, State} |
+%% {noreply, State, Timeout} |
+%% {stop, Reason, State}
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_info(Info :: timeout() | term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+
+
+handle_info({tcp,_Port,Data}, #state{recv_buffer = RecvBuffer} = State) ->
+%% inet:setopts(State#state.socket, [{active, once}]),
+%% lager:debug("[INFO] recv one data ~w",[Data]),
+ {ok,NextBuffer,NewState} = case check_recv_data(<< RecvBuffer/binary,Data/binary >>,State) of
+ {next_buffer,NextBuffer2,State3}->
+ lager:debug("[INFO] recv one data state wait next_buffer"),
+ {ok,NextBuffer2,State3}
+ end,
+%% HeartbeatInfo =update_heartbeat(write,NewState#state.heartbeat),
+ {noreply, NewState#state{recv_buffer = NextBuffer}};
+handle_info({tcp_closed,Port},State)->
+ NewState=reconnect(State),
+ {noreply, NewState};
+handle_info({timeout, _TimerRef, {reconnect}},State)->
+ NewState=reconnect(State),
+ {noreply, NewState};
+handle_info({timeout, _TimerRef, {heartbeat_timer}},State) ->
+ {ok,NewState} = case check_heartbeat_state(State) of
+ {normal}-> {ok,State};
+ {send_heart}->
+%% @todo send_heartbeat_msg(undefined,true,State);
+ {ok,State};
+ {reconnect} ->
+ %% @todo reconnect
+ {ok,State}
+ end,
+ HeartbeatInfo = update_heartbeat(write,NewState#state.heartbeat),
+ start_heartbeat_timer(HeartbeatInfo),
+ {noreply,NewState#state{heartbeat = HeartbeatInfo}};
+handle_info(_Info,State) ->
+ lager:warning("[INFO] get one info:~p",[_Info]),
+%% inet:setopts(State#state.socket, [{active, once}]),
+%% case State#state.tmp_pid of
+%% undefined ->ok;
+%% Pid ->
+%% gen_server:cast(Pid,{msg_back})
+%% end,
+ HeartbeatInfo =update_heartbeat(write,State#state.heartbeat),
+ {noreply, State#state{heartbeat = HeartbeatInfo}}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% This function is called by a gen_server when it is about to
+%% terminate. It should be the opposite of Module:init/1 and do any
+%% necessary cleaning up. When it returns, the gen_server terminates
+%% with Reason. The return value is ignored.
+%%
+%% @spec terminate(Reason, State) -> void()
+%% @end
+%%--------------------------------------------------------------------
+-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
+ State :: #state{}) -> term()).
+terminate(_Reason, _State) ->
+ lager:warning("terminate reason:~p",[_Reason]),
+ ok.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Convert process state when code is changed
+%%
+%% @spec code_change(OldVsn, State, Extra) -> {ok, NewState}
+%% @end
+%%--------------------------------------------------------------------
+-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{},
+ Extra :: term()) ->
+ {ok, NewState :: #state{}} | {error, Reason :: term()}).
+code_change(_OldVsn, State, _Extra) ->
+ {ok, State}.
+
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
+
+open(Host,Port)->
+ lager:debug("will connect to provider ~p ~p",[Host,Port]),
+ %
+ case gen_tcp:connect(Host,Port,[
+ binary,
+ {packet,0},{active, false},
+ {reuseaddr,true},
+ {delay_send, true},
+ {nodelay, true},
+ {high_watermark, 512 * 1024},
+ {low_watermark, 256 * 1024},
+%% {high_msgq_watermark,128 * 1024},
+%% {low_msgq_watermark,64 * 1024},
+ {sndbuf, 512 * 1024},
+ {recbuf, 512 * 1024}
+ ]) of
+ {ok,Sockets} ->
+%% inet:setopts(Sockets, [{active, once}]),
+ inet:setopts(Sockets, [{active, true}]),
+ {ok,Sockets};
+ Info ->
+ lager:error("start netty client ~p~n",[Info]),
+ {error,Info}
+ end.
+
+reconnect(State)->
+ #provider_config{host = Host,port = Port} = State#state.provider_config,
+ case State#state.socket of
+ undefined ->ok;
+ Socket->
+ gen_tcp:close(Socket)
+ end,
+ case open(Host,Port) of
+ {ok,Socket2}->
+ State#state{socket = Socket2,recv_buffer = <<>>};
+ {error,_Info}->
+ erlang:start_timer(2000,self(),{reconnect}),
+ State#state{socket = undefined}
+ end.
+
+send_msg(Msg,State) ->
+ case State#state.socket of
+ undefined->
+ {error,closed};
+ Socket ->
+ case gen_tcp:send(Socket,Msg) of
+ ok->
+ ok;
+ {error,Reason}->
+ lager:error("send to server error,reason:~p",[Reason]),
+ {error,Reason}
+ end
+ end.
+
+%%%=================================================================
+%%% 心跳检测
+%%%=================================================================
+start_heartbeat_timer(HeartbeatInfo)->
+ erlang:start_timer(HeartbeatInfo#heartbeat.timeout, self() , {heartbeat_timer}),
+ ok.
+update_heartbeat(write,Info)->
+ Info#heartbeat{last_write = time_util:timestamp_ms()};
+update_heartbeat(read,Info)->
+ Info#heartbeat{last_read = time_util:timestamp_ms()}.
+
+
+check_heartbeat_state(#state{heartbeat = HeartBeatInfo}=_State)->
+ Now = time_util:timestamp_ms(),
+ #heartbeat{last_read = LastRead,last_write = LastWrite,timeout = Timeout,max_timeout = MaxTimeout} = HeartBeatInfo,
+ if
+ (Now - LastRead) > Timeout ->
+ {send_heart};
+ (Now - LastWrite) > Timeout ->
+ {send_heart};
+ (Now - LastRead) > MaxTimeout ->
+ {reconnect};
+ true->
+ {normal}
+ end.
+
+
+send_heartbeat_msg(Mid,NeedResponse,State)->
+ {ok,Bin} = de_heartbeat:generate_request(Mid,NeedResponse),
+ NewState = case send_msg(Bin,State) of
+ ok ->
+ lager:info("send one heartbeat msg to server"),
+ State;
+ {error,_Reason} ->
+ State2 = reconnect(State),
+ State2
+ end,
+ {ok,NewState}.
+
+%%%=================================================================
+%%% 接收数据处理
+%%%=================================================================
+-spec check_recv_data(Data::binary(),State::#state{})->{ready,ReadyData::binary()} | {ready,ReadyData::binary(),NextBuffer::binary()}.
+check_recv_data(<<?DUBBO_MEGIC_HIGH,?DUBBO_MEGIC_LOW,Rest/binary>> = Data,State) when byte_size(Rest)<14 ->
+ {next_buffer,Data,State};
+check_recv_data(<<?DUBBO_MEGIC_HIGH,?DUBBO_MEGIC_LOW,_OtherFlag:80,DataLen:32,Rest/binary>> = Data,State) ->
+ RestSize = byte_size(Rest),
+ if
+ DataLen==RestSize ->
+ {ok,State2} = process_data(Data,State),
+ {next_buffer,<<>>,State2};
+ DataLen>RestSize ->
+ lager:warning("need wait next buffer data ~p",[Data]),
+ {next_buffer,Data,State};
+ DataLen<RestSize ->
+ <<ReadyData:DataLen/binary,NextBuffer/binary>> = Rest,
+ OneData = <<?DUBBO_MEGIC_HIGH:8,?DUBBO_MEGIC_LOW:8,_OtherFlag:80,DataLen:32,ReadyData/binary>>,
+ {ok,State3} = process_data(OneData,State),
+%% lager:warning("recevi more data ~w ",[NextBuffer]),
+ check_recv_data(NextBuffer,State3)
+ end;
+check_recv_data(<<Error/integer,Data/binary>>,State)->
+ lager:error("recv bad header data,Begin Byte:~p",[Error]),
+ check_recv_data(Data,State);
+check_recv_data(<<>>,State)->
+ {next_buffer,<<>>,State}.
+
+
+process_data(Data,State)->
+ TmpTime = time_util:timestamp_ms(),
+ <<Header:16/binary,RestData/binary>> = Data,
+ case de_codec:decode_header(Header) of
+ {ok,response,ResponseInfo}->
+ %%心跳包的回应，是否会造成错误
+ dubbo_traffic_control:decr_count(State#state.host_flag),
+ case get_earse_request_info(ResponseInfo#dubbo_response.mid) of
+ undefined->
+ lager:error("dubbo response can't find request data,response ~p",[ResponseInfo]);
+ {SourcePid,Ref,RequestState} ->
+%% RequestState2 = request_context:update(<<"t_net_b">>,TmpTime,RequestState),
+ RequestState3 = request_context:update(<<"t_net_e">>,RequestState),
+
+ {ok,Res} = de_codec:decode_response(ResponseInfo,RestData),
+
+ %%从另一条路返回
+%% case Res#dubbo_response.is_event of
+%% false ->
+%% mesh_agent_invoker:response(Ref,Res#dubbo_response.data,RequestState3);
+%% _->
+%% ok
+%% end
+
+ %% 从原路返回
+ case Res#dubbo_response.is_event of
+ false ->
+ gen_server:cast(SourcePid,{response_process,Ref,RequestState3,Res#dubbo_response.data});
+ _->
+ ok
+ end
+%% gen_server:cast(SourcePid,{response_process,Ref,ResponseInfo,RestData,RequestState3})
+
+%% lager:debug("will cast mid ~p to source process SourcePid ~p",[Response#dubbo_response.mid,SourcePid]),
+%% RpcContent=[],
+%% ResponseData = de_type_transfer:response_to_native(Response),
+%% lager:debug("one response ~p",[Response]),
+%% gen_server:cast(SourcePid,{msg_back,Ref,Response,RpcContent,RequestState3})
+ end,
+
+
+
+%% {ok,Res} = de_codec:decode_response(ResponseInfo,RestData),
+%% lager:info("get one response mid ~p, is_event ~p state ~p",[Res#dubbo_response.mid,Res#dubbo_response.is_event,Res#dubbo_response.state]),
+%% {ok,State3} =process_response(Res#dubbo_response.is_event,Res,State,TmpTime),
+ {ok,State};
+ {ok,request,RequestInfo}->
+ {ok,Req} = de_codec:decode_request(RequestInfo,RestData),
+ lager:info("get one request mid ~p, is_event ~p",[Req#dubbo_request.mid,Req#dubbo_request.is_event]),
+ {ok,State2} = process_request(Req#dubbo_request.is_event,Req,State),
+ {ok,State2};
+ {error,Type,RelData}->
+ lager:error("process_data error type ~p RelData ~p",[Type,RelData]),
+ {ok,State}
+ end.
+
+
+%% @doc process event
+-spec process_response(IsEvent::boolean(),#dubbo_response{},#state{},term())->ok.
+process_response(false,Response,State,TmpTime)->
+ dubbo_traffic_control:decr_count(State#state.host_flag),
+ case get_earse_request_info(Response#dubbo_response.mid) of
+ undefined->
+ lager:error("dubbo response can't find request data,response ~p",[Response]);
+ {SourcePid,Ref,RequestState} ->
+%% RequestState2 = request_context:update(<<"t_net_b">>,TmpTime,RequestState),
+ RequestState3 = request_context:update(<<"t_net_e">>,RequestState),
+%% lager:debug("will cast mid ~p to source process SourcePid ~p",[Response#dubbo_response.mid,SourcePid]),
+ RpcContent=[],
+%% ResponseData = de_type_transfer:response_to_native(Response),
+%% lager:debug("one response ~p",[Response]),
+ gen_server:cast(SourcePid,{msg_back,Ref,Response,RpcContent,RequestState3})
+ end,
+ {ok,State};
+process_response(true,Response,State,TmpTime)->
+
+ {ok,State}.
+
+process_request(true,Request,State)->
+ {ok,NewState} = send_heartbeat_msg(Request#dubbo_request.mid,false,State),
+ {ok,NewState};
+process_request(false,Request,State)->
+ {ok,State}.
+
+
+save_request_info(Request,SourcePid,Ref,RequestState)->
+%% SaveFlag = get_request_flag(),
+
+ put(Request#dubbo_request.mid,{SourcePid,Ref,RequestState}).
+get_earse_request_info(Mid)->
+%% Flag=get_request_flag(Mid),
+ erase(Mid).
+
+
+
+
+get_request_flag(Mid)->
+ Mid.
+%% list_to_binary(io_lib:format(<<"request_~p">>,[Mid])).
\ No newline at end of file
diff --git a/src/dubbo_node_config_util.erl b/src/dubbo_node_config_util.erl
new file mode 100644
index 0000000..f0636e2
--- /dev/null
+++ b/src/dubbo_node_config_util.erl
@@ -0,0 +1,102 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2017, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 30. Dec 2017 2:27 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_node_config_util).
+-author("dlive").
+
+-include("dubbo.hrl").
+%% API
+-export([parse_provider_info/1,gen_provider_info/1]).
+
+%%
+parse_provider_info(ProviderStr)->
+ case http_uri:parse(http_uri:decode(ProviderStr),[{scheme_defaults,[{dubbo,20880}]}]) of
+ {ok, {Scheme, UserInfo, Host, Port, Path, Query}} ->
+ QueryStr = case lists:prefix("?",Query) of
+ true ->
+ [_|Query2] = Query,
+ Query2;
+ false->
+ Query
+ end,
+ QueryListTmp = string:tokens(QueryStr,"&"),
+ ProviderConfig = parse_parameter(QueryListTmp,#provider_config{protocol=Scheme,host=Host,port = Port}),
+ lager:debug("parse provider info string ~p,result: ~p",[ProviderStr,ProviderConfig]),
+ {ok,ProviderConfig};
+ {error,R1} ->
+ lager:debug("parse provider error string ~p, error ~p",[ProviderStr,R1]),
+ {error,R1}
+ end.
+%% PrivoderInfo =list_to_binary(http_uri:decode(binary_to_list(PrivoderStr))),
+%% [{ProtocolEndPos,3},{HostEndPos,1},{InterfaceEndPos,1} ] = binary:matches(PrivoderInfo,[<<"://">>,<<"/">>,<<"?">>],[]),
+%% HostLength=HostEndPos - ProtocolEndPos-3,
+%% InterfaceLenth=InterfaceEndPos-HostEndPos-1,
+%% << Protocol:5/binary,_:3/binary,Host:HostLength/binary,_:1/binary,Interface:InterfaceLenth/binary,_:1/binary,Parameter/binary>> = PrivoderInfo,
+%% [HostName,Port]=binary:split(Host,<<":">>),
+%% ParameterList = binary:split(Parameter,<<"&">>),
+
+%% io:format(user,"protocol end Pos ~p~n protocol:~p~n Host:~p~n Interface:~p~n",[ProtocolEndPos,Protocol,Host,Interface]),
+
+parse_parameter([],Config)->
+ Config;
+parse_parameter([Item|Rest],Config)->
+ case string:tokens(Item,"=") of
+ KeyPair when length(KeyPair) ==2 ->
+ [Key,Value] = KeyPair,
+ ConfigNew = parse_parameter(Key,Value,Config),
+ parse_parameter(Rest,ConfigNew);
+ KeyPair2 ->
+ lager:error("parse parameter error, keypair ~p",[KeyPair2]),
+ parse_parameter(Rest,Config)
+ end.
+parse_parameter("anyhost",Value,Config)->
+ Config#provider_config{anyhost = list_to_atom(Value)};
+parse_parameter("application",Value,Config)->
+ Config#provider_config{application = list_to_binary(Value)};
+parse_parameter("dubbo",Value,Config)->
+ Config#provider_config{dubbo = list_to_binary(Value)};
+parse_parameter("executes",Value,Config)->
+ Config#provider_config{executes = list_to_integer(Value)};
+parse_parameter("interface",Value,Config)->
+ Config#provider_config{interface = list_to_binary(Value)};
+parse_parameter("methods",Value,Config)->
+ MethodList= string:tokens(Value,","),
+ MethodList2 = [list_to_binary(Item) || Item <- MethodList],
+ Config#provider_config{methods = MethodList2};
+parse_parameter("side",Value,Config)->
+ Config#provider_config{side = list_to_binary(Value)};
+parse_parameter("interface",Value,Config)->
+ Config#provider_config{interface = list_to_binary(Value)};
+parse_parameter(_,_,Config)->
+ Config.
+
+gen_provider_info(ProviderConfig)->
+ Parameter=gen_provider_parameter(ProviderConfig),
+ Info = io_lib:format("dubbo://~s:~p/~s?~s",[
+ ProviderConfig#provider_config.host,
+ ProviderConfig#provider_config.port,
+ ProviderConfig#provider_config.interface,
+ Parameter
+ ]),
+ list_to_binary(http_uri:encode(Info)).
+
+gen_provider_parameter(Providerconfig) ->
+ Method= [binary_to_list(Item) || Item <- Providerconfig#provider_config.methods],
+ Method2= list_to_binary(string:join(Method,",")),
+ List=[
+ {<<"interface">>,Providerconfig#provider_config.interface},
+ {<<"application">>,Providerconfig#provider_config.application},
+ {<<"anyhost">>, <<"true">>},
+ {<<"dubbo">>,Providerconfig#provider_config.dubbo},
+ {<<"executes">>,integer_to_binary(Providerconfig#provider_config.executes)},
+ {<<"methods">>,Method2},
+ {<<"side">>,Providerconfig#provider_config.side},
+ {<<"timestamp">>,integer_to_binary(time_util:timestamp_ms())}
+ ],
+ List2 = [io_lib:format("~ts=~ts",[Key,Value]) || {Key,Value} <- List],
+ lists:flatten(string:join(List2,"&")).
\ No newline at end of file
diff --git a/src/dubbo_provider_protocol.erl b/src/dubbo_provider_protocol.erl
new file mode 100644
index 0000000..ad6074d
--- /dev/null
+++ b/src/dubbo_provider_protocol.erl
@@ -0,0 +1,200 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 20. Mar 2018 7:19 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_provider_protocol).
+-author("dlive").
+
+-behaviour(gen_server).
+-behaviour(ranch_protocol).
+-include("dubboerl.hrl").
+-include("dubbo.hrl").
+
+
+%% API
+-export([start_link/4,register_impl_provider/3, select_impl_provider/1]).
+
+%% gen_server callbacks
+-export([init/1,
+ handle_call/3,
+ handle_cast/2,
+ handle_info/2,
+ terminate/2,
+ code_change/3]).
+
+-define(SERVER, ?MODULE).
+
+-define(TIMEOUT, 5000).
+
+-record(heartbeat,{last_write=0,last_read=0,timeout=50000,max_timeout=9000}).
+
+-record(state, {transport,provider_config,socket =undefined,
+ heartbeat=#heartbeat{},
+ recv_buffer= <<>> %%从客户端接收的数据
+}).
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+
+start_link(Ref, Socket, Transport, Opts) ->
+ {ok, proc_lib:spawn_link(?MODULE, init, [{Ref, Socket, Transport, Opts}])}.
+
+%% gen_server.
+
+%% This function is never called. We only define it so that
+%% we can use the -behaviour(gen_server) attribute.
+%init([]) -> {ok, undefined}.
+
+init({Ref, Socket, Transport, _Opts = []}) ->
+ lager:info("provider connected"),
+ ok = ranch:accept_ack(Ref),
+ ok = Transport:setopts(Socket, [{active, once}]),
+ gen_server:enter_loop(?MODULE, [],
+ #state{socket=Socket, transport=Transport},
+ ?TIMEOUT).
+
+handle_info({tcp,_Port,Data}, #state{recv_buffer = RecvBuffer,socket=Socket, transport=Transport} = State) ->
+ Transport:setopts(Socket, [{active, once}]),
+ NowBuffer = << RecvBuffer/binary,Data/binary >>,
+
+ {ok,NextBuffer,NewState} = case check_recv_data(NowBuffer,State) of
+ {next_buffer,<<>>,State2} ->
+ {ok,<<>>,State2};
+ {next_buffer,NextBuffer2,State3}->
+ lager:debug("[INFO] recv one data state wait next_buffer"),
+ {ok,NextBuffer2,State3}
+ end,
+%% HeartbeatInfo =update_heartbeat(write,NewState#state.heartbeat),
+ {noreply, NewState#state{recv_buffer = NextBuffer}};
+handle_info({tcp_closed,Port},State)->
+%% NewState=reconnect(State),
+ {noreply, State};
+%%handle_info({timeout, _TimerRef, {reconnect}},State)->
+%% NewState=reconnect(State),
+%% {noreply, NewState};
+
+handle_info({tcp_closed, _Socket}, State) ->
+ {stop, normal, State};
+handle_info({tcp_error, _, Reason}, State) ->
+ {stop, Reason, State};
+handle_info(timeout, State) ->
+ {stop, normal, State};
+handle_info(_Info, State) ->
+ {stop, normal, State}.
+
+handle_call(_Request, _From, State) ->
+ {reply, ok, State}.
+
+handle_cast({send_response,Data}, #state{socket = Socket} = State) ->
+ case gen_tcp:send(Socket,Data) of
+ ok ->
+ ok;
+ Other ->
+ lager:warning("response error ~p",[Other])
+ end,
+ {noreply, State};
+handle_cast(_Msg, State) ->
+ {noreply, State}.
+
+terminate(_Reason, _State) ->
+ ok.
+
+code_change(_OldVsn, State, _Extra) ->
+ {ok, State}.
+
+
+register_impl_provider(Interface,ImplModuleName,ModuleName)->
+ ets:insert(?PROVIDER_IMPL_TABLE,{Interface,ImplModuleName,ModuleName}),
+ ok.
+
+-spec select_impl_provider(Interface::binary()) ->{ok,binary()} | {error,term()}.
+select_impl_provider(Interface) ->
+ case ets:lookup(?PROVIDER_IMPL_TABLE,Interface) of
+ []->
+ {error,no_provider};
+ [{Interface,ImplModuleName,ModuleName}] ->
+ {ok,ImplModuleName}
+ end.
+
+
+
+%%%=================================================================
+%%% 接收数据处理
+%%%=================================================================
+-spec check_recv_data(Data::binary(),State::#state{})->{ready,ReadyData::binary()} | {ready,ReadyData::binary(),NextBuffer::binary()}.
+check_recv_data(<<?DUBBO_MEGIC_HIGH,?DUBBO_MEGIC_LOW,Rest/binary>> = Data,State) when byte_size(Rest)<14 ->
+ {next_buffer,Data,State};
+check_recv_data(<<?DUBBO_MEGIC_HIGH,?DUBBO_MEGIC_LOW,_OtherFlag:80,DataLen:32,Rest/binary>> = Data,State) ->
+ RestSize = byte_size(Rest),
+ if
+ DataLen==RestSize ->
+ {ok,State2} = process_data(Data,State),
+ {next_buffer,<<>>,State2};
+ DataLen>RestSize ->
+ lager:warning("need wait next buffer data ~p",[Data]),
+ {next_buffer,Data,State};
+ DataLen<RestSize ->
+ <<ReadyData:DataLen/binary,NextBuffer/binary>> = Rest,
+ OneData = <<?DUBBO_MEGIC_HIGH:8,?DUBBO_MEGIC_LOW:8,_OtherFlag:80,DataLen:32,ReadyData/binary>>,
+ {ok,State3} = process_data(OneData,State),
+ lager:warning("recevi more data ~w ",[NextBuffer]),
+ check_recv_data(NextBuffer,State3)
+ end;
+check_recv_data(<<Error/integer,Data/binary>>,State)->
+ lager:error("recv bad header data,Begin Byte:~p",[Error]),
+ check_recv_data(Data,State);
+check_recv_data(<<>>,State)->
+ {next_buffer,<<>>,State}.
+
+
+process_data(Data,State)->
+ <<Header:16/binary,RestData/binary>> = Data,
+ case de_codec:decode_header(Header) of
+ {ok,request,RequestInfo}->
+ {ok,Req} = de_codec:decode_request(RequestInfo,RestData),
+ lager:info("get one request mid ~p, is_event ~p",[Req#dubbo_request.mid,Req#dubbo_request.is_event]),
+ {ok,State2} = process_request(Req#dubbo_request.is_event,Req,State),
+ {ok,State2};
+ {ok,response,ResponseInfo}->
+ {ok,Res} = de_codec:decode_response(ResponseInfo,RestData),
+ lager:info("get one response mid ~p, is_event ~p state ~p",[Res#dubbo_response.mid,Res#dubbo_response.is_event,Res#dubbo_response.state]),
+ {ok,State3} =process_response(Res#dubbo_response.is_event,Res,State),
+ {ok,State3};
+ {error,Type,RelData}->
+ lager:error("process_data error type ~p RelData ~p",[Type,RelData]),
+ {ok,State}
+ end.
+
+
+%% @doc process event
+-spec process_response(IsEvent::boolean(),#dubbo_response{},#state{})->ok.
+process_response(true,Response,State)->
+
+ {ok,State};
+
+process_response(false,Response,State)->
+%% case get_earse_request_info(Response#dubbo_response.mid) of
+%% undefined->
+%% lager:error("dubbo response can't find request data,response ~p",[Response]);
+%% {SourcePid,Ref,Request} ->
+%% lager:debug("will cast mid ~p to source process SourcePid ~p",[Response#dubbo_response.mid,SourcePid]),
+%% RpcContent=[],
+%% ResponseData = de_type_transfer:response_to_native(Response),
+%% gen_server:cast(SourcePid,{msg_back,Ref,ResponseData,RpcContent})
+%% end,
+ {ok,State}.
+
+process_request(true,Request,State)->
+%% {ok,NewState} = send_heartbeat_msg(Request#dubbo_request.mid,State),
+ lager:info("process request event ~p",[Request]),
+ {ok,State};
+process_request(false,Request,State)->
+ lager:info("process request ~p",[Request]),
+ dubbo_provider_worker:process_request(Request,self()),
+ {ok,State}.
\ No newline at end of file
diff --git a/src/dubbo_provider_worker.erl b/src/dubbo_provider_worker.erl
new file mode 100644
index 0000000..00d299e
--- /dev/null
+++ b/src/dubbo_provider_worker.erl
@@ -0,0 +1,198 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 11. Mar 2018 8:08 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_provider_worker).
+-author("dlive").
+
+-behaviour(gen_server).
+
+%% API
+-export([start_link/1,process_request/2]).
+
+%% gen_server callbacks
+-export([init/1,
+ handle_call/3,
+ handle_cast/2,
+ handle_info/2,
+ terminate/2,
+ code_change/3]).
+
+-define(SERVER, ?MODULE).
+-include("dubbo.hrl").
+-include("dubboerl.hrl").
+-include("dubbo_type.hrl").
+
+-record(heartbeat,{last_write=0,last_read=0,timeout=50000,max_timeout=9000}).
+-record(state, {provider_config,socket =undefined,
+ heartbeat=#heartbeat{},
+ recv_buffer= <<>> %%从客户端接收的数据
+}).
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @doc
+%% Starts the server
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(start_link(term()) ->
+ {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link(Args) ->
+ gen_server:start_link(?MODULE, Args, []).
+
+%%%===================================================================
+%%% gen_server callbacks
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Initializes the server
+%%
+%% @spec init(Args) -> {ok, State} |
+%% {ok, State, Timeout} |
+%% ignore |
+%% {stop, Reason}
+%% @end
+%%--------------------------------------------------------------------
+-spec(init(Args :: term()) ->
+ {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term()} | ignore).
+init(Args) ->
+ process_flag(trap_exit, true),
+ {ok, #state{}}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling call messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()},
+ State :: #state{}) ->
+ {reply, Reply :: term(), NewState :: #state{}} |
+ {reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} |
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_call(_Request, _From, State) ->
+ {reply, ok, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling cast messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_cast(Request :: term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_cast({request,Request,SourcePid},State)->
+%% #dubbo_request{mid=Mid} = Request,
+
+%% Data = #databaseOperateResponse{databaseOperateRsp = "ha-ha"},
+%% Data2 =#dubbo_rpc_invocation{parameters = [Data]},
+%% {ok,Content }= de_codec:encode_response(#dubbo_response{mid=Mid,is_event = false,data= Data2}),
+ {ok,Content} = invoker_implement(Request),
+ gen_server:cast(SourcePid,{send_response,Content}),
+
+ {noreply, State};
+handle_cast(_Request, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling all non call/cast messages
+%%
+%% @spec handle_info(Info, State) -> {noreply, State} |
+%% {noreply, State, Timeout} |
+%% {stop, Reason, State}
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_info(Info :: timeout() | term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+
+
+handle_info(_Info, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% This function is called by a gen_server when it is about to
+%% terminate. It should be the opposite of Module:init/1 and do any
+%% necessary cleaning up. When it returns, the gen_server terminates
+%% with Reason. The return value is ignored.
+%%
+%% @spec terminate(Reason, State) -> void()
+%% @end
+%%--------------------------------------------------------------------
+-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
+ State :: #state{}) -> term()).
+terminate(_Reason, _State) ->
+ ok.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Convert process state when code is changed
+%%
+%% @spec code_change(OldVsn, State, Extra) -> {ok, NewState}
+%% @end
+%%--------------------------------------------------------------------
+-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{},
+ Extra :: term()) ->
+ {ok, NewState :: #state{}} | {error, Reason :: term()}).
+code_change(_OldVsn, State, _Extra) ->
+ {ok, State}.
+
+
+process_request(Request,SourcePid)->
+ Worker = poolboy:checkout(?PROVIDER_WORKER),
+ try
+ gen_server:cast(Worker,{request,Request,SourcePid})
+ after
+ ok = poolboy:checkin(?PROVIDER_WORKER, Worker)
+ end.
+
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
+
+-spec invoker_implement(#dubbo_request{})-> {ok,response_content()}.
+invoker_implement(Request)->
+ #dubbo_rpc_invocation{className = Interface,methodName = MethodName,parameters = Parameters} = Request#dubbo_request.data,
+ case dubbo_provider_protocol:select_impl_provider(Interface) of
+ {ok,ImplModule}->
+ case apply(ImplModule,binary_to_atom(MethodName,latin1),Parameters) of
+ {error}->
+ ok;
+ #dubbo_rpc_invocation{}=ResultInvoca ->
+ #dubbo_request{mid = Mid} = Request,
+ {ok,Content }= de_codec:encode_response(#dubbo_response{mid=Mid,is_event = false,data= ResultInvoca}),
+ {ok,Content};
+ ResultObj->
+%% Data = #databaseOperateResponse{databaseOperateRsp = "ha-ha"},
+ #dubbo_request{mid = Mid} = Request,
+ Data2 =#dubbo_rpc_invocation{parameters = [ResultObj]},
+ {ok,Content }= de_codec:encode_response(#dubbo_response{mid=Mid,is_event = false,data= Data2}),
+ {ok,Content}
+ end;
+ {error,Reason} ->
+ {error,Reason}
+ end.
\ No newline at end of file
diff --git a/src/dubbo_provider_worker_sup.erl b/src/dubbo_provider_worker_sup.erl
new file mode 100644
index 0000000..0b5708f
--- /dev/null
+++ b/src/dubbo_provider_worker_sup.erl
@@ -0,0 +1,85 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 11. Mar 2018 8:04 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_provider_worker_sup).
+-author("dlive").
+
+-behaviour(supervisor).
+
+%% API
+-export([start_link/0]).
+
+%% Supervisor callbacks
+-export([init/1]).
+-define(SERVER, ?MODULE).
+
+%%%===================================================================
+%%% API functions
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @doc
+%% Starts the supervisor
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(start_link() ->
+ {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link() ->
+ supervisor:start_link({local, ?SERVER}, ?MODULE, []).
+
+%%%===================================================================
+%%% Supervisor callbacks
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Whenever a supervisor is started using supervisor:start_link/[2,3],
+%% this function is called by the new process to find out about
+%% restart strategy, maximum restart frequency and child
+%% specifications.
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(init(Args :: term()) ->
+ {ok, {SupFlags :: {RestartStrategy :: supervisor:strategy(),
+ MaxR :: non_neg_integer(), MaxT :: non_neg_integer()},
+ [ChildSpec :: supervisor:child_spec()]
+ }} |
+ ignore |
+ {error, Reason :: term()}).
+init([]) ->
+ RestartStrategy = one_for_one,
+ MaxRestarts = 1000,
+ MaxSecondsBetweenRestarts = 3600,
+
+ SupFlags = {RestartStrategy, MaxRestarts, MaxSecondsBetweenRestarts},
+
+ Restart = permanent,
+ Shutdown = 2000,
+ Type = worker,
+
+ AChild = {'AName', {'AModule', start_link, []},
+ Restart, Shutdown, Type, ['AModule']},
+
+ PoolArgs = [{name, {local, provider_worker}},
+ {worker_module, dubbo_provider_worker},
+ {size, 5},
+ {max_overflow, 100}
+ ],
+ WorkerPool = poolboy:child_spec(provider_worker, PoolArgs, []),
+ {ok, {SupFlags, [WorkerPool]}}.
+
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
+%%start_child(InterfaceList)->
+%% ChildSpec = {dubbo_provider_server,{dubbo_provider_server,start_link,[InterfaceList]},permanent,2000,worker},
+%% supervisor:start_child(?SERVER,ChildSpec),
+%% ok.
\ No newline at end of file
diff --git a/src/dubbo_serializa_fastjson.erl b/src/dubbo_serializa_fastjson.erl
new file mode 100644
index 0000000..819a118
--- /dev/null
+++ b/src/dubbo_serializa_fastjson.erl
@@ -0,0 +1,295 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 11. May 2018 10:07 AM
+%%%-------------------------------------------------------------------
+-module(dubbo_serializa_fastjson).
+-author("dlive").
+
+-include("dubbo.hrl").
+%% API
+-export([encode_request_data/1,decode_response/2,decode_request/2]).
+
+-export([decode_header/1]).
+-export([decode_request/2]).
+
+encode_request_data(Request)->
+ DataType =case Request#dubbo_request.is_event of
+ false->
+ case Request#dubbo_request.data of
+ #dubbo_rpc_invocation{} ->
+ dubbo_rpc_invocation;
+ _ ->
+ unknow
+ end;
+ true->
+ dubbo_event
+ end,
+ {ok,Bin} = encode_request_data(DataType,Request,Request#dubbo_request.data,[]),
+ {ok,Bin}.
+
+
+encode_request_data(dubbo_rpc_invocation,Request,Data,State) ->
+%% METHOD_NAME = Data#dubbo_rpc_invocation.methodName,
+%% METHOD_ARGS_TYPES = Data#dubbo_rpc_invocation.parameterDesc,
+ RequestList = [
+%% jiffy:encode(?DUBBO_VERSION,[]),
+ string_encode(?DUBBO_VERSION),
+ ?LINE_SEPERATOR,
+%% jiffy:encode(Data#dubbo_rpc_invocation.className,[]),
+ string_encode(Data#dubbo_rpc_invocation.className),
+ ?LINE_SEPERATOR,
+%% jiffy:encode(Data#dubbo_rpc_invocation.classVersion,[]),
+ string_encode(Data#dubbo_rpc_invocation.classVersion),
+ ?LINE_SEPERATOR,
+%% jiffy:encode(Data#dubbo_rpc_invocation.methodName,[]),
+ string_encode(Data#dubbo_rpc_invocation.methodName),
+ ?LINE_SEPERATOR,
+%% jiffy:encode(Data#dubbo_rpc_invocation.parameterDesc,[]),
+ string_encode(Data#dubbo_rpc_invocation.parameterDesc),
+ ?LINE_SEPERATOR
+%%
+%% hessianEncode:encode(?DUBBO_VERSION, State), %% dubbo version
+%% hessianEncode:encode(Data#dubbo_rpc_invocation.className, State),
+%% hessianEncode:encode(Data#dubbo_rpc_invocation.classVersion, State),
+%% hessianEncode:encode(METHOD_NAME, State),
+%% hessianEncode:encode(METHOD_ARGS_TYPES, State)
+ ],
+ {ArgsBin,_} = encode_arguments(Data,State),
+%% AttachDict = dict:from_list(Data#dubbo_rpc_invocation.attachments),
+%% AttachMaps = #map{dict = AttachDict },
+%% AttachBinay = hessianEncode:encode(AttachMaps, State2),
+ AttachBinay = jiffy:encode({Data#dubbo_rpc_invocation.attachments},[]),
+ RequestData = erlang:iolist_to_binary(RequestList ++ [ArgsBin,AttachBinay,?LINE_SEPERATOR]),
+ {ok,RequestData};
+encode_request_data(dubbo_event,Request,Data,State) ->
+ %% @todo 确认该数据类型
+ Bin = jiffy:encode(Data),
+%% Bin = hessianEncode:encode(Data,State),
+ {ok,Bin}.
+
+
+-spec encode_response(#dubbo_response{})-> {ok,term()}.
+encode_response(Response)->
+ {ok,ResponseData} = encode_response_data(Response),
+ Size = byte_size(ResponseData),
+ Header = encode_response_header(Response,Size,?RESPONSE_STATE_OK),
+ ResponseContent = <<Header/binary,ResponseData/binary>>,
+ {ok, ResponseContent}.
+
+encode_response_data(Response)->
+ State=type_encoding:init(),
+ DataType =case Response#dubbo_response.is_event of
+ true->
+ dubbo_event;
+ false->
+ case Response#dubbo_response.data of
+ #dubbo_rpc_invocation{} ->
+ dubbo_rpc_invocation;
+ _ ->
+ unknow
+ end
+ end,
+ {ok,Bin} = encode_response_data(DataType,Response,Response#dubbo_response.data,State),
+ {ok,Bin}.
+encode_response_data(dubbo_event,Response,Data,State) ->
+ Bin = hessianEncode:encode(Data,State),
+ {ok,Bin};
+encode_response_data(dubbo_rpc_invocation,Response,Data,State) ->
+ Result = case Data of
+ null ->
+ [
+ hessianEncode:encode(?RESPONSE_NULL_VALUE, State)
+ ];
+ _ ->
+ {ArgsBin,_State2} = encode_arguments(Data,State),
+ [
+ hessianEncode:encode(?RESPONSE_VALUE, State),
+ ArgsBin
+ ]
+ end,
+ ResponseData = erlang:iolist_to_binary(Result),
+ {ok,ResponseData}.
+
+encode_response_header(Response,DataLen, ResponseState)->
+ Header2= Response#dubbo_response.serialize_type,
+ Header21=case Response#dubbo_response.is_twoway of
+ true -> Header2 bor 64;
+ false-> Header2
+ end,
+ Header22=case Response#dubbo_response.is_event of
+ true -> Header21 bor 32;
+ false-> Header21
+ end,
+ RequestId = Response#dubbo_response.mid,
+ Header = << ?DUBBO_MEGIC:16,Header22:8, ResponseState:8,RequestId:64,DataLen:32>>,
+ Header.
+encode_arguments(Data,State)->
+ {Bin} = lists:foldl(
+ fun(X,{BinTmp})->
+ ArgsBin = string_encode(X),
+ {<<BinTmp/binary,ArgsBin/binary ,?LINE_SEPERATOR/binary>>}
+ end,
+ {<<>>},Data#dubbo_rpc_invocation.parameters),
+ {Bin,State}.
+
+-spec decode_header(binary())-> {State::ok|error,Type::request|response,Data::#dubbo_response{}|#dubbo_request{}}.
+decode_header(Header)->
+ <<?DUBBO_MEGIC_HIGH,?DUBBO_MEGIC_LOW,Flag:8,State:8,Mid:64,DataLen:32>> = Header,
+ if
+ (Flag band 16#80) == 0 ->
+ {DecodeState,Res} = decode_header(response,Flag,State,Mid,DataLen),
+ {DecodeState,response,Res};
+ true ->
+ {DecodeState,Req} = decode_header(request,Flag,State,Mid,DataLen),
+ {DecodeState,request,Req}
+ end.
+decode_header(request,Flag,State,Mid,DataLen)->
+ SerializeType = Flag band 16#1f,
+ IsTwoWay = if
+ (Flag band 16#40) /=0 -> true;
+ true -> false
+ end,
+ IsEvent = if
+ (Flag band 16#20) /=0 -> true;
+ true -> false
+ end,
+ Req = #dubbo_request{
+ is_event = IsEvent,
+ is_twoway = IsTwoWay,
+ mid = Mid,
+ mversion = <<"2.0.0">>,
+ serialize_type = SerializeType
+ },
+ {ok,Req};
+decode_header(response,Flag,State,Mid,DataLen)->
+ SerializeType = Flag band 16#1f,
+ IsEvent = if
+ (Flag band 16#20) /= 0 -> true;
+ true -> false
+ end,
+ Res = #dubbo_response{is_event = IsEvent,
+ serialize_type = SerializeType,
+ state = State,
+ mid = Mid
+ },
+ {ok,Res}.
+
+-spec decode_response(#dubbo_response{},binary())-> {ok,#dubbo_response{}}.
+decode_response(Res,Data)->
+ if
+ Res#dubbo_response.is_event == true ->
+ decode_response(dubbo_event,Res,Data);
+ true ->
+ decode_response(dubbo_rpc_invocation,Res,Data)
+ end.
+decode_response(dubbo_rpc_invocation,Res,Data)->
+ DataList = binary:split(Data,<<"\n">>),
+ [TypeBin | DataList1] = DataList,
+%% {Rest,Type,State} = hessianDecode2:decode(Data,hessianDecode2:init()),
+ Type = jiffy:decode(TypeBin),
+
+ case Type of
+ ?RESPONSE_VALUE ->
+%% {_,Object,DecodeState} = hessianDecode2:decode(Rest,State),
+ [Value | _] = DataList1,
+ Object = jiffy:decode(Value),
+ {ok,Res#dubbo_response{data = Object}};
+ ?RESPONSE_NULL_VALUE ->
+ {ok,Res#dubbo_response{data = null}};
+ ?RESPONSE_WITH_EXCEPTION ->
+ [ExceptionValue | _] = DataList1,
+ ExceptionObject = jiffy:decode(ExceptionValue),
+%% lager:warning("decode unkonw type ~p ~p",[Type,Rest]),
+%% {Rest2,Object2,DecodeState2} = hessianDecode2:decode(Rest,State),
+%% lager:warning("decode unkonw type2 ~p ~p",[Object2,Rest2]),
+ {ok,Res#dubbo_response{data = ExceptionObject}};
+ Other ->
+ lager:error("server response unkonw info ~p",[Other]),
+ {ok,Res#dubbo_response{data = <<"server pool exhausted">>}}
+
+ end;
+decode_response(dubbo_event,Res,Data)->
+%% {_Rest,undefined,_NewState} = hessianDecode2:decode(Data,hessianDecode2:init()),
+ {ok,Res#dubbo_response{data = null}}.
+
+-spec decode_request(#dubbo_request{},binary())-> {ok,#dubbo_request{}}.
+decode_request(Req,Data)->
+ if
+ Req#dubbo_request.is_event == true ->
+ decode_request(dubbo_event,Req,Data);
+ true ->
+ decode_request(dubbo_rpc_invocation,Req,Data)
+ end.
+
+decode_request(dubbo_rpc_invocation,Req,Data)->
+ {ResultList,NewState,RestData} = decode_request_body(Data,hessianDecode2:init(),[dubbo,path,version,method_name,desc_and_args,attachments]),
+ [DubboVersion,Path,Version,MethodName,Desc,ArgsObj,Attachments]=ResultList,
+ RpcData = #dubbo_rpc_invocation{className = Path,classVersion = Version,methodName = MethodName,parameterDesc = Data,parameters = ArgsObj,attachments = Attachments},
+ Req2 = Req#dubbo_request{data = RpcData},
+ {ok,Req2};
+%% {Rest,Dubbo,State} = hessianDecode2:decode(Data,hessianDecode2:init()),
+%% {Rest1,ClassName,State1} = hessianDecode2:decode(Data,State),
+%% {Rest2,ClassName,State2} = hessianDecode2:decode(Rest1,State1),
+%% case Type of
+%% 1 ->
+%% {_,Object,DecodeState} = hessianDecode2:decode(Rest,State),
+%% {ok,Req#dubbo_request{data = Object,decode_state = DecodeState}};
+%% 2 ->
+%% {ok,Req#dubbo_request{data = null,decode_state = State}};
+%% _->
+%% lager:warning("decode unkonw type ~p ~p",[Type,Rest]),
+%% {Rest2,Object2,DecodeState2} = hessianDecode2:decode(Rest,State),
+%% lager:warning("decode unkonw type2 ~p ~p",[Object2,Rest2]),
+%% {ok,Req#dubbo_request{data = Object2,decode_state = DecodeState2}}
+%% end;
+decode_request(dubbo_event,Req,Data)->
+%% DataList = binary:split(Data,<<"\n">>),
+ lager:debug("dubbo_event datalist ~w",[Data]),
+ Result = jiffy:decode(Data,[]),
+%% {_Rest,undefined,_NewState} = hessianDecode2:decode(Data,hessianDecode2:init()),
+ {ok,Req#dubbo_request{data = Result}}.
+
+decode_request_body(Data,State,List)->
+ {ResultList,NewState,RestData} = decode_request_body(List,Data,State,[]),
+ {lists:reverse(ResultList),NewState,RestData}.
+decode_request_body([ParseType|List],Data,State,ResultList)
+ when ParseType==dubbo;ParseType==path;ParseType==version;ParseType==method_name ->
+ {Rest,Result,NewState } = hessianDecode2:decode(Data,State),
+ decode_request_body(List,Rest,NewState, [Result] ++ ResultList);
+decode_request_body([desc_and_args| List],Data,State,ResultList)->
+ {Rest,ParameterDesc,State1 } = hessianDecode2:decode(Data,State),
+ if
+ size(ParameterDesc) == 0 ->
+ decode_request_body(List,Rest,State1, [ [],[] ]++ ResultList);
+ true ->
+ ParameterDescArray = binary:split(ParameterDesc,<<";">>),
+ {ArgsObjList,NewState,RestData} = decode_request_body_args(ParameterDescArray,Rest,State1,[]),
+ decode_request_body(List,RestData,NewState, [ArgsObjList,ParameterDesc]++ ResultList)
+ end;
+decode_request_body([attachments|List],Data,State,ResultList)->
+ {Rest,Attachments,State1 } = hessianDecode2:decode(Data,State),
+ AttachmentsList = dict:to_list(Attachments#map.dict),
+ decode_request_body(List,Rest,State1,[AttachmentsList] ++ ResultList);
+decode_request_body([_Type1|List],Data,State,ResultList)->
+ lager:warning("decode_request_body unknow type"),
+ decode_request_body(List,Data,State, ResultList);
+decode_request_body([],Data,State,ResultList)->
+ {ResultList,State,Data}.
+
+decode_request_body_args([],Data,State,ArgsObjList)->
+ {ArgsObjList,State,Data};
+decode_request_body_args([ArgsType|RestList],Data,State,ArgsObjList) when ArgsType== <<>> ->
+ decode_request_body_args(RestList,Data,State,ArgsObjList);
+decode_request_body_args([_ArgsType|RestList],Data,State,ArgsObjList) ->
+ {Rest,ArgObj,NewState } = hessianDecode2:decode(Data,State),
+ ArgObj2 = de_type_transfer:classobj_to_native(ArgObj,NewState),
+ decode_request_body_args(RestList,Rest,NewState,ArgsObjList++[ArgObj2]).
+
+string_encode(Data) when is_binary(Data)->
+ << <<"\"">>/binary,Data/binary,<<"\"">>/binary >>;
+string_encode(Data)->
+ jiffy:encode(Data).
diff --git a/src/dubbo_serializa_hession.erl b/src/dubbo_serializa_hession.erl
new file mode 100644
index 0000000..1e622fb
--- /dev/null
+++ b/src/dubbo_serializa_hession.erl
@@ -0,0 +1,246 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 11. May 2018 4:12 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_serializa_hession).
+-author("dlive").
+
+-include("dubbo.hrl").
+%% API
+-export([decode_header/1]).
+-export([decode_response/2]).
+-export([decode_request/2]).
+
+
+encode_request_data(dubbo_event,Request,Data,State) ->
+ Bin = hessianEncode:encode(Data,State),
+ {ok,Bin};
+encode_request_data(dubbo_rpc_invocation,Request,Data,State) ->
+ METHOD_NAME = Data#dubbo_rpc_invocation.methodName,
+ METHOD_ARGS_TYPES = Data#dubbo_rpc_invocation.parameterDesc,
+ RequestList = [
+ hessianEncode:encode(?DUBBO_VERSION, State), %% dubbo version
+ hessianEncode:encode(Data#dubbo_rpc_invocation.className, State),
+ hessianEncode:encode(Data#dubbo_rpc_invocation.classVersion, State),
+ hessianEncode:encode(METHOD_NAME, State),
+ hessianEncode:encode(METHOD_ARGS_TYPES, State)
+ ],
+ {ArgsBin,State2} = encode_arguments(Data,State),
+ AttachDict = dict:from_list(Data#dubbo_rpc_invocation.attachments),
+ AttachMaps = #map{dict = AttachDict },
+ {AttachBinay,_} = hessianEncode:encode(AttachMaps, State2),
+ RequestData = erlang:iolist_to_binary(RequestList ++ [ArgsBin,AttachBinay]),
+ {ok,RequestData}.
+
+-spec encode_response(#dubbo_response{})-> {ok,term()}.
+encode_response(Response)->
+ {ok,ResponseData} = encode_response_data(Response),
+ Size = byte_size(ResponseData),
+ Header = encode_response_header(Response,Size,?RESPONSE_STATE_OK),
+ ResponseContent = <<Header/binary,ResponseData/binary>>,
+ {ok, ResponseContent}.
+
+encode_response_data(Response)->
+ State=type_encoding:init(),
+ DataType =case Response#dubbo_response.is_event of
+ true->
+ dubbo_event;
+ false->
+ case Response#dubbo_response.data of
+ #dubbo_rpc_invocation{} ->
+ dubbo_rpc_invocation;
+ _ ->
+ unknow
+ end
+ end,
+ {ok,Bin} = encode_response_data(DataType,Response,Response#dubbo_response.data,State),
+ {ok,Bin}.
+encode_response_data(dubbo_event,Response,Data,State) ->
+ Bin = hessianEncode:encode(Data,State),
+ {ok,Bin};
+encode_response_data(dubbo_rpc_invocation,Response,Data,State) ->
+ Result = case Data of
+ null ->
+ [
+ hessianEncode:encode(?RESPONSE_NULL_VALUE, State)
+ ];
+ _ ->
+ {ArgsBin,_State2} = encode_arguments(Data,State),
+ [
+ hessianEncode:encode(?RESPONSE_VALUE, State),
+ ArgsBin
+ ]
+ end,
+ ResponseData = erlang:iolist_to_binary(Result),
+ {ok,ResponseData}.
+
+encode_response_header(Response,DataLen, ResponseState)->
+ Header2= Response#dubbo_response.serialize_type,
+ Header21=case Response#dubbo_response.is_twoway of
+ true -> Header2 bor 64;
+ false-> Header2
+ end,
+ Header22=case Response#dubbo_response.is_event of
+ true -> Header21 bor 32;
+ false-> Header21
+ end,
+ RequestId = Response#dubbo_response.mid,
+ Header = << ?DUBBO_MEGIC:16,Header22:8, ResponseState:8,RequestId:64,DataLen:32>>,
+ Header.
+encode_arguments(Data,State)->
+ {StateNew} = lists:foldl(fun(X,{StateTmp})->
+ StateTmpNew = type_encoding:enlist(X,StateTmp),
+ {StateTmpNew} end,
+ {State},Data#dubbo_rpc_invocation.parameterTypes),
+ {Bin,State2} = lists:foldl(fun(X,{BinTmp,StateTmp2})->
+ case hessianEncode:encode(X, StateTmp2) of
+ {ArgsBin,StateTmpNew} ->
+ {<<BinTmp/binary,ArgsBin/binary>>, StateTmpNew};
+ ArgsBin2 ->
+ {<<BinTmp/binary,ArgsBin2/binary>>, StateTmp2}
+ end end,
+ {<<>>,StateNew},Data#dubbo_rpc_invocation.parameters),
+ {Bin,State2}.
+
+-spec decode_header(binary())-> {State::ok|error,Type::request|response,Data::#dubbo_response{}|#dubbo_request{}}.
+decode_header(Header)->
+ <<?DUBBO_MEGIC_HIGH,?DUBBO_MEGIC_LOW,Flag:8,State:8,Mid:64,DataLen:32>> = Header,
+ if
+ (Flag band 16#80) == 0 ->
+ {DecodeState,Res} = decode_header(response,Flag,State,Mid,DataLen),
+ {DecodeState,response,Res};
+ true ->
+ {DecodeState,Req} = decode_header(request,Flag,State,Mid,DataLen),
+ {DecodeState,request,Req}
+ end.
+decode_header(request,Flag,State,Mid,DataLen)->
+ SerializeType = Flag band 16#1f,
+ IsTwoWay = if
+ (Flag band 16#40) /=0 -> true;
+ true -> false
+ end,
+ IsEvent = if
+ (Flag band 16#20) /=0 -> true;
+ true -> false
+ end,
+ Req = #dubbo_request{
+ is_event = IsEvent,
+ is_twoway = IsTwoWay,
+ mid = Mid,
+ mversion = <<"2.0.0">>,
+ serialize_type = SerializeType
+ },
+ {ok,Req};
+decode_header(response,Flag,State,Mid,DataLen)->
+ SerializeType = Flag band 16#1f,
+ IsEvent = if
+ (Flag band 16#20) /= 0 -> true;
+ true -> false
+ end,
+ Res = #dubbo_response{is_event = IsEvent,
+ serialize_type = SerializeType,
+ state = State,
+ mid = Mid
+ },
+ {ok,Res}.
+
+-spec decode_response(#dubbo_response{},binary())-> {ok,#dubbo_response{}}.
+decode_response(Res,Data)->
+ if
+ Res#dubbo_response.is_event == true ->
+ decode_response(dubbo_event,Res,Data);
+ true ->
+ decode_response(dubbo_rpc_invocation,Res,Data)
+ end.
+
+decode_response(dubbo_rpc_invocation,Res,Data)->
+ {Rest,Type,State} = hessianDecode2:decode(Data,hessianDecode2:init()),
+ case Type of
+ 1 ->
+ {_,Object,DecodeState} = hessianDecode2:decode(Rest,State),
+ {ok,Res#dubbo_response{data = Object,decode_state = DecodeState}};
+ 2 ->
+ {ok,Res#dubbo_response{data = null,decode_state = State}};
+ _->
+ lager:warning("decode unkonw type ~p ~p",[Type,Rest]),
+ {Rest2,Object2,DecodeState2} = hessianDecode2:decode(Rest,State),
+ lager:warning("decode unkonw type2 ~p ~p",[Object2,Rest2]),
+ {ok,Res#dubbo_response{data = Object2,decode_state = DecodeState2}}
+ end;
+decode_response(dubbo_event,Res,Data)->
+ {_Rest,undefined,_NewState} = hessianDecode2:decode(Data,hessianDecode2:init()),
+ {ok,Res#dubbo_response{data = undefined}}.
+
+-spec decode_request(#dubbo_request{},binary())-> {ok,#dubbo_request{}}.
+decode_request(Req,Data)->
+ if
+ Req#dubbo_request.is_event == true ->
+ decode_request(dubbo_event,Req,Data);
+ true ->
+ decode_request(dubbo_rpc_invocation,Req,Data)
+ end.
+
+decode_request(dubbo_rpc_invocation,Req,Data)->
+ {ResultList,NewState,RestData} = decode_request_body(Data,hessianDecode2:init(),[dubbo,path,version,method_name,desc_and_args,attachments]),
+ [DubboVersion,Path,Version,MethodName,Desc,ArgsObj,Attachments]=ResultList,
+ RpcData = #dubbo_rpc_invocation{className = Path,classVersion = Version,methodName = MethodName,parameterDesc = Data,parameters = ArgsObj,attachments = Attachments},
+ Req2 = Req#dubbo_request{data = RpcData},
+ {ok,Req2};
+%% {Rest,Dubbo,State} = hessianDecode2:decode(Data,hessianDecode2:init()),
+%% {Rest1,ClassName,State1} = hessianDecode2:decode(Data,State),
+%% {Rest2,ClassName,State2} = hessianDecode2:decode(Rest1,State1),
+%% case Type of
+%% 1 ->
+%% {_,Object,DecodeState} = hessianDecode2:decode(Rest,State),
+%% {ok,Req#dubbo_request{data = Object,decode_state = DecodeState}};
+%% 2 ->
+%% {ok,Req#dubbo_request{data = null,decode_state = State}};
+%% _->
+%% lager:warning("decode unkonw type ~p ~p",[Type,Rest]),
+%% {Rest2,Object2,DecodeState2} = hessianDecode2:decode(Rest,State),
+%% lager:warning("decode unkonw type2 ~p ~p",[Object2,Rest2]),
+%% {ok,Req#dubbo_request{data = Object2,decode_state = DecodeState2}}
+%% end;
+decode_request(dubbo_event,Req,Data)->
+ {_Rest,undefined,_NewState} = hessianDecode2:decode(Data,hessianDecode2:init()),
+ {ok,Req#dubbo_request{data = undefined}}.
+
+decode_request_body(Data,State,List)->
+ {ResultList,NewState,RestData} = decode_request_body(List,Data,State,[]),
+ {lists:reverse(ResultList),NewState,RestData}.
+decode_request_body([ParseType|List],Data,State,ResultList)
+ when ParseType==dubbo;ParseType==path;ParseType==version;ParseType==method_name ->
+ {Rest,Result,NewState } = hessianDecode2:decode(Data,State),
+ decode_request_body(List,Rest,NewState, [Result] ++ ResultList);
+decode_request_body([desc_and_args| List],Data,State,ResultList)->
+ {Rest,ParameterDesc,State1 } = hessianDecode2:decode(Data,State),
+ if
+ size(ParameterDesc) == 0 ->
+ decode_request_body(List,Rest,State1, [ [],[] ]++ ResultList);
+ true ->
+ ParameterDescArray = binary:split(ParameterDesc,<<";">>),
+ {ArgsObjList,NewState,RestData} = decode_request_body_args(ParameterDescArray,Rest,State1,[]),
+ decode_request_body(List,RestData,NewState, [ArgsObjList,ParameterDesc]++ ResultList)
+ end;
+decode_request_body([attachments|List],Data,State,ResultList)->
+ {Rest,Attachments,State1 } = hessianDecode2:decode(Data,State),
+ AttachmentsList = dict:to_list(Attachments#map.dict),
+ decode_request_body(List,Rest,State1,[AttachmentsList] ++ ResultList);
+decode_request_body([_Type1|List],Data,State,ResultList)->
+ lager:warning("decode_request_body unknow type"),
+ decode_request_body(List,Data,State, ResultList);
+decode_request_body([],Data,State,ResultList)->
+ {ResultList,State,Data}.
+
+decode_request_body_args([],Data,State,ArgsObjList)->
+ {ArgsObjList,State,Data};
+decode_request_body_args([ArgsType|RestList],Data,State,ArgsObjList) when ArgsType== <<>> ->
+ decode_request_body_args(RestList,Data,State,ArgsObjList);
+decode_request_body_args([_ArgsType|RestList],Data,State,ArgsObjList) ->
+ {Rest,ArgObj,NewState } = hessianDecode2:decode(Data,State),
+ ArgObj2 = de_type_transfer:classobj_to_native(ArgObj,NewState),
+ decode_request_body_args(RestList,Rest,NewState,ArgsObjList++[ArgObj2]).
\ No newline at end of file
diff --git a/src/dubbo_traffic_control.erl b/src/dubbo_traffic_control.erl
new file mode 100644
index 0000000..d7b6fcb
--- /dev/null
+++ b/src/dubbo_traffic_control.erl
@@ -0,0 +1,52 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 22. May 2018 1:58 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_traffic_control).
+-author("dlive").
+-include("dubboerl.hrl").
+%% API
+-export([init/0,check_goon/2,decr_count/1]).
+
+
+init()->
+ case ets:info(?TRAFFIC_CONTROL) of
+ undefined ->
+ io:format("init decoding TRAFFIC_CONTROL table pid ~p~n",[self()]),
+ ets:new(?TRAFFIC_CONTROL,[public,named_table, {write_concurrency, true}]); %% public
+ _ ->
+ ets:delete(?TRAFFIC_CONTROL),
+ ets:new(?TRAFFIC_CONTROL,[public,named_table, {write_concurrency, true}])
+ end,
+ ok.
+
+
+check_goon(Key,Max)->
+ try ets:update_counter(?TRAFFIC_CONTROL,Key,1) of
+ Value when Value > Max ->
+ ets:update_counter(?TRAFFIC_CONTROL,Key,-1),
+ full;
+ _V ->
+%% lager:debug("check traffic incr value ~p",[V]),
+ ok
+
+ catch
+ _T:_R->
+ ets:insert(?TRAFFIC_CONTROL,{Key,1}),
+ ok
+ end.
+
+decr_count(Key)->
+ try ets:update_counter(?TRAFFIC_CONTROL,Key,-1) of
+ _V ->
+%% lager:debug("check traffic decr value ~p",[V]),
+ ok
+ catch
+ _T:_R->
+ ets:insert(?TRAFFIC_CONTROL,{Key,0}),
+ ok
+ end.
\ No newline at end of file
diff --git a/src/dubbo_zookeeper.erl b/src/dubbo_zookeeper.erl
new file mode 100644
index 0000000..f0016a8
--- /dev/null
+++ b/src/dubbo_zookeeper.erl
@@ -0,0 +1,270 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 29. 十月 2016 上午9:56
+%%%-------------------------------------------------------------------
+-module(dubbo_zookeeper).
+-author("dlive").
+
+-behaviour(gen_server).
+
+-include("dubbo.hrl").
+%% API
+-export([start_link/0,register_consumer/1,register_consumer/2,gen_consumer_node_info/1,register_provider/1,provider_watcher/1]).
+
+%% gen_server callbacks
+-export([init/1,
+ handle_call/3,
+ handle_cast/2,
+ handle_info/2,
+ terminate/2,
+ code_change/3]).
+
+-define(SERVER, ?MODULE).
+
+-record(state, {zk_pid}).
+
+%%%===================================================================
+%%% API
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @doc
+%% Starts the server
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(start_link() ->
+ {ok, Pid :: pid()} | ignore | {error, Reason :: term()}).
+start_link() ->
+ gen_server:start_link({local, ?SERVER}, ?MODULE, [], []).
+
+%%%===================================================================
+%%% gen_server callbacks
+%%%===================================================================
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Initializes the server
+%%
+%% @spec init(Args) -> {ok, State} |
+%% {ok, State, Timeout} |
+%% ignore |
+%% {stop, Reason}
+%% @end
+%%--------------------------------------------------------------------
+-spec(init(Args :: term()) ->
+ {ok, State :: #state{}} | {ok, State :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term()} | ignore).
+init([]) ->
+ {ok,Pid} = connection(),
+ {ok, #state{zk_pid = Pid}}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling call messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_call(Request :: term(), From :: {pid(), Tag :: term()},
+ State :: #state{}) ->
+ {reply, Reply :: term(), NewState :: #state{}} |
+ {reply, Reply :: term(), NewState :: #state{}, timeout() | hibernate} |
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), Reply :: term(), NewState :: #state{}} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+
+handle_call({add_consumer,Consumer}, _From, State) ->
+ add_consumer(Consumer,State),
+ {reply, ok, State};
+handle_call({add_provider,Provider}, _From, State) ->
+ register_provider_path(Provider,State),
+ {reply, ok, State};
+handle_call(_Request, _From, State) ->
+ {reply, ok, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling cast messages
+%%
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_cast(Request :: term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_cast({provider_node_change,Interface,Path}, #state{zk_pid = Pid}=State) ->
+ get_provider_and_start(Pid,Interface,Path),
+ {noreply, State};
+handle_cast(_Request, State) ->
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Handling all non call/cast messages
+%%
+%% @spec handle_info(Info, State) -> {noreply, State} |
+%% {noreply, State, Timeout} |
+%% {stop, Reason, State}
+%% @end
+%%--------------------------------------------------------------------
+-spec(handle_info(Info :: timeout() | term(), State :: #state{}) ->
+ {noreply, NewState :: #state{}} |
+ {noreply, NewState :: #state{}, timeout() | hibernate} |
+ {stop, Reason :: term(), NewState :: #state{}}).
+handle_info(_Info, State) ->
+ lager:info("zk server recv msg:~p",[_Info]),
+ {noreply, State}.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% This function is called by a gen_server when it is about to
+%% terminate. It should be the opposite of Module:init/1 and do any
+%% necessary cleaning up. When it returns, the gen_server terminates
+%% with Reason. The return value is ignored.
+%%
+%% @spec terminate(Reason, State) -> void()
+%% @end
+%%--------------------------------------------------------------------
+-spec(terminate(Reason :: (normal | shutdown | {shutdown, term()} | term()),
+ State :: #state{}) -> term()).
+terminate(_Reason, _State) ->
+ ok.
+
+%%--------------------------------------------------------------------
+%% @private
+%% @doc
+%% Convert process state when code is changed
+%%
+%% @spec code_change(OldVsn, State, Extra) -> {ok, NewState}
+%% @end
+%%--------------------------------------------------------------------
+-spec(code_change(OldVsn :: term() | {down, term()}, State :: #state{},
+ Extra :: term()) ->
+ {ok, NewState :: #state{}} | {error, Reason :: term()}).
+code_change(_OldVsn, State, _Extra) ->
+ {ok, State}.
+
+
+register_consumer(Consumer) ->
+ gen_server:call(?SERVER,{add_consumer,Consumer}),
+ ok.
+register_consumer(Name,Option)->
+ Consumer=#consumer_config{interface = Name,methods = [<<"testa">>,<<"testb">>]},
+ register_consumer(Consumer),
+ ok.
+register_provider(Provider)->
+ gen_server:call(?SERVER,{add_provider,Provider}),
+ ok.
+
+%%%===================================================================
+%%% Internal functions
+%%%===================================================================
+
+connection()->
+ {ok,List} = application:get_env(dubboerl,zookeeper_list),
+ {ok, Pid} = erlzk:connect(List, 30000, [
+ {chroot, "/"},
+ {monitor, self()}]),
+ {ok,Pid}.
+
+add_consumer(Consumer,State)->
+ Pid= State#state.zk_pid,
+%% InterfacePath= << <<"/dubbo/">>/binary,Name/binary ,<<"consumers">>/binary >>,
+ ConsumerNode = gen_consumer_node_info(Consumer),
+ ConsumerNode2= list_to_binary(edoc_lib:escape_uri(binary_to_list(ConsumerNode))),
+ check_and_create_path(Pid,<<"">>,[{<<"dubbo">>,p},{Consumer#consumer_config.interface,p},{<<"consumers">>,p},{ConsumerNode2,e} ]),
+ get_provider_list(Consumer,State),
+ ok.
+register_provider_path(Provider,State)->
+ #state{zk_pid = Pid}=State,
+ ProviderNode = dubbo_node_config_util:gen_provider_info(Provider),
+ check_and_create_path(Pid,<<"">>,[{<<"dubbo">>,p},{Provider#provider_config.interface,p},{<<"providers">>,p},{ProviderNode,e}]),
+ ok.
+
+
+get_provider_list(Consumer,State)->
+ Pid= State#state.zk_pid,
+ InterfacePath= << <<"/dubbo/">>/binary,(Consumer#consumer_config.interface)/binary ,<<"/providers">>/binary >>,
+ get_provider_and_start(Pid,Consumer#consumer_config.interface,InterfacePath),
+ ok.
+get_provider_and_start(Pid,Interface,Path)->
+ case erlzk:get_children(Pid,Path,spawn(dubbo_zookeeper,provider_watcher,[Interface])) of
+ {ok,ChildList} ->
+ lager:debug("get provider list ~p",[ChildList]),
+ start_provider_process(Interface,ChildList),
+ ok;
+ {error,R1} ->
+ lager:debug("[add_consumer] get_provider_list error ~p ~p",[R1]),
+ ok
+ end.
+
+provider_watcher(Interface)->
+ receive
+ {node_children_changed,Path} ->
+ gen_server:cast(?SERVER,{provider_node_change,Interface,Path}),
+ lager:debug("provider_watcher get event ~p ~p",[node_children_changed,Path]);
+ {Event, Path} ->
+%% Path = "/a",
+%% Event = node_created
+ lager:debug("provider_watcher get event ~p ~p",[Event,Path])
+ end,
+ ok.
+
+
+create_path(Pid,Path,CreateType)->
+ case erlzk:create(Pid,Path,CreateType) of
+ {ok,ActualPath}->
+ lager:debug("[add_consumer] create zk path success ~p",[ActualPath]),
+ ok;
+ {error,R1}->
+ lager:debug("[add_consumer] create zk path error ~p ~p",[Path,R1])
+ end,
+ ok.
+check_and_create_path(_Pid,_RootPath,[]) ->
+ ok;
+check_and_create_path(Pid,RootPath,[{Item,CreateType}|Rst])->
+ CheckPath= << RootPath/binary,<<"/">>/binary,Item/binary >>,
+ case erlzk:exists(Pid,CheckPath) of
+ {ok,Stat} ->
+ check_and_create_path(Pid,CheckPath,Rst);
+ {error,no_node}->
+ lager:debug("[add_consumer] check_and_create_path unexist no_node ~p",[CheckPath]),
+ create_path(Pid,CheckPath,CreateType),
+ check_and_create_path(Pid,CheckPath,Rst);
+ {error,R1} ->
+ lager:debug("[add_consumer] check_and_create_path unexist ~p",[R1]),
+ check_and_create_path(Pid,CheckPath,Rst)
+ end.
+
+gen_consumer_node_info(Consumer)->
+ %% revision参数字段的作用是什么？ 暂时不添加
+ Methods=lists_util:join(Consumer#consumer_config.methods,<<",">>),
+ Value=io_lib:format(<<"consumer://~s/~s?application=~s&category=~s&check=~p&default.timeout=~p&dubbo=~s&interface=~s&methods=~s&side=~s×tamp=~p">>,
+ [de_common_fun:local_ip_v4_str(),
+ Consumer#consumer_config.interface,
+ Consumer#consumer_config.application,
+ Consumer#consumer_config.category,
+ Consumer#consumer_config.check,
+ Consumer#consumer_config.default_timeout,
+ Consumer#consumer_config.dubbo_version,
+ Consumer#consumer_config.interface,
+ Methods,
+ Consumer#consumer_config.side,
+ time_util:timestamp_ms()
+ ]),
+ list_to_binary(Value).
+
+%%dubbo_zookeeper:register_consumer(<<"com.ifcoder.abcd">>,[]).
+start_provider_process(Interface,ProviderList)->
+ dubbo_consumer_pool:start_consumer(Interface,ProviderList).
+
diff --git a/src/dubboerl.app.src b/src/dubboerl.app.src
new file mode 100644
index 0000000..4998bf0
--- /dev/null
+++ b/src/dubboerl.app.src
@@ -0,0 +1,16 @@
+{application, dubboerl,
+ [{description, "An OTP application"},
+ {vsn, "0.1.0"},
+ {registered, []},
+ {mod, { dubboerl_app, []}},
+ {applications,
+ [kernel,
+ stdlib,xmerl,eunit,erlzk,lager,poolboy,inets
+ ]},
+ {env,[]},
+ {modules, []},
+
+ {maintainers, []},
+ {licenses, []},
+ {links, []}
+ ]}.
diff --git a/src/dubboerl.erl b/src/dubboerl.erl
new file mode 100644
index 0000000..8d841bd
--- /dev/null
+++ b/src/dubboerl.erl
@@ -0,0 +1,54 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2017, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 22. Dec 2017 11:54 PM
+%%%-------------------------------------------------------------------
+-module(dubboerl).
+-author("dlive").
+
+-include("dubboerl.hrl").
+%% API
+-export([init/0,start_consumer/0,start_provider/0]).
+
+init()->
+ start_consumer(),
+ start_provider(),
+ ok.
+
+
+start_consumer()->
+ ConsumerList = application:get_env(dubboerl,consumer,[]),
+ ApplicationName = application:get_env(dubboerl,application,<<"defaultApplication">>),
+ lists:map(fun({Interface,Option})->
+ ConsumerInfo = dubbo_config_util:gen_consumer(ApplicationName,Interface,Option),
+ dubbo_zookeeper:register_consumer(ConsumerInfo),
+ lager:info("register consumer success ~p",[Interface])
+ end,ConsumerList),
+ ok.
+
+start_provider()->
+ ProviderList = application:get_env(dubboerl,provider,[]),
+ ApplicationName = application:get_env(dubboerl,application,<<"defaultApplication">>),
+ DubboServerPort = application:get_env(dubboerl,port,20881),
+ start_provider_listen(DubboServerPort),
+ lists:map(fun({ImplModuleName,BehaviourModuleName,Interface,Option})->
+ ok = dubbo_provider_protocol:register_impl_provider(Interface,ImplModuleName,BehaviourModuleName),
+ MethodList= apply(BehaviourModuleName,get_method_999_list,[]),
+ ProviderInfo = dubbo_config_util:gen_provider(ApplicationName,DubboServerPort,Interface,MethodList,Option),
+ dubbo_zookeeper:register_provider(ProviderInfo),
+ lager:info("register provider success ~p ~p",[ImplModuleName,Interface])
+ end,ProviderList),
+ ok.
+
+start_provider_listen(Port)->
+ ets:new(?PROVIDER_IMPL_TABLE,[public,named_table]),
+ {ok, _} = ranch:start_listener(tcp_reverse,
+ ranch_tcp, [{port, Port}], dubbo_provider_protocol, []),
+ ok.
+
+
+
+
diff --git a/src/dubboerl_app.erl b/src/dubboerl_app.erl
new file mode 100644
index 0000000..fb3a1a2
--- /dev/null
+++ b/src/dubboerl_app.erl
@@ -0,0 +1,42 @@
+%%%-------------------------------------------------------------------
+%% @doc dubboerl public API
+%% @end
+%%%-------------------------------------------------------------------
+
+-module(dubboerl_app).
+
+-behaviour(application).
+
+%% Application callbacks
+-export([start/2, stop/1,env_init/0]).
+
+%%====================================================================
+%% API
+%%====================================================================
+
+start(_StartType, _StartArgs) ->
+ io:format("[START] server start~n"),
+ env_init(),
+ dubboerl_sup:start_link().
+
+%%--------------------------------------------------------------------
+stop(_State) ->
+ ok.
+
+%%====================================================================
+%% Internal functions
+%%====================================================================
+env_init()->
+ dubbo_traffic_control:init(),
+ type_register:init(),
+ register_type_list().
+%% type_decoding:init().
+
+
+register_type_list()->
+ List = java_type_defined:get_list(),
+ lists:map(
+ fun({NativeType,ForeignType,Fields}) ->
+ de_type_transfer:pre_process_typedef(NativeType,ForeignType,Fields)
+ end,List),
+ ok.
\ No newline at end of file
diff --git a/src/dubboerl_sup.erl b/src/dubboerl_sup.erl
new file mode 100644
index 0000000..4e42308
--- /dev/null
+++ b/src/dubboerl_sup.erl
@@ -0,0 +1,57 @@
+%%%-------------------------------------------------------------------
+%% @doc dubboerl top level supervisor.
+%% @end
+%%%-------------------------------------------------------------------
+
+-module(dubboerl_sup).
+
+-behaviour(supervisor).
+
+-include("common.hrl").
+%% API
+-export([start_link/0]).
+
+%% Supervisor callbacks
+-export([init/1]).
+
+-define(SERVER, ?MODULE).
+
+%%====================================================================
+%% API functions
+%%====================================================================
+
+start_link() ->
+ supervisor:start_link({local, ?SERVER}, ?MODULE, []).
+
+%%====================================================================
+%% Supervisor callbacks
+%%====================================================================
+
+%% Child :: {Id,StartFunc,Restart,Shutdown,Type,Modules}
+init([]) ->
+ ZK = {dubbo_zookeeper,{dubbo_zookeeper, start_link, []},transient,5000,worker,[dubbo_zookeeper]},
+%% NettySer = {dubbo_netty_client,{dubbo_netty_client, start_link, []},transient,5000,worker,[dubbo_netty_client]},
+ Id_count = {de_id_count,{de_id_count, start_link, []},transient,5000,worker,[de_id_count]},
+ ProviderPoolSup = {dubbo_provider_worker_sup,{dubbo_provider_worker_sup, start_link, []},transient,5000,supervisor,[dubbo_provider_worker_sup]},
+ ConsumerPoolSup = {dubbo_consumer_pool_sup,{dubbo_consumer_pool_sup, start_link, []},transient,5000,supervisor,[dubbo_consumer_pool_sup]},
+ ConsumerPool = {dubbo_consumer_pool,{dubbo_consumer_pool, start_link, []},transient,5000,worker,[dubbo_consumer_pool]},
+%% Reloader = {push_reloader,{push_reloader, start_link, []},transient,5000,worker,[push_reloader]},
+%% List = case ?RELOADER of
+%% true ->
+%% io:format("[START] will start push_reloader service2222~n"),
+%% [Reloader];
+%% _->[]
+%% end,
+ ListNew1=
+ case application:get_env(dubboerl,registry,false) of
+ true ->
+ [ZK];
+ false->
+ []
+ end,
+ ListNew = ListNew1 ++ [Id_count,ConsumerPool,ConsumerPoolSup,ProviderPoolSup],
+ {ok, { {one_for_one, 60, 10}, ListNew} }.
+
+%%====================================================================
+%% Internal functions
+%%====================================================================
diff --git a/src/encode_test.erl b/src/encode_test.erl
new file mode 100644
index 0000000..e806784
--- /dev/null
+++ b/src/encode_test.erl
@@ -0,0 +1,53 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2016, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 18. 十月 2016 上午10:46
+%%%-------------------------------------------------------------------
+-module(encode_test).
+-author("dlive").
+
+-include("hessian.hrl").
+%% API
+-export([object_test/0,de_object/0]).
+
+-record(de_TestReq, {name, nick,age}).
+-record(de_reg2, {reqinfo,age}).
+
+object_test()->
+ ForeignTypeA = <<"com.ifcoder.demo.bean.UserInfoRequest">>,
+ TypeDefA = #type_def{foreign_type = ForeignTypeA,
+ native_type = de_TestReq,
+ fieldnames = record_info(fields,de_TestReq)},
+ EncodingState0 = type_encoding:enlist(TypeDefA),
+ io:format("state:~p~n",[EncodingState0]),
+ RequestArg0 = #de_TestReq{name = <<"nameinfo">>, nick = <<"nickname">> ,age=10 },
+%% Object = #object{values = [RequestArg0] },
+%% io:format("Object:~p~n",[Object]),
+ {Bin, State0} = hessianEncode:encode(RequestArg0, EncodingState0),
+ file:write_file("/tmp/object_erl.data",Bin),
+%% ?assertMatch(Expected, Bin),
+ %% This test is asymmetric because decode($O,Rest/bin)
+ %% will only consume the outer class definition,
+ %% in normal circumstances, the calling decode/2 function will recursively
+ %% consume all object definitions.
+%% {Rest, TypeDef, State1} = hessian:decode(Bin, DecodingState),
+%% ?assertMatch(TypeDefA, TypeDef),
+%% [Function|Arguments] = hessian:decode(<<99,2,0,109,0,1,97,Bin/binary>>, DecodingState),
+%% ?assertMatch([[A]], Arguments).
+
+ ok.
+
+de_object()->
+ ForeignTypeA = <<"com.ifcoder.demo.bean.UserInfoRequest">>,
+ TypeDefA = #type_def{foreign_type = ForeignTypeA,
+ native_type = de_TestReq,
+ fieldnames = record_info(fields,de_TestReq)},
+ EncodingState0 = hessianDecode2:enlist(TypeDefA),
+ {ok,Bin} = file:read_file("/tmp/object_erl.data"), %% /tmp/objectencode.data
+ Info = hessianDecode2:decode(Bin,EncodingState0),
+ io:format("info:~p~n",[Info]),
+ ok.
+
diff --git a/src/hessian.erl b/src/hessian.erl
new file mode 100644
index 0000000..b877b97
--- /dev/null
+++ b/src/hessian.erl
@@ -0,0 +1,590 @@
+% ---------------------------------------------------------------------------
+% Copyright (C) 2008 0x6e6562
+%
+% Licensed under the Apache License, Version 2.0 (the "License");
+% you may not use this file except in compliance with the License.
+% You may obtain a copy of the License at
+%
+% http://www.apache.org/licenses/LICENSE-2.0
+%
+% Unless required by applicable law or agreed to in writing, software
+% distributed under the License is distributed on an "AS IS" BASIS,
+% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+% See the License for the specific language governing permissions and
+% limitations under the License.
+% ---------------------------------------------------------------------------
+
+-module(hessian).
+
+-include("hessian.hrl").
+
+-export([call/5]).
+-export([invoke/4]).
+-export([decode/2]).
+-export([encode/2, encode/3, encode/4, encode/5]).
+%% TODO Move the e2cc function to encoding module
+-export([erlang_to_camel_case/1]).
+
+%---------------------------------------------------------------------------
+% Decoding
+%---------------------------------------------------------------------------
+
+% Binaries
+decode(<<16#20,Rest/binary>>, State) -> {Rest, <<>>, State};
+decode(<<Len:8/unsigned,Rest/binary>>, State) when Len =< 16#2f, 16#20 < Len ->
+ _Len = Len - 16#20,
+ <<Bin:_Len/binary,_Rest/binary>> = Rest,
+ {_Rest, Bin, State};
+decode(<<$B,Len:16/unsigned,Bin:Len/binary,Rest/binary>>, State) -> {Rest, Bin, State};
+decode(<<$b,Rest/binary>>,State) -> decode(<<$b,Rest/binary>>, [], State);
+%% Booleans
+decode(<<$T,Rest/binary>>, State) -> {Rest, true, State};
+decode(<<$F,Rest/binary>>, State) -> {Rest, false, State};
+%% Dates
+decode(<<$d,Date:64/unsigned,Rest/binary>>, State) ->
+ MegaSecs = Date div ?MegaSeconds,
+ Secs = (Date - MegaSecs * ?MegaSeconds) div ?Seconds,
+ MicroSecs = (Date - MegaSecs * ?MegaSeconds - Secs * ?Seconds) * ?MicroSeconds,
+ {Rest, {MegaSecs, Secs, MicroSecs}, State};
+%% Doubles
+decode(<<16#67,Rest/binary>>, State)-> {Rest, 0.0, State};
+decode(<<16#68,Rest/binary>>, State)-> {Rest, 1.0, State};
+decode(<<16#69,Int:8/signed,Rest/binary>>, State)-> {Rest, float(Int), State};
+decode(<<16#6a,Int:16/signed,Rest/binary>>, State)-> {Rest, float(Int), State};
+%% TODO ask erlang-questions about not being able to match a 32bit float
+decode(<<16#6b,Int:32/signed,Rest/binary>>, State)->
+ <<Double:64/float>> = <<Int:32,0,0,0,0>>,
+ {Rest, Double, State};
+decode(<<$D,Double:64/float,Rest/binary>>, State)-> {Rest, Double, State};
+%% Ints
+decode(<<$I,Int:32/unsigned,Rest/binary>>, State)-> {Rest, Int, State};
+decode(<<Int:8,Rest/binary>>, State) when Int >= 16#80, Int =< 16#bf -> {Rest, Int - 16#90, State};
+decode(<<B2:8,B1:8,B0:8,Rest/binary>>, State) when B2 >= 16#d0, B2 =< 16#d7 -> {Rest, ((B2 - 16#d4) bsl 16) + (B1 bsl 8) + B0, State};
+decode(<<B1:8,B0:8,Rest/binary>>, State) when B1 >= 16#c0, B1 =< 16#cf -> {Rest, ((B1 - 16#c8) bsl 8) + B0, State};
+%% Longs
+decode(<<$L,Long:64/unsigned,Rest/binary>>, State)-> {Rest, Long, State};
+decode(<<16#77,Long:32,Rest/binary>>, State) -> {Rest, Long, State};
+decode(<<Long:8,Rest/binary>>, State) when Long >= 16#d8, Long =< 16#ef -> {Rest, Long - 16#e0, State};
+decode(<<B2:8,B1:8,B0:8,Rest/binary>>, State) when B2 >= 16#38, B2 =< 16#3f -> {Rest, ((B2 - 16#3c) bsl 16) + (B1 bsl 8) + B0, State};
+decode(<<B1:8,B0:8,Rest/binary>>, State) when B1 >= 16#f0, B1 =< 16#ff -> {Rest, ((B1 - 16#f8) bsl 8) + B0, State};
+%% Strings
+decode(<<0,Rest/binary>>, State) -> {Rest, <<>>, State};
+decode(<<Len:8,String:Len/binary,Rest/binary>>, State) when Len < 32 -> {Rest, list_to_binary(xmerl_ucs:from_utf8(String)), State};
+decode(<<$S,Len:16/unsigned,String:Len/binary,Rest/binary>>, State) -> {Rest, list_to_binary(xmerl_ucs:from_utf8(String)), State};
+decode(<<$s,Rest/binary>>, State) -> decode(<<$s,Rest/binary>>,[], State);
+%% Nulls
+decode(<<$N,Rest/binary>>, State) -> {Rest, undefined, State};
+%% References
+decode(<<$R,Ref:32/unsigned,Rest/binary>>, State)-> {ref, Rest, Ref, State};
+%% Maps
+decode(<<$M,$t,L:16/unsigned,Type:L/binary,Map/binary>>, State) -> decode(map, Map, dict:store(fqn, Type, dict:new()), State);
+decode(<<$M,Map/binary>>, State) -> decode(map, Map, dict:new(), State);
+%%list ::= V type? length? value* z
+%% ::= v int int value*
+%%length ::= 'l' b3 b2 b1 b0
+%% ::= x6e int
+%% Lists
+decode(<<$V,$t,L1:16/unsigned,T:L1/binary,$l,L2:32/unsigned,Bin/binary>>, State) -> decode(list, Bin, [], State);
+decode(<<$V,$l,L1:32/unsigned,Bin/binary>>, State) -> decode(list, Bin, [], State);
+decode(<<$V,16#6e,L1:8,Bin/binary>>, State) -> decode(list, Bin, [], State);
+decode(<<$V,16#6e,L1:16,Bin/binary>>, State) -> decode(list, Bin, [], State);
+decode(<<$V,$t,L1:16/unsigned,T:L1/binary,Bin/binary>>, State) -> decode(list, Bin, [], State);
+decode(<<$V,Bin/binary>>, State) -> decode(list, Bin, [], State);
+decode(<<$O,?M,?m,Hash:32/unsigned,$u,$z>>, State0) -> {peer_cannot_resolve,Hash};
+decode(<<$O,Hash:32/unsigned,$t,L:16/unsigned,Type:L/binary,Bin/binary>>, State0) ->
+ {Rest, TypeDef, State} = decode(type_definition,Type,Bin,State0),
+ NewState = type_decoding:hash_store(Hash,TypeDef,State),
+ {Rest, {Hash,TypeDef}, NewState};
+decode(<<$O,Hash:32/unsigned,Bin/binary>>, State) ->
+ ?TYPEDEF(Hash),
+ case type_decoding:hash_lookup(Hash, State) of
+ {not_found, Hash} ->
+ %?LOG(Hash),
+ {Bin, {not_found, Hash}, State};
+ TypeDef ->
+ %?LOG(TypeDef),
+ NewState = type_decoding:visit(TypeDef,State),
+ {Bin,TypeDef,NewState}
+ end;
+decode(<<$o,Bin/binary>>, State) ->
+ {Rest,Ref,_State} = decode(Bin, State),
+ ?INSTANCE(Ref),
+ ForeignView = type_decoding:lookup_reference(Ref, _State),
+ #type_def{native_type = NativeType,
+ foreign_type = ForeignType,
+ fieldnames = ForeignFieldNames} = ForeignView,
+ NativeView = type_decoding:resolve_native_type(ForeignType,_State),
+ Count = count_fields(ForeignView),
+ case decode(field, Rest, Count,[], _State) of
+ {not_found,Hash} ->
+ {not_found,Hash};
+ {_Rest,FieldValues, NewState} ->
+ Object = type_decoding:project_native_view(ForeignFieldNames,FieldValues,NativeView),
+ {_Rest, Object, NewState}
+ end;
+%---------------------------------------------------------------------------
+% Call and reply decoding
+%---------------------------------------------------------------------------
+decode(<<$c,?M,?m,$m,L1:16/unsigned,Function:L1/binary,Bin/binary>>, State) ->
+ ?START(c, [?M,?m]),
+ ?METHOD(Function),
+ case decode(list, Bin,[], State) of
+ {error, Encoded} ->
+ {error, Encoded};
+ {not_found, Hash} ->
+ {not_found, Hash};
+ {Rest, Arguments, NewState} ->
+ [type_decoding:camel_case_to_erlang(Function), Arguments]
+ end;
+decode(<<$r,?M,?m,$N,$z>>, State) -> ok;
+%% TODO The string decoding in the fault decoding is a bit dodgy
+%% Also, have a look at the way it is being encoded
+decode(<<$r,?M,?m,$f,
+ 4,"code",L1:8,Code:L1/binary,
+ 7,"message",L2:8,Message:L2/binary,
+ 6,"detail",L3:8,Detail:L3/binary,$z>>, State) ->
+ {error, list_to_atom(binary_to_list(Message)) };
+decode(<<$r,?M,?m,Args/binary>>, State) ->
+ case decode(Args,[], State) of
+ {<<>>, Decoded,_State} ->
+ case lists:dropwhile(fun is_type_def/1, Decoded) of
+ [Value] ->
+ Value;
+ [H|T] ->
+ [H|T]
+ end;
+ {error, Encoded} ->
+ {error, Encoded}
+ end;
+%% Type queries
+decode(<<$q,?M,?m,Hash:32/unsigned,$z>>, State) ->
+ ?START(q, [?M,?m]),
+ ?VALUE(<<Hash:32>>),
+ case type_decoding:hash_lookup(Hash, State) of
+ {not_found, Hash} ->
+ {error, encode(fault, <<"ProtocolException">>, unknown_hash, Hash, State) };
+ TypeDef ->
+ {Hash,TypeDef, State}
+ end;
+decode(<<$y,?M,?m,Hash:32/unsigned,$z>>, State) ->
+ {type_query_ack, Hash};
+%% Anything else
+decode(<<Unexpected/binary>>, State) ->
+ {error, encode(fault, <<"ProtocolException">>, unexpected_byte_sequence, Unexpected, State) }.
+%----------------------------------
+decode(<<$b,Len:16/unsigned,Bin:Len/binary,$b,Rest/binary>>, Acc, State) ->
+ decode(<<$b,Rest/binary>>,Acc ++ [Bin], State);
+decode(<<$b,Len:16/unsigned,Bin:Len/binary,$B,Rest/binary>>, Acc, State) ->
+ _Acc = Acc ++ [Bin],
+ {_Rest,_Bin, State} = decode(<<$B,Rest/binary>>, State),
+ {_Rest, list_to_binary(_Acc ++ [_Bin]), State};
+decode(<<$s,Len:16,String:Len/binary,$s,Rest/binary>>,Acc, State) ->
+ _String = list_to_binary(xmerl_ucs:from_utf8(String)),
+ decode(<<$s,Rest/binary>>,Acc ++ [_String], State);
+decode(<<$s,Len:16,String:Len/binary,$S,Rest/binary>>,Acc, State) ->
+ _String = list_to_binary(xmerl_ucs:from_utf8(String)),
+ _Acc = Acc ++ [_String],
+ {_Rest,_Bin, _State} = decode(<<$S,Rest/binary>>, State),
+ {_Rest, list_to_binary(_Acc ++ [_Bin]), _State};
+decode(<<>>, List, State) -> {<<>>, List, State};
+decode(<<$z>>, List, State) -> {<<>>, List, State};
+decode(Args, List, State) ->
+ case decode(Args,State) of
+ {Rest, [H|T], _State} ->
+ decode(Rest, List ++ [H|T], _State);
+ {Rest, Result, _State} ->
+ decode(Rest, List ++ [Result], _State);
+ {ref, Rest, Ref, _State} ->
+ _Ref = lists:nth(Ref + 1, List),
+ decode(Rest, [List,[_Ref]] , _State);
+ {error, Encoded} ->
+ {error, Encoded}
+ end.
+decode(map, <<$z>>, Dict, State) -> {Dict, State};
+decode(map, <<$z,Rest/binary>>, Dict, State) -> {Rest,Dict, State};
+decode(map, Bin, Dict, State) ->
+ {_Rest, Key, _State} = decode(Bin, State),
+ case decode(_Rest, _State) of
+ {Rest, Value, __State} ->
+ decode(map, Rest, dict:store(Key, Value, Dict), __State);
+ {ref, Rest, Ref, __State} ->
+ %Value = lists:nth(Ref + 1, List),
+ Value = Ref,
+ decode(map, Rest, dict:store(Key, Value, Dict), __State)
+ end;
+decode(list, <<>>, List, State) -> {<<>>,List, State};
+decode(list, <<$z>>, List, State) -> {<<>>,List, State};
+decode(list, <<$z,Rest/binary>>, List, State) -> {Rest, List, State};
+decode(list, Bin, List, State) ->
+ case decode(Bin, State) of
+ {error, Encoded} ->
+ {error, Encoded};
+ {Rest, {type_def,_,_,_}, _State} ->
+ decode(list, Rest, List, _State);
+ {not_found,Hash} ->
+ {not_found, Hash};
+ {Rest, {not_found, Hash}, _State} ->
+ {not_found, Hash};
+ {Rest, Value, _State} ->
+ ?VALUE(Value),
+ decode(list, Rest, List ++ [Value], _State)
+ end;
+decode(type_definition, ForeignType, Bin, State) ->
+ {Rest,Count, _State} = decode(Bin, State),
+ {NewRest,FieldNames, NewState} = decode(field, Rest, Count, [], _State),
+ TypeDef = type_decoding:build_foreign_view(ForeignType,FieldNames,NewState),
+ {NewRest, TypeDef, NewState}.
+decode(field, <<$z,Rest/binary>>, Count, Acc, State) -> {Rest, Acc, State};
+decode(field, Rest, 0, Acc, State) -> {Rest, Acc, State};
+decode(field, Bin, Count, Acc, State) ->
+ {Rest,Field, _State} = decode(Bin, State),
+ case Field of
+ {not_found,Hash} ->
+ {not_found,Hash};
+ {type_def,_,_,_} ->
+ {_Rest, Object, __State} = decode(Rest, _State),
+ decode(field, _Rest, Count - 1, Acc ++ [Object], __State);
+ _ ->
+ decode(field, Rest, Count - 1, Acc ++ [Field], _State)
+ end.
+
+%---------------------------------------------------------------------------
+% Encoding
+%---------------------------------------------------------------------------
+
+encode(type_query, Hash) ->
+ ?START(q,[?M,?m]),
+ ?VALUE(<<Hash:32>>),
+ <<$q,?M,?m,Hash:32/unsigned,$z>>;
+encode(type_query_ok, Hash) -> <<$y,?M,?m,Hash:32/unsigned,$z>>;
+encode(type_information, TypeDef = #type_def{fieldnames = FieldNames,
+ foreign_type = ForeignType}) ->
+ Size = size(ForeignType),
+ Count = count_fields(TypeDef),
+ Int = encode(int, Count, []),
+ _FieldNames = lists:map(fun erlang_to_camel_case/1,FieldNames),
+ {AccOut, _} = lists:foldl(fun encode/2,{<<>>, []},_FieldNames),
+ Hash = erlang:phash2(TypeDef),
+ <<$O,Hash:32/unsigned,$t,Size:16/unsigned,ForeignType/binary,Int/binary,AccOut/binary,$z>>;
+
+encode(Value, {Acc,State}) ->
+ case encode(Value, State) of
+ {ValueBin, _State} ->
+ {<<Acc/binary,ValueBin/binary>>,_State};
+ ValueBin ->
+ {<<Acc/binary,ValueBin/binary>>,State}
+ end;
+
+% Null
+encode(undefined, State) -> <<$N>>;
+
+encode(Value, State) when is_integer(Value) -> encode(int, Value, State);
+encode(Value, State) when is_float(Value) -> encode(double, Value, State);
+encode(Value, State) when is_boolean(Value) -> encode(boolean, Value, State);
+encode(Value, State) when is_atom(Value) -> encode(string, atom_to_list(Value), State);
+encode(Value, State) when is_list(Value) -> encode(list, Value, State);
+encode(Value, State) when is_pid(Value) -> throw("Erlang Pid encoding not supported");
+%% Assume that a binary is a string
+%% TODO what about encapsulating binary-data????
+encode(Value, State) when is_binary(Value) -> encode(string, Value, State);
+%% TODO The order of this is_tuple guard worries me a bit, needs further attention.
+encode(Value, State) when is_tuple(Value) -> encode(object, Value, State).
+
+% x20 # zero-length binary data
+% x23 x01 x02 x03 # 3 octet data
+% B x10 x00 .... # 4k final chunk of data
+% b x04 x00 .... # 1k non-final chunk of data
+encode(binary, <<>>, State) -> <<16#20>>;
+encode(binary, Value, State) when size(Value) < 15 ->
+ Size = 16#20 + size(Value),
+ <<Size:8/unsigned,Value/binary>>;
+encode(binary, Value, State) -> encode(binary, Value, <<>>, State);
+encode(boolean, true, State) -> <<$T>>;
+encode(boolean, false, State) -> <<$F>>;
+encode(timestamp, {MegaSecs, Secs, MicroSecs}, State) ->
+ Date = MegaSecs * ?MegaSeconds + Secs * ?Seconds + MicroSecs div ?MicroSeconds,
+ <<$d,Date:64/unsigned>>;
+encode(localtime, DateTime={{Year,Month,Day},{Hour,Min,Sec}}, State) ->
+ [Universal] = calendar:local_time_to_universal_time_dst(DateTime),
+ Seconds = calendar:datetime_to_gregorian_seconds(Universal),
+ MilliSeconds = (Seconds - ?UnixEpoch) * 1000,
+ <<$d,MilliSeconds:64/unsigned>>;
+encode(double, 0.0, State) -> <<16#67>>;
+encode(double, 1.0, State) -> <<16#68>>;
+encode(double, Double, State) when Double >= -128.0, Double =< 127.0, Double == round(Double) ->
+ Byte = round(Double),
+ <<16#69, Byte/signed>>;
+encode(double, Double, State) when Double >= -32768.0, Double =< 32767.0, Double == round(Double) ->
+ Byte = round(Double),
+ <<16#6a, Byte:16/signed>>;
+encode(double, Double, State) ->
+ case <<Double/float>> of
+ <<B24,B16,B8,B0,0,0,0,0>> ->
+ <<16#6b,B24,B16,B8,B0>>;
+ Other ->
+ <<$D,Other/binary>>
+ end;
+encode(int, Int, State) when Int >= -16, Int =< 47 ->
+ _Int = Int + 16#90,
+ <<_Int:8>>;
+encode(int, Int, State) when Int >= -2048, Int =< 2047 ->
+ <<B1:8,B0:8>> = <<Int:16>>,
+ _B1 = B1 + 16#c8,
+ <<_B1,B0>>;
+encode(int, Int, State) when Int >= -262144, Int =< 262143 ->
+ <<B2:8,B1:8,B0:8>> = <<Int:24>>,
+ _B2 = B2 + 16#d4,
+ <<_B2,B1,B0>>;
+encode(int, Int, State) when Int > 16#100000000 -> <<$L,Int:64/unsigned>>;
+encode(int, Int, State) -> <<$I,Int:32/unsigned>>;
+encode(long, Long, State) when Long >= -8, Long =< 15 ->
+ _Long = Long + 16#e0,
+ <<_Long:8>>;
+encode(long, Long, State) when Long >= -2048, Long =< 2047 ->
+ <<B1:8,B0:8>> = <<Long:16>>,
+ _B1 = B1 + 16#f8,
+ <<_B1,B0>>;
+encode(long, Long, State) when Long >= -262144, Long =< 262143 ->
+ <<B2:8,B1:8,B0:8>> = <<Long:24>>,
+ _B2 = B2 + 16#3c,
+ <<_B2,B1,B0>>;
+encode(long, Long, State) when Long >= -16#100000000, Long =< 16#100000000 -> <<16#77,Long:32>>;
+encode(long, Long, State) -> <<$L,Long:64/unsigned>>;
+encode(string, <<>>, State) -> <<0>>;
+encode(string, [], State) -> <<0>>;
+encode(string, String, State) when is_binary(String)-> encode(string, binary_to_list(String), State);
+encode(string, String, State) when is_list(String)->
+ UTF8 = case catch xmerl_ucs:is_incharset(String,'utf-8') of
+ true ->
+ String;
+ _ ->
+ xmerl_ucs:to_utf8(String)
+ end,
+ %% There is a question pending on the hessian list as to whether the length
+ %% refers to the UTF-8 or the native length
+ %Length = length(String),
+ Length = length(UTF8),
+ if
+ Length < 32 ->
+ Bin = list_to_binary(UTF8),
+ <<Length:8,Bin/binary>>;
+ true ->
+ encode(string, list_to_binary(String), <<>>, State)
+ end;
+encode(dictionary, Dict, State) ->
+ Encoder = fun(Key, Value, AccIn) ->
+ KeyBin = encode(Key, State),
+ ValueBin = encode(Value, State),
+ <<AccIn/binary,KeyBin/binary,ValueBin/binary>> end,
+ AccOut = dict:fold(Encoder, <<$M>>, Dict),
+ <<AccOut/binary,$z>>;
+%% Length
+%::= 'l' b3 b2 b1 b0
+%::= x6e int
+encode(length, List, State) ->
+ Length = length(List),
+ case encode(int, Length, State) of
+ <<$I,Int/binary>> ->
+ <<$l,Int/binary>>;
+ Other ->
+ <<16#6e,Other/binary>>
+ end;
+%% Lists
+encode(list, List, State) ->
+ Length = encode(length, List, State),
+ encode(list, List, <<$V,Length/binary>>, State);
+encode(method, Method, State) when is_atom(Method) ->
+ String = atom_to_list(Method),
+ encode(method, String, State);
+encode(method, Method, State) when is_binary(Method) ->
+ _Method = erlang_to_camel_case(Method),
+ Size = size(_Method),
+ <<$m,Size:16/unsigned,_Method/binary>>;
+%---------------------------------------------------
+% TODO I don't think this ever gets called
+encode(method, String, State) when is_list(String) ->
+ _String = erlang_to_camel_case(String),
+ Length = string:len(_String),
+ Bin = list_to_binary(_String),
+ <<$m,Length:16/unsigned,Bin/binary>>;
+%---------------------------------------------------
+encode(type, FullyQualifiedName, State) when is_list(FullyQualifiedName) ->
+ Bin = list_to_binary(FullyQualifiedName),
+ encode(type,Bin, State);
+encode(type, FullyQualifiedName, State) when is_binary(FullyQualifiedName) ->
+ Length = size(FullyQualifiedName),
+ <<$t,Length:16,FullyQualifiedName/binary>>;
+%% TODO implement header
+%% reply ::= r x01 x00 header* object z
+%% ::= r x01 x00 header* fault z
+encode(reply, ok, State) -> <<$r,?M,?m,$N,$z>>;
+encode(reply, {ok, Object}, State) -> encode(reply, Object, State);
+encode(reply, {error, {Error, Reason} }, State) -> encode(fault, Error, Reason, State);
+encode(reply, Object, State) ->
+ ?START(r,[?M,?m]),
+ Bin = case encode(Object, State) of
+ {_Bin, NewState} ->
+ _Bin;
+ _Bin ->
+ _Bin
+ end,
+ <<$r,?M,?m,Bin/binary,$z>>;
+encode(object, DateTime = {MegaSecs, Secs, MicroSecs}, State)
+ when is_integer(MegaSecs), is_integer(Secs), is_integer(MicroSecs)->
+ ?LOG("Employing date heuristic"),
+ encode(timestamp,DateTime,State);
+encode(object, Object, State) when is_tuple(Object) ->
+ [NativeType|Values] = tuple_to_list(Object),
+ {TypeEncoding, EncodedRef, NewState} =
+ case type_encoding:visit(NativeType,State) of
+ {ref, Ref} ->
+ encode(type_information, {ref, Ref}, State);
+ {hash, Hash, Ref, State0} ->
+ encode(type_information, {hash, Hash, Ref}, State0)
+ end,
+ {AccOut, _NewState} = lists:foldl(fun encode/2,{<<>>, NewState},Values),
+ {<<TypeEncoding/binary,$o,EncodedRef/binary,AccOut/binary>>, _NewState};
+encode(type_information, {ref, Ref}, State) ->
+ {<<>>, encode(int, Ref, State), State};
+encode(type_information, {hash, Hash, Ref}, State) ->
+ EncodedRef = encode(int, Ref, State),
+ {<<$O,Hash:32/unsigned>>, EncodedRef, State}.
+encode(binary, Value, <<>>, State) when size(Value) =< ?CHUNK_SIZE ->
+ Size = size(Value),
+ <<$B,Size:16,Value/binary>>;
+encode(binary, Value, Acc, State) when size(Value) =< ?CHUNK_SIZE ->
+ Size = size(Value),
+ <<Acc/binary,$B,Size:16,Value/binary>>;
+encode(binary, Value, <<>>, State) ->
+ <<Chunk:?CHUNK_SIZE/binary,Rest/binary>> = Value,
+ encode(binary, Rest, <<$b,?CHUNK_SIZE:16,Chunk/binary>>, State);
+encode(binary, Value, Acc, State) ->
+ <<Chunk:?CHUNK_SIZE/binary,Rest/binary>> = Value,
+ encode(binary, Rest, <<Acc/binary,$b,?CHUNK_SIZE:16,Chunk/binary>>, State);
+encode(string, Value, Acc, State) when size(Value) =< ?CHUNK_SIZE ->
+ Size = size(Value),
+ <<Acc/binary,$S,Size:16,Value/binary>>;
+encode(string, Value, <<>>, State) ->
+ <<Chunk:?CHUNK_SIZE/binary,Rest/binary>> = Value,
+ encode(string, Rest, <<$s,?CHUNK_SIZE:16,Chunk/binary>>, State);
+encode(string, Value, Acc, State) ->
+ <<Chunk:?CHUNK_SIZE/binary,Rest/binary>> = Value,
+ encode(string, Rest, <<Acc/binary,$s,?CHUNK_SIZE:16,Chunk/binary>>, State);
+%---------------------------------------------------------------------------
+% List Encoding
+%---------------------------------------------------------------------------
+encode(list, Type, List, State) when is_binary(Type) ->
+ TypeLength = size(Type),
+ ListLength = length(List),
+ encode(list, List, <<$V,$t,TypeLength:16/unsigned,Type/binary,$l,ListLength:32/unsigned>>, State);
+encode(list, List, Acc0, State) when is_binary(Acc0) ->
+ {AccOut, State} = lists:foldl(fun encode_accumulate/2, {Acc0,State}, List),
+ <<AccOut/binary,$z>>;
+%---------------------------------------------------------------------------
+% Call and Reply Encoding
+%---------------------------------------------------------------------------
+%% TODO implement header call ::= c x01 x00 header* method object* z
+encode(call, Method, Args, State) ->
+ encode(call, Method, Args, fun encode_accumulate/2, State);
+encode(fault, _Error, _Reason, State) ->
+ encode(fault, <<"ServiceException">>, _Error, _Reason, State).
+encode(fault, Code, _Error, _Reason, State) ->
+ EncodedCode = encode(string,Code, State),
+ <<131,100,L2:16/unsigned,Error/binary>> = term_to_binary(_Error),
+ EncodedError = encode(string,Error, State),
+ <<$r,?M,?m,$f,
+ 4,"code",EncodedCode/binary,
+ 7,"message",EncodedError/binary,
+ 6,"detail",31,"Stack trace not yet implemented",
+ $z>>;
+encode(call, Method, Args, Fun, State) when is_function(Fun) ->
+ MethodBin = encode(method,Method, State),
+ {Bin, NewState} = lists:foldl(Fun, {<<>>, State}, Args),
+ <<$c,?M,?m,MethodBin/binary,Bin/binary,$z>>.
+
+%---------------------------------------------------------------------------
+% Invocation
+%---------------------------------------------------------------------------
+
+invoke(Module,Bin,DecodingState,EncodingState) ->
+ case decode(Bin,DecodingState) of
+ {error, Reason} ->
+ encode(fault, decoding_error, Reason, EncodingState);
+ {not_found, Hash} ->
+ encode(type_query,Hash);
+ {peer_cannot_resolve,Hash} ->
+ %% TODO what should happen here? Is this good enough?
+ encode(reply,ok,[]);
+ {type_query_ack, Hash} ->
+ %% TODO This has not been implemented yet
+ ok;
+ %% Don't know if I like this weakly typed differentiation,
+ %% it seems a bit brittle
+ {_,{Hash,TypeDef},_} ->
+ encode(type_query_ok, Hash);
+ %% TODO look into whether this 2nd branch for type_query_ok is needed,
+ %% or whether to refactor the corresponding return value from the
+ %% decode function
+ {_,TypeDef,_} ->
+ encode(type_information, TypeDef);
+ [Function,Args] ->
+ Result = apply(Module,Function,Args),
+ encode(reply,Result,EncodingState)
+ end.
+
+%% This is used for synchronous transports that can respond
+%% to a type query
+call(Dispatcher,Method,Args,DecodingState,EncodingState) ->
+ Bin = encode(call,Method,Args,EncodingState),
+ Response0 = apply(Dispatcher,[Bin]),
+ case decode(Response0,DecodingState) of
+ {Hash,TypeDef,_} ->
+ ok = send_type_negotiation(Dispatcher,TypeDef,DecodingState),
+ Response = apply(Dispatcher,[Bin]),
+ decode(Response,DecodingState);
+ Other ->
+ Other
+ end.
+
+send_type_negotiation(Dispatcher,TypeDef,DecodingState) ->
+ TypeDefBin = hessian:encode(type_information, TypeDef),
+ Response = apply(Dispatcher,[TypeDefBin]),
+ case hessian:decode(Response,DecodingState) of
+ ok ->
+ ok;
+ Error ->
+ throw({type_negotiation_error,Error})
+ end.
+
+%---------------------------------------------------------------------------
+% Utility methods
+%---------------------------------------------------------------------------
+erlang_to_camel_case(String) when is_binary(String) ->
+ AsList = binary_to_list(String),
+ AsCamel = lists:foldl(fun camelize/2,[],AsList),
+ list_to_binary(AsCamel);
+erlang_to_camel_case(String) when is_atom(String) ->
+ AsList = atom_to_list(String),
+ AsCamel = lists:foldl(fun camelize/2,[],AsList),
+ list_to_binary(AsCamel).
+
+camelize(Element,Acc) when Element == $_ -> [$_|Acc];
+camelize(Element,[$_|Acc]) -> lists:append(Acc,[Element - 16#20]);
+camelize(Element,Acc) -> lists:append(Acc,[Element]).
+
+
+%% May want to take another look at this:
+%% All of the primitive encoding functions do not return the state.
+%% Maybe they should to avoid differentiations like this.
+encode_accumulate(Value, {Acc, State}) ->
+ case encode(Value, State) of
+ {Encoded,NewState} ->
+ {<<Acc/binary,Encoded/binary>>,NewState};
+ Encoded ->
+ {<<Acc/binary,Encoded/binary>>,State}
+ end.
+
+is_type_def(#type_def{}) -> true;
+is_type_def(_) -> false.
+
+count_fields(#type_def{fieldnames = FieldNames}) -> length(FieldNames).
diff --git a/src/hessianDecode.erl b/src/hessianDecode.erl
new file mode 100755
index 0000000..adc06fe
--- /dev/null
+++ b/src/hessianDecode.erl
@@ -0,0 +1,347 @@
+-module(hessianDecode).
+
+-include("hessian.hrl").
+
+-export([decode/2]).
+%%-export([init/0]).
+
+%%-record(decoding_state,{type_pool = dict:new(), reference_pool = dict:new()}).
+-record(decoding_state,{type_pool = dict:new(), reference_pool = dict:new(),obj_define_no=0}).
+%---------------------------------------------------------------------------
+% Decoding
+%---------------------------------------------------------------------------
+decode_str(Rest, 0, R) ->
+ {list_to_binary(xmerl_ucs:to_utf8(lists:reverse(R))), Rest};
+decode_str(<<C/utf8, Rest/binary>>, N, R) ->
+ decode_str(Rest, N-1, [C|R]).
+
+% Call
+decode(<<$H,?M,?m,$C,Bin/binary>>, State) ->
+ {Rest, Function, _State} = decode(Bin,State),
+ {Rest2, Count, __State} = decode(Rest,_State),
+ case decode(list, Rest2,Count,[], __State) of
+ {error, Encoded} ->
+ {error, Encoded};
+ {not_found, Hash} ->
+ {not_found, Hash};
+ {_Rest, Arguments, _NewState} ->
+ [Function, Arguments]
+ end;
+% Fault
+decode(<<$H,?M,?m,$F,
+ Rest/binary>>, State) ->
+ {_Rest,#map{dict=Dict},_State} = decode(Rest, State),
+ {ok, Message} = dict:find(<<"message">>, Dict),
+ {error, Message};
+% Reply
+decode(<<$H,?M,?m,$R,Args/binary>>, State) ->
+ case decode(Args,[], State) of
+ {<<>>, Decoded,_State} ->
+ TypeSet = get_type_set(_State),
+ case Decoded of
+ [Value] ->
+ {Value,TypeSet};
+ [H|T] ->
+ {[H|T],TypeSet}
+ end;
+ {error, Encoded} ->
+ {error, Encoded}
+ end;
+% Binaries
+decode(<<16#20,Rest/binary>>, State) -> {Rest, <<>>, State};
+decode(<<Len:8/unsigned,Rest/binary>>, State) when Len =< 16#2f, 16#20 < Len ->
+ _Len = Len - 16#20,
+ <<Bin:_Len/binary,_Rest/binary>> = Rest,
+ {_Rest, Bin, State};
+decode(<<$B,Len:16/unsigned,Bin:Len/binary,Rest/binary>>, State) -> {Rest, Bin, State};
+decode(<<$b,Rest/binary>>,State) -> decode(<<$b,Rest/binary>>, [], State);
+%% Booleans
+decode(<<$T,Rest/binary>>, State) -> {Rest, true, State};
+decode(<<$F,Rest/binary>>, State) -> {Rest, false, State};
+%% Dates
+decode(<<16#4a,Date:64/unsigned,Rest/binary>>, State) ->
+ MegaSecs = Date div ?MegaSeconds,
+ Secs = (Date - MegaSecs * ?MegaSeconds) div ?Seconds,
+ MicroSecs = (Date - MegaSecs * ?MegaSeconds - Secs * ?Seconds) * ?MicroSeconds,
+ {Rest, {MegaSecs, Secs, MicroSecs}, State};
+decode(<<16#4b,Date:32/unsigned,Rest/binary>>, State) ->
+ MegaSecs = (Date * 60000) div ?MegaSeconds,
+ Secs = (Date * 60000 - MegaSecs * ?MegaSeconds) div ?Seconds,
+ {Rest, {MegaSecs, Secs, 0}, State};
+%% Doubles
+decode(<<16#5b,Rest/binary>>, State)-> {Rest, 0.0, State};
+decode(<<16#5c,Rest/binary>>, State)-> {Rest, 1.0, State};
+decode(<<16#5d,Int:8/signed,Rest/binary>>, State)-> {Rest, float(Int), State};
+decode(<<16#5e,Int:16/signed,Rest/binary>>, State)-> {Rest, float(Int), State};
+decode(<<16#5f,Int:32/signed,Rest/binary>>, State)->
+ <<Double:64/float>> = <<Int:32,0,0,0,0>>,
+ {Rest, Double, State};
+decode(<<$D,Double:64/float,Rest/binary>>, State)-> {Rest, Double, State};
+%% Ints
+decode(<<$I,Int:32/signed,Rest/binary>>, State)-> {Rest, Int, State};
+decode(<<Int:8,Rest/binary>>, State) when Int >= 16#80, Int =< 16#bf -> {Rest, Int - 16#90, State};
+decode(<<B2:8,B1:8,B0:8,Rest/binary>>, State) when B2 >= 16#d0, B2 =< 16#d7 -> {Rest, ((B2 - 16#d4) bsl 16) + (B1 bsl 8) + B0, State};
+decode(<<B1:8,B0:8,Rest/binary>>, State) when B1 >= 16#c0, B1 =< 16#cf -> {Rest, ((B1 - 16#c8) bsl 8) + B0, State};
+%% Longs
+decode(<<$L,Long:64/signed,Rest/binary>>, State)-> {Rest, Long, State};
+decode(<<16#59,Long:32/signed,Rest/binary>>, State) -> {Rest, Long, State};
+decode(<<Long:8,Rest/binary>>, State) when Long >= 16#d8, Long =< 16#ef -> {Rest, Long - 16#e0, State};
+decode(<<B2:8,B1:8,B0:8,Rest/binary>>, State) when B2 >= 16#38, B2 =< 16#3f -> {Rest, ((B2 - 16#3c) bsl 16) + (B1 bsl 8) + B0, State};
+decode(<<B1:8,B0:8,Rest/binary>>, State) when B1 >= 16#f0, B1 =< 16#ff -> {Rest, ((B1 - 16#f8) bsl 8) + B0, State};
+%% Strings
+decode(<<0,Rest/binary>>, State) -> {Rest, <<>>, State};
+decode(<<Len:8,Rest/binary>>, State) when Len < 32 ->
+ {String, NewRest} = decode_str(Rest, Len, []),
+ {NewRest, String, State};
+decode(<<B1:8,B0:8,Rest/binary>>, State) when B1 =< 16#33,B1 >= 16#30 ->
+ Len = ((B1 - 16#30) bsl 8) + B0,
+ {String, NewRest} = decode_str(Rest, Len, []),
+ {NewRest, String, State};
+decode(<<$S,Len:16/unsigned,Rest/binary>>, State) ->
+ {String, NewRest} = decode_str(Rest, Len, []),
+ {NewRest, String, State};
+decode(<<$R,Rest/binary>>, State) -> decode(<<$R,Rest/binary>>,[], State);
+%% Nulls
+decode(<<$N,Rest/binary>>, State) -> {Rest, undefined, State};
+%% References
+decode(<<$Q,Bin/binary>>, State)->
+ {Rest, IntRef, _State} = decode(Bin,State),
+ {Rest, {ref, IntRef}, _State};
+%% Maps
+decode(<<$M,Map/binary>>, State) ->
+ {Rest,Type,_State} = decode(Map, State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = map},_State),
+ {_Rest,Dict, NewState} = decode(map, Rest, dict:new(), __State),
+ {_Rest,#map{refNo=_Refnum,type=Type,dict=Dict},NewState};
+decode(<<$H,Map/binary>>, State) ->
+ {_Refnum,_State} = visit(#type_def{foreign_type = map},State),
+ {_Rest,Dict, NewState} = decode(map, Map, dict:new(), _State),
+ {_Rest,#map{refNo=_Refnum,dict=Dict},NewState};
+%% Lists
+% 'V' type int value* # fixed-length list
+decode(<<$V,Bin/binary>>, State) ->
+ {Rest1,_Type,_State1} = decode(Bin,State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = list},_State1),
+ {Rest2,Len,_State2} = decode(Rest1,__State),
+ {NewRest,List,NewState} = decode(list, Rest2, Len, [], _State2),
+ {NewRest,#list{refNo=_Refnum,len=Len,type=_Type,values=List},NewState};
+% 'X' int value* # fixed-length untyped list
+decode(<<$X,Bin/binary>>, State) ->
+ {Rest1,Len,_State} = decode(Bin,State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = list},_State),
+ {NewRest,List,NewState} = decode(list, Rest1, Len, [], __State),
+ {NewRest,#list{refNo=_Refnum,len=Len,values=List},NewState};
+% [x70-77] type value* # fixed-length typed list
+decode(<<H:5,Len:3,Bin/binary>>, State) when H == 14 ->
+ {Rest1,_Type,_State} = decode(Bin,State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = list},_State),
+ {NewRest,List,NewState} = decode(list, Rest1, Len, [], __State),
+ {NewRest,#list{refNo=_Refnum,len=Len,type=_Type,values=List},NewState};
+% [x78-7f] value* # fixed-length untyped list
+decode(<<H:5,Len:3,Bin/binary>>, State) when H == 15 ->
+ {_Refnum,_State} = visit(#type_def{foreign_type = list},State),
+ {NewRest,List,NewState} = decode(list, Bin, Len, [], _State),
+ {NewRest,#list{refNo=_Refnum,len=Len,values=List},NewState};
+% 'U' type value* 'Z' # variable-length list
+decode(<<$U,Bin/binary>>, State) ->
+ {Rest1,_Type,_State} = decode(Bin,State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = list},_State),
+ {NewRest,List,NewState} = decode(list, Rest1, [], __State),
+ {NewRest,#list{refNo=_Refnum,type=_Type,values=List},NewState};
+% 'W' value* 'Z' # variable-length untyped list
+decode(<<$W,Bin/binary>>, State) ->
+ {_Refnum,_State} = visit(#type_def{foreign_type = list},State),
+ {NewRest,List,NewState} = decode(list, Bin, [], _State),
+ {NewRest,#list{refNo=_Refnum,values=List},NewState};
+decode(<<$C,Bin/binary>>, State0) ->
+ {Rest1,Type,State1} = decode(Bin,State0), %% Rest1 剩余字节码, Type 对象类型
+ {Rest, TypeDef, State} = decode(type_definition,Type,Rest1,State1),
+ NewState = type_decoding:hash_store(TypeDef,State),
+ decode(Rest,NewState);
+decode(<<$O,Bin/binary>>, State) ->
+ {Rest,Ref,_State} = decode(Bin, State),
+ case type_decoding:hash_lookup(Ref, _State) of
+ {not_found, Ref} ->
+ {Rest, {not_found, Ref}, _State};
+ ForeignView ->
+ #type_def{fieldnames = ForeignFieldNames} = ForeignView,
+ {_Refnum,__State} = type_decoding:visit(ForeignView,_State),
+ Count = count_fields(ForeignView),
+ case decode(field, Rest, Count,[], __State) of
+ {not_found,Hash} ->
+ {not_found,Hash};
+ {_Rest,FieldValues, NewState} ->
+ Object = type_decoding:project_native_view(ForeignFieldNames,FieldValues,ForeignView),
+%% {_Rest, #object{refNo=_Refnum, typeRef=Ref,values=Object}, NewState}
+ {_Rest, Object, NewState}
+ end
+ end;
+decode(<<H:4,Ref:4,Rest/binary>>, _State) when H == 6 ->
+ case type_decoding:hash_lookup(Ref, _State) of
+ {not_found, Ref} ->
+ {Rest, {not_found, Ref}, _State};
+ ForeignView ->
+ #type_def{fieldnames = ForeignFieldNames} = ForeignView,
+ {_Refnum,__State} = visit(ForeignView,_State),
+ Count = count_fields(ForeignView),
+ case decode(field, Rest, Count,[], __State) of
+ {not_found,Hash} ->
+ {not_found,Hash};
+ {_Rest,FieldValues, NewState} ->
+ Object = type_decoding:project_native_view(ForeignFieldNames,FieldValues,ForeignView),
+ %%{_Rest, #object{refNo =_Refnum, typeRef=Ref,values=Object}, NewState}
+ {_Rest, Object, NewState}
+ end
+ end;
+%% Anything else
+decode(<<Unexpected/binary>>, State) ->
+ {error, hessianEncode:encode(fault, <<"ProtocolException">>, unexpected_byte_sequence, Unexpected, State) }.
+decode(<<$b,Len:16/unsigned,Bin:Len/binary,$b,Rest/binary>>, Acc, State) ->
+ decode(<<$b,Rest/binary>>,Acc ++ [Bin], State);
+decode(<<$b,Len:16/unsigned,Bin:Len/binary,$B,Rest/binary>>, Acc, State) ->
+ _Acc = Acc ++ [Bin],
+ {_Rest,_Bin, State} = decode(<<$B,Rest/binary>>, State),
+ {_Rest, list_to_binary(_Acc ++ [_Bin]), State};
+decode(<<$R,Len:16/unsigned,Rest/binary>>,Acc, State) ->
+ {_String, NewRest} = decode_str(Rest, Len, []),
+ <<H:8,_/binary>> = NewRest,
+ case H of
+ $R -> decode(NewRest,list_to_binary([Acc|[_String]]), State);
+ $S -> {_Rest,_Bin, _State} = decode(NewRest, State),
+ _Acc2 =[Acc |[_String]],
+ {_Rest, list_to_binary(_Acc2 ++ [_Bin]), _State}
+ end;
+decode(<<>>, List, State) -> {<<>>, List, State};
+decode(<<$Z>>, List, State) -> {<<>>, List, State};
+decode(Args, List, State) ->
+ case decode(Args,State) of
+ {Rest,{ref, Ref}, _State} ->
+ decode(Rest, List ++ [{ref, Ref}] , _State);
+ {Rest, [H|T], _State} ->
+ decode(Rest, List ++ [H|T], _State);
+ {Rest, Result, _State} ->
+ decode(Rest, List ++ [Result], _State);
+ {error, Encoded} ->
+ {error, Encoded}
+ end.
+decode(map, <<$Z>>, Dict, State) -> {<<>>,Dict, State};
+decode(map, <<$Z,Rest/binary>>, Dict, State) -> {Rest,Dict, State};
+decode(map, Bin, Dict, State) ->
+ {_Rest, Key, _State} = decode(Bin, State),
+ case decode(_Rest, _State) of
+ {Rest, {ref, Ref}, __State} ->
+ %Value = lists:nth(Ref + 1, List),
+ Value = Ref,
+ decode(map, Rest, dict:store(Key, {ref, Value}, Dict), __State);
+ {Rest, Value, __State} ->
+ decode(map, Rest, dict:store(Key, Value, Dict), __State)
+ end;
+decode(list, <<>>, List, State) -> {<<>>,lists:reverse(List), State};
+decode(list, <<$Z>>, List, State) -> {<<>>,lists:reverse(List), State};
+decode(list, <<$Z,Rest/binary>>, List, State) -> {Rest, lists:reverse(List), State};
+decode(list, Bin, List, State) ->
+ case decode(Bin, State) of
+ {error, Encoded} ->
+ {error, Encoded};
+ {not_found,Hash} ->
+ {not_found, Hash};
+ {_Rest, {not_found, Hash}, _State} ->
+ {not_found, Hash};
+ {Rest, Value, _State} ->
+ decode(list, Rest, [Value|List], _State)
+ end;
+decode(type_definition, ForeignType, Bin, State) ->
+ {Rest,Count, _State} = decode(Bin, State),
+ {NewRest,FieldNames, NewState} = decode(field, Rest, Count, [], _State),
+ %% change 用回之前的 build_foreign_view NewState 不变
+ {TypeDef,NewState2} = type_decoding:build_foreign_view(ForeignType,FieldNames,NewState),
+ {NewRest, TypeDef, NewState2}.
+decode(list, Bin, 0, List, State) -> {Bin, lists:reverse(List), State};
+decode(list, Bin, Len, List, State) ->
+ case decode(Bin, State) of
+ {error, Encoded} ->
+ {error, Encoded};
+ {not_found,Hash} ->
+ {not_found, Hash};
+ {_Rest, {not_found, Hash}, _State} ->
+ {not_found, Hash};
+ {Rest, Value, _State} ->
+ decode(list, Rest, Len - 1, [Value|List], _State)
+ end;
+decode(field, Rest, 0, Acc, State) -> {Rest, Acc, State};
+decode(field, <<$Z,Rest/binary>>, _Count, Acc, State) -> {Rest, Acc, State};
+decode(field, Bin, Count, Acc, State) ->
+ {Rest,Field, _State} = decode(Bin, State),
+ case Field of
+ {not_found,Hash} ->
+ {not_found,Hash};
+ _ ->
+ decode(field, Rest, Count - 1, Acc ++ [Field], _State)
+ end.
+
+get_type_set(#decoding_state{type_pool = Pool}) ->
+ case dict:to_list(Pool) of
+ [] -> [];
+ Data -> [Value || {_Key,Value} <- Data]
+ end.
+
+build_foreign_view(ForeignType,FieldNames,State) ->
+ ForeignView = FieldNames,
+ #decoding_state{type_pool = OldPool} = State,
+ Native = dict:size(OldPool),
+ NewPool = dict:store(Native,
+ #type_def{native_type = Native,
+ foreign_type = ForeignType,
+ fieldnames = ForeignView},
+ OldPool),
+ {
+ #type_def{native_type = Native,
+ foreign_type = ForeignType,
+ fieldnames = ForeignView},
+ State#decoding_state{type_pool = NewPool}
+ }.
+
+project_native_view(ForeignView,ForeignData,
+ #type_def{native_type = _NativeType, foreign_type = _ForeignType, fieldnames = NativeView}) ->
+ AsDict = dict:from_list(lists:zip(ForeignView,ForeignData)),
+ NativeData = [dict:fetch(Key,AsDict) || Key <- NativeView],
+ NativeData.
+
+visit(TypeDef, State = #decoding_state{reference_pool = OldPool}) ->
+ Size = dict:size(OldPool),
+ NewPool = dict:store(Size, TypeDef, OldPool),
+ {Size,State#decoding_state{reference_pool = NewPool}}.
+
+%%hash_lookup(Hash,_State) ->
+%% init(false),
+%% case ets:lookup(hashes, Hash) of
+%% [] ->
+%% {not_found, Hash};
+%% [{Hash,TypeDef}] ->
+%% TypeDef
+%% end.
+
+%%hash_store(TypeDef = #type_def{native_type = Hash}, State) ->
+%% init(false),
+%% ets:insert(hashes,{Hash,TypeDef}),
+%% State.
+%%
+%%init() -> init(true).
+%%
+%%init(Delete) when is_boolean(Delete) ->
+%% case ets:info(hashes) of
+%% undefined ->
+%% ets:new(hashes,[public,named_table]);
+%% _ ->
+%% if
+%% Delete ->
+%% ets:delete(hashes),
+%% ets:new(hashes,[public,named_table]);
+%% true ->
+%% ok
+%% end
+%% end,
+%% #decoding_state{}.
+
+count_fields(#type_def{fieldnames = FieldNames}) -> length(FieldNames).
+
diff --git a/src/hessianDecode2.erl b/src/hessianDecode2.erl
new file mode 100644
index 0000000..93c8173
--- /dev/null
+++ b/src/hessianDecode2.erl
@@ -0,0 +1,361 @@
+-module(hessianDecode2).
+
+-include("hessian.hrl").
+
+-export([decode/2]).
+-export([init/0]).
+-export([get_deftype/2]).
+-record(decoding_state,{type_pool = dict:new(), reference_pool = dict:new(),hash_pool = dict:new()}).
+
+%---------------------------------------------------------------------------
+% Decoding
+%---------------------------------------------------------------------------
+decode_str(Rest, 0, R) ->
+ {list_to_binary(xmerl_ucs:to_utf8(lists:reverse(R))), Rest};
+decode_str(<<C/utf8, Rest/binary>>, N, R) ->
+ decode_str(Rest, N-1, [C|R]).
+
+% Call
+decode(<<$H,?M,?m,$C,Bin/binary>>, State) ->
+ {Rest, Function, _State} = decode(Bin,State),
+ {Rest2, Count, __State} = decode(Rest,_State),
+ case decode(list, Rest2,Count,[], __State) of
+ {error, Encoded} ->
+ {error, Encoded};
+ {not_found, Hash} ->
+ {not_found, Hash};
+ {_Rest, Arguments, _NewState} ->
+ [Function, Arguments]
+ end;
+% Fault
+decode(<<$H,?M,?m,$F,
+ Rest/binary>>, State) ->
+ {_Rest,#map{dict=Dict},_State} = decode(Rest, State),
+ {ok, Message} = dict:find(<<"message">>, Dict),
+ {error, Message};
+% Reply
+decode(<<$H,?M,?m,$R,Args/binary>>, State) ->
+ case decode(Args,[], State) of
+ {<<>>, Decoded,_State} ->
+ TypeSet = get_type_set(_State),
+ case Decoded of
+ [Value] ->
+ {Value,TypeSet};
+ [H|T] ->
+ {[H|T],TypeSet}
+ end;
+ {error, Encoded} ->
+ {error, Encoded}
+ end;
+% Binaries
+decode(<<16#20,Rest/binary>>, State) -> {Rest, <<>>, State};
+decode(<<Len:8/unsigned,Rest/binary>>, State) when Len =< 16#2f, 16#20 < Len ->
+ _Len = Len - 16#20,
+ <<Bin:_Len/binary,_Rest/binary>> = Rest,
+ {_Rest, Bin, State};
+decode(<<$B,Len:16/unsigned,Bin:Len/binary,Rest/binary>>, State) -> {Rest, Bin, State};
+decode(<<$b,Rest/binary>>,State) -> decode(<<$b,Rest/binary>>, [], State);
+%% Booleans
+decode(<<$T,Rest/binary>>, State) -> {Rest, true, State};
+decode(<<$F,Rest/binary>>, State) -> {Rest, false, State};
+%% Dates
+decode(<<16#4a,Date:64/unsigned,Rest/binary>>, State) ->
+ MegaSecs = Date div ?MegaSeconds,
+ Secs = (Date - MegaSecs * ?MegaSeconds) div ?Seconds,
+ MicroSecs = (Date - MegaSecs * ?MegaSeconds - Secs * ?Seconds) * ?MicroSeconds,
+ {Rest, {MegaSecs, Secs, MicroSecs}, State};
+decode(<<16#4b,Date:32/unsigned,Rest/binary>>, State) ->
+ MegaSecs = (Date * 60000) div ?MegaSeconds,
+ Secs = (Date * 60000 - MegaSecs * ?MegaSeconds) div ?Seconds,
+ {Rest, {MegaSecs, Secs, 0}, State};
+%% Doubles
+decode(<<16#5b,Rest/binary>>, State)-> {Rest, 0.0, State};
+decode(<<16#5c,Rest/binary>>, State)-> {Rest, 1.0, State};
+decode(<<16#5d,Int:8/signed,Rest/binary>>, State)-> {Rest, float(Int), State};
+decode(<<16#5e,Int:16/signed,Rest/binary>>, State)-> {Rest, float(Int), State};
+decode(<<16#5f,Int:32/signed,Rest/binary>>, State)->
+ <<Double:64/float>> = <<Int:32,0,0,0,0>>,
+ {Rest, Double, State};
+decode(<<$D,Double:64/float,Rest/binary>>, State)-> {Rest, Double, State};
+%% Ints
+decode(<<$I,Int:32/signed,Rest/binary>>, State)-> {Rest, Int, State};
+decode(<<Int:8,Rest/binary>>, State) when Int >= 16#80, Int =< 16#bf -> {Rest, Int - 16#90, State};
+decode(<<B2:8,B1:8,B0:8,Rest/binary>>, State) when B2 >= 16#d0, B2 =< 16#d7 -> {Rest, ((B2 - 16#d4) bsl 16) + (B1 bsl 8) + B0, State};
+decode(<<B1:8,B0:8,Rest/binary>>, State) when B1 >= 16#c0, B1 =< 16#cf -> {Rest, ((B1 - 16#c8) bsl 8) + B0, State};
+%% Longs
+decode(<<$L,Long:64/signed,Rest/binary>>, State)-> {Rest, Long, State};
+decode(<<16#59,Long:32/signed,Rest/binary>>, State) -> {Rest, Long, State};
+decode(<<Long:8,Rest/binary>>, State) when Long >= 16#d8, Long =< 16#ef -> {Rest, Long - 16#e0, State};
+decode(<<B2:8,B1:8,B0:8,Rest/binary>>, State) when B2 >= 16#38, B2 =< 16#3f -> {Rest, ((B2 - 16#3c) bsl 16) + (B1 bsl 8) + B0, State};
+decode(<<B1:8,B0:8,Rest/binary>>, State) when B1 >= 16#f0, B1 =< 16#ff -> {Rest, ((B1 - 16#f8) bsl 8) + B0, State};
+%% Strings
+decode(<<0,Rest/binary>>, State) -> {Rest, <<>>, State};
+decode(<<Len:8,Rest/binary>>, State) when Len < 32 ->
+ {String, NewRest} = decode_str(Rest, Len, []),
+ {NewRest, String, State};
+decode(<<B1:8,B0:8,Rest/binary>>, State) when B1 =< 16#33,B1 >= 16#30 ->
+ Len = ((B1 - 16#30) bsl 8) + B0,
+ {String, NewRest} = decode_str(Rest, Len, []),
+ {NewRest, String, State};
+decode(<<$S,Len:16/unsigned,Rest/binary>>, State) ->
+ {String, NewRest} = decode_str(Rest, Len, []),
+ {NewRest, String, State};
+decode(<<$R,Rest/binary>>, State) -> decode(<<$R,Rest/binary>>,[], State);
+%% Nulls
+decode(<<$N,Rest/binary>>, State) -> {Rest, undefined, State};
+%% References
+decode(<<$Q,Bin/binary>>, State)->
+ {Rest, IntRef, _State} = decode(Bin,State),
+ {Rest, {ref, IntRef}, _State};
+%% Maps
+decode(<<$M,Map/binary>>, State) ->
+ {Rest,Type,_State} = decode(Map, State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = map},_State),
+ {_Rest,Dict, NewState} = decode(map, Rest, dict:new(), __State),
+ {_Rest,#map{refNo=_Refnum,type=Type,dict=Dict},NewState};
+decode(<<$H,Map/binary>>, State) ->
+ {_Refnum,_State} = visit(#type_def{foreign_type = map},State),
+ {_Rest,Dict, NewState} = decode(map, Map, dict:new(), _State),
+ {_Rest,#map{refNo=_Refnum,dict=Dict},NewState};
+%% Lists
+% 'V' type int value* # fixed-length list
+decode(<<$V,Bin/binary>>, State) ->
+ {Rest1,_Type,_State1} = decode(Bin,State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = list},_State1),
+ {Rest2,Len,_State2} = decode(Rest1,__State),
+ {NewRest,List,NewState} = decode(list, Rest2, Len, [], _State2),
+ {NewRest,#list{refNo=_Refnum,len=Len,type=_Type,values=List},NewState};
+% 'X' int value* # fixed-length untyped list
+decode(<<$X,Bin/binary>>, State) ->
+ {Rest1,Len,_State} = decode(Bin,State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = list},_State),
+ {NewRest,List,NewState} = decode(list, Rest1, Len, [], __State),
+ {NewRest,#list{refNo=_Refnum,len=Len,values=List},NewState};
+% [x70-77] type value* # fixed-length typed list
+decode(<<H:5,Len:3,Bin/binary>>, State) when H == 14 ->
+ {Rest1,_Type,_State} = decode(Bin,State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = list},_State),
+ {NewRest,List,NewState} = decode(list, Rest1, Len, [], __State),
+ {NewRest,#list{refNo=_Refnum,len=Len,type=_Type,values=List},NewState};
+% [x78-7f] value* # fixed-length untyped list
+decode(<<H:5,Len:3,Bin/binary>>, State) when H == 15 ->
+ {_Refnum,_State} = visit(#type_def{foreign_type = list},State),
+ {NewRest,List,NewState} = decode(list, Bin, Len, [], _State),
+ {NewRest,#list{refNo=_Refnum,len=Len,values=List},NewState};
+% 'U' type value* 'Z' # variable-length list
+decode(<<$U,Bin/binary>>, State) ->
+ {Rest1,_Type,_State} = decode(Bin,State),
+ {_Refnum,__State} = visit(#type_def{foreign_type = list},_State),
+ {NewRest,List,NewState} = decode(list, Rest1, [], __State),
+ {NewRest,#list{refNo=_Refnum,type=_Type,values=List},NewState};
+% 'W' value* 'Z' # variable-length untyped list
+decode(<<$W,Bin/binary>>, State) ->
+ {_Refnum,_State} = visit(#type_def{foreign_type = list},State),
+ {NewRest,List,NewState} = decode(list, Bin, [], _State),
+ {NewRest,#list{refNo=_Refnum,values=List},NewState};
+decode(<<$C,Bin/binary>>, State0) ->
+ {Rest1,Type,State1} = decode(Bin,State0),
+ {Rest, TypeDef, State} = decode(type_definition,Type,Rest1,State1),
+ NewState = hash_store(TypeDef,State),
+ decode(Rest,NewState);
+decode(<<$O,Bin/binary>>, State) ->
+ {Rest,Ref,_State} = decode(Bin, State),
+ case hash_lookup(Ref, _State) of
+ {not_found, Ref} ->
+ {Rest, {not_found, Ref}, _State};
+ ForeignView ->
+ #type_def{fieldnames = ForeignFieldNames} = ForeignView,
+ {_Refnum,__State} = visit(ForeignView,_State),
+ Count = count_fields(ForeignView),
+ case decode(field, Rest, Count,[], __State) of
+ {not_found,Hash} ->
+ {not_found,Hash};
+ {_Rest,FieldValues, NewState} ->
+ Object = project_native_view(ForeignFieldNames,FieldValues,ForeignView),
+ {_Rest, #object{refNo=_Refnum, typeRef=Ref,values=Object}, NewState}
+ end
+ end;
+decode(<<H:4,Ref:4,Rest/binary>>, _State) when H == 6 ->
+ lager:debug("decode data find ref ~p",[Ref]),
+ case hash_lookup(Ref, _State) of
+ {not_found, Ref} ->
+ {Rest, {not_found, Ref}, _State};
+ ForeignView ->
+ #type_def{fieldnames = ForeignFieldNames} = ForeignView,
+ {_Refnum,__State} = visit(ForeignView,_State),
+ Count = count_fields(ForeignView),
+ case decode(field, Rest, Count,[], __State) of
+ {not_found,Hash} ->
+ {not_found,Hash};
+ {_Rest,FieldValues, NewState} ->
+ Object = project_native_view(ForeignFieldNames,FieldValues,ForeignView),
+ {_Rest, #object{refNo=_Refnum, typeRef=Ref,values=Object}, NewState}
+ end
+ end;
+%% Anything else
+decode(<<Unexpected/binary>>, State) ->
+ {error, hessianEncode:encode(fault, <<"ProtocolException">>, unexpected_byte_sequence, Unexpected, State) }.
+decode(<<$b,Len:16/unsigned,Bin:Len/binary,$b,Rest/binary>>, Acc, State) ->
+ decode(<<$b,Rest/binary>>,Acc ++ [Bin], State);
+decode(<<$b,Len:16/unsigned,Bin:Len/binary,$B,Rest/binary>>, Acc, State) ->
+ _Acc = Acc ++ [Bin],
+ {_Rest,_Bin, State} = decode(<<$B,Rest/binary>>, State),
+ {_Rest, list_to_binary(_Acc ++ [_Bin]), State};
+decode(<<$R,Len:16/unsigned,Rest/binary>>,Acc, State) ->
+ {_String, NewRest} = decode_str(Rest, Len, []),
+ <<H:8,_/binary>> = NewRest,
+ case H of
+ $R -> decode(NewRest,list_to_binary([Acc|[_String]]), State);
+ $S -> {_Rest,_Bin, _State} = decode(NewRest, State),
+ _Acc2 =[Acc |[_String]],
+ {_Rest, list_to_binary(_Acc2 ++ [_Bin]), _State}
+ end;
+decode(<<>>, List, State) -> {<<>>, List, State};
+decode(<<$Z>>, List, State) -> {<<>>, List, State};
+decode(Args, List, State) ->
+ case decode(Args,State) of
+ {Rest,{ref, Ref}, _State} ->
+ decode(Rest, List ++ [{ref, Ref}] , _State);
+ {Rest, [H|T], _State} ->
+ decode(Rest, List ++ [H|T], _State);
+ {Rest, Result, _State} ->
+ decode(Rest, List ++ [Result], _State);
+ {error, Encoded} ->
+ {error, Encoded}
+ end.
+decode(map, <<$Z>>, Dict, State) -> {<<>>,Dict, State};
+decode(map, <<$Z,Rest/binary>>, Dict, State) -> {Rest,Dict, State};
+decode(map, Bin, Dict, State) ->
+ {_Rest, Key, _State} = decode(Bin, State),
+ case decode(_Rest, _State) of
+ {Rest, {ref, Ref}, __State} ->
+ %Value = lists:nth(Ref + 1, List),
+ Value = Ref,
+ decode(map, Rest, dict:store(Key, {ref, Value}, Dict), __State);
+ {Rest, Value, __State} ->
+ decode(map, Rest, dict:store(Key, Value, Dict), __State)
+ end;
+decode(list, <<>>, List, State) -> {<<>>,lists:reverse(List), State};
+decode(list, <<$Z>>, List, State) -> {<<>>,lists:reverse(List), State};
+decode(list, <<$Z,Rest/binary>>, List, State) -> {Rest, lists:reverse(List), State};
+decode(list, Bin, List, State) ->
+ case decode(Bin, State) of
+ {error, Encoded} ->
+ {error, Encoded};
+ {not_found,Hash} ->
+ {not_found, Hash};
+ {_Rest, {not_found, Hash}, _State} ->
+ {not_found, Hash};
+ {Rest, Value, _State} ->
+ decode(list, Rest, [Value|List], _State)
+ end;
+decode(type_definition, ForeignType, Bin, State) ->
+ {Rest,Count, _State} = decode(Bin, State),
+ {NewRest,FieldNames, NewState} = decode(field, Rest, Count, [], _State),
+ {TypeDef,NewState2} = build_foreign_view(ForeignType,FieldNames,NewState),
+ {NewRest, TypeDef, NewState2}.
+decode(list, Bin, 0, List, State) -> {Bin, lists:reverse(List), State};
+decode(list, Bin, Len, List, State) ->
+ case decode(Bin, State) of
+ {error, Encoded} ->
+ {error, Encoded};
+ {not_found,Hash} ->
+ {not_found, Hash};
+ {_Rest, {not_found, Hash}, _State} ->
+ {not_found, Hash};
+ {Rest, Value, _State} ->
+ decode(list, Rest, Len - 1, [Value|List], _State)
+ end;
+decode(field, Rest, 0, Acc, State) -> {Rest, Acc, State};
+decode(field, <<$Z,Rest/binary>>, _Count, Acc, State) -> {Rest, Acc, State};
+decode(field, Bin, Count, Acc, State) ->
+ {Rest,Field, _State} = decode(Bin, State),
+ case Field of
+ {not_found,Hash} ->
+ {not_found,Hash};
+ _ ->
+ decode(field, Rest, Count - 1, Acc ++ [Field], _State)
+ end.
+
+get_type_set(#decoding_state{type_pool = Pool}) ->
+ case dict:to_list(Pool) of
+ [] -> [];
+ Data -> [Value || {_Key,Value} <- Data]
+ end.
+
+build_foreign_view(ForeignType,FieldNames,State) ->
+ lager:debug("[DECODE] build_foreign_view ForeignType ~p FieldNames ~p",[ForeignType,FieldNames]),
+ ForeignView = FieldNames,
+ #decoding_state{type_pool = OldPool} = State,
+ Native = dict:size(OldPool),
+ NewPool = dict:store(Native,
+ #type_def{
+ defineNo = Native,
+%% native_type = Native,
+ foreign_type = ForeignType,
+ fieldnames = ForeignView},
+ OldPool),
+ {
+ #type_def{defineNo = Native,
+%% native_type = Native,
+ foreign_type = ForeignType,
+ fieldnames = ForeignView},
+ State#decoding_state{type_pool = NewPool}
+ }.
+
+project_native_view(ForeignView,ForeignData,
+ #type_def{native_type = _NativeType, foreign_type = _ForeignType, fieldnames = NativeView}) ->
+ AsDict = dict:from_list(lists:zip(ForeignView,ForeignData)),
+ NativeData = [dict:fetch(Key,AsDict) || Key <- NativeView],
+ NativeData.
+
+visit(TypeDef, State = #decoding_state{reference_pool = OldPool}) ->
+ lager:debug("[DECODE] visit typedef ~p",[TypeDef]),
+ Size = dict:size(OldPool),
+ NewPool = dict:store(Size, TypeDef, OldPool),
+ {Size,State#decoding_state{reference_pool = NewPool}}.
+
+hash_lookup(Hash,#decoding_state{hash_pool = HashPool} = State) ->
+ case dict:find(Hash,HashPool) of
+ error->
+ {not_found, Hash};
+ {ok,TypeDef}->
+ TypeDef
+ end.
+%% init(false),
+%% case ets:lookup(hashes, Hash) of
+%% [] ->
+%% {not_found, Hash};
+%% [{Hash,TypeDef}] ->
+%% TypeDef
+%% end.
+
+hash_store(TypeDef = #type_def{defineNo = Hash}, #decoding_state{hash_pool = HashPool} = State) ->
+%% init(false),
+%% ets:insert(hashes,{Hash,TypeDef}),
+ lager:debug("[DECODE] hash store typedef ~p",[TypeDef]),
+ NewPool = dict:store(Hash,TypeDef,HashPool),
+ State#decoding_state{hash_pool = NewPool}.
+
+init() -> init(true).
+
+init(Delete) when is_boolean(Delete) ->
+%% case ets:info(hashes) of
+%% undefined ->
+%% ets:new(hashes,[private,named_table]);
+%% _ ->
+%% if
+%% Delete ->
+%% ets:delete(hashes),
+%% ets:new(hashes,[private,named_table]);
+%% true ->
+%% ok
+%% end
+%% end,
+ #decoding_state{}.
+
+count_fields(#type_def{fieldnames = FieldNames}) -> length(FieldNames).
+
+%% extend func
+get_deftype(Ref,#decoding_state{type_pool = Pool})->
+ dict:fetch(Ref,Pool).
\ No newline at end of file
diff --git a/src/hessianEncode.erl b/src/hessianEncode.erl
new file mode 100755
index 0000000..0b29a9e
--- /dev/null
+++ b/src/hessianEncode.erl
@@ -0,0 +1,577 @@
+-module(hessianEncode).
+
+-include("hessian.hrl").
+
+-export([encode/2, encode/3, encode/4, encode/5]).
+-export([get_value/3, get_value/4]).
+-export([wrap_class/1, encode_for_decode/2,encode_object/3]).
+
+%---------------------------------------------------------------------------
+% Encoding
+%---------------------------------------------------------------------------
+encode_for_decode(Value, [{set,SetInfo},ClassList]) when is_tuple(Value) -> encode(struct, Value, [{set,SetInfo},wrap_class(ClassList)]);
+encode_for_decode(Value, State) when is_tuple(Value) -> encode(struct, Value, wrap_class(State)).
+%---------------------------------------------------------------------------
+% encode/2 <-- ** Entry **
+%---------------------------------------------------------------------------
+
+encode(undefined, _State) -> <<$N>>;
+encode(null, _State) -> <<$N>>;
+encode(true, _State) -> <<$T>>;
+encode(false, _State) -> <<$F>>;
+encode(Value, State) when is_integer(Value) -> encode(int, Value, State);
+encode(Value, State) when is_atom(Value) -> encode(string, erlang:atom_to_binary(Value,utf8), State);
+encode(Value, State) when is_float(Value) -> encode(double, Value, State);
+encode(Value, State) when is_list(Value) -> encode(string, Value, State);
+encode(Value, State) when is_binary(Value) -> encode(string, Value, State);
+encode(Value, State) when is_tuple(Value) -> encode(struct, Value, State).
+%---------------------------------------------------------------------------
+% encode/3
+%---------------------------------------------------------------------------
+encode(struct, Input, State) ->
+ case Input of
+ #list{} -> encode(list, Input, State);
+ #map{} -> encode(map, Input, State);
+ #object{} -> encode(object, Input, State);
+ #class{} -> encode(class_store, Input, State);
+ {binary, Bin} -> encode(binary, Bin, State);
+ {date, Timestamp} -> encode(date, Timestamp, State);
+ {ref, Index} ->
+ IndexBin = encode(int, Index, State),
+ <<$Q, IndexBin/binary>>;
+ _Object ->
+ lager:debug("[encode] object ~p",[Input]),
+ encode(class_object, Input, State);
+%% {<<>>,State};
+ {K, V} ->
+ {BK,SK} = encode(K, State),
+ {BV,SV} = encode(V, SK),
+ {<<BK/binary, BV/binary>>, SV}
+ end;
+encode(int, Int, _State) when Int >= -16, Int =< 47 ->
+ _Int = Int + 16#90,
+ <<_Int:8>>;
+encode(int, Int, _State) when Int >= -2048, Int =< 2047 ->
+ <<B1:8,B0:8>> = <<Int:16>>,
+ _B1 = B1 + 16#c8,
+ <<_B1,B0>>;
+encode(int, Int, _State) when Int >= -262144, Int =< 262143 ->
+ <<B2:8,B1:8,B0:8>> = <<Int:24>>,
+ _B2 = B2 + 16#d4,
+ <<_B2,B1,B0>>;
+encode(int, Int, _State) when Int > -16#80000001, Int < 16#80000000 ->
+ <<$I,Int:32/signed>>;
+encode(int, Int, State) ->
+ encode(long, Int, State);
+encode(long, Long, _State) when Long >= -8, Long =< 15 ->
+ _Long = Long + 16#e0,
+ <<_Long:8>>;
+encode(long, Long, _State) when Long >= -2048, Long =< 2047 ->
+ <<B1:8,B0:8>> = <<Long:16>>,
+ _B1 = B1 + 16#f8,
+ <<_B1,B0>>;
+encode(long, Long, _State) when Long >= -262144, Long =< 262143 ->
+ <<B2:8,B1:8,B0:8>> = <<Long:24>>,
+ _B2 = B2 + 16#3c,
+ <<_B2,B1,B0>>;
+encode(long, Long, _State) when Long > -16#80000001, Long < 16#80000000 ->
+ <<16#59,Long:32/signed>>;
+encode(long, Long, _State) ->
+ <<$L,Long:64/signed>>;
+encode(double, 0.0, _State) ->
+ <<16#5b>>;
+encode(double, 1.0, _State) ->
+ <<16#5c>>;
+encode(double, Double, _State) when Double >= -128.0, Double =< 127.0, Double == round(Double) ->
+ Byte = round(Double),
+ <<16#5d, Byte/signed>>;
+encode(double, Double, _State) when Double >= -32768.0, Double =< 32767.0, Double == round(Double) ->
+ Byte = round(Double),
+ <<16#5e, Byte:16/signed>>;
+encode(double, Double, _State) ->
+ case <<Double/float>> of
+ <<B24,B16,B8,B0,0,0,0,0>> -> <<16#5f,B24,B16,B8,B0>>;
+ Other -> <<$D,Other/binary>>
+ end;
+encode(string, <<>>, _State) ->
+ <<0>>;
+encode(string, [], _State) ->
+ <<0>>;
+encode(string, String, State) when is_list(String)->
+ UTF8 = xmerl_ucs:from_utf8(String),
+ Length = length(UTF8),
+ encode(sub, Length, String, [UTF8|State]);
+encode(string, String, State) when is_binary(String)->
+ encode(string, binary_to_list(String), State);
+encode(binary, <<>>, _State) ->
+ <<16#20>>;
+encode(binary, Value, _State) when size(Value) < 15 ->
+ Size = 16#20 + size(Value),
+ <<Size:8/unsigned,Value/binary>>;
+encode(binary, Value, State) ->
+ encode(binary, Value, <<>>, State);
+encode(date, {MegaSeconds,Seconds,MicroSeconds}, State) ->
+ MilliSeconds = MegaSeconds * ?MegaSeconds + Seconds * ?Seconds + MicroSeconds div ?MicroSeconds,
+ encode(date, MilliSeconds, State);
+encode(date, MilliSeconds, _State) ->
+ MinuteRemain = MilliSeconds rem (?Seconds * 60),
+ case MinuteRemain of
+ 0 ->
+ Minutes = MilliSeconds div (?Seconds * 60),
+ <<16#4b,Minutes:32/unsigned>>;
+ _ -> <<16#4a,MilliSeconds:64/unsigned>>
+ end;
+encode(list, Input, [{set,SetInfo},_T]=State) when is_record(Input, list) ->
+ case find_set_info(Input#list.refNo, SetInfo) of
+ not_found -> encode(list, Input#list.len, Input#list.type, Input#list.values, State);
+ List -> encode(list, List#list.len, List#list.type, List#list.values, State)
+ end;
+encode(list, Input, State) when is_record(Input, list) ->
+ encode(list, Input#list.len, Input#list.type, Input#list.values, State);
+encode(list, List, State) ->
+ ListLength = length(List),
+ encode(fixedlist, ListLength, List, State);
+encode(vlist, List, State) ->
+ case List of
+ [] -> <<$W,$Z>>;
+ _ -> encode(vlist, List, <<$W>>, State)
+ end;
+encode(map, Input, [{set,SetInfo},_T]=State) when is_record(Input, map) ->
+ case find_set_info(Input#map.refNo, Input#map.type, SetInfo) of
+ not_found -> encode(map, Input#map.dict, State);
+ Map -> encode(map, Map#map.dict, State)
+ end;
+encode(map, Input, State) when is_record(Input, map) ->
+ encode(map, Input#map.dict, State);
+encode(map, Dict, State) ->
+ List = dict:to_list(Dict),
+ Encoder = fun({Key, Value}, {AccIn, StateIn}) ->
+ % Key
+ RK = encode(Key, StateIn),
+ {KeyBin, NewStateKey} = case RK of
+ {_, _} -> RK;
+ KeyB -> {KeyB, StateIn}
+ end,
+ % Value
+ RV = encode(Value, NewStateKey),
+ {ValueBin, NewStateValue} = case RV of
+ {_, _} -> RV;
+ ValueB -> {ValueB, NewStateKey}
+ end,
+ % Acc Out
+ {<<AccIn/binary,KeyBin/binary,ValueBin/binary>>, NewStateValue}
+ end,
+ {AccOut, NewState} = lists:foldl(Encoder, {<<$H>>, State}, List),
+ {<<AccOut/binary,$Z>>, NewState};
+encode(class, #class{name=Name, fields=Fields}, State) ->
+ % type
+ NameBin = encode(Name, State),
+ % fields length
+ FieldsLen = length(Fields),
+ FieldsLenBin = encode(int, FieldsLen, State),
+ % fields
+ encode(list, Fields, <<$C,NameBin/binary,FieldsLenBin/binary>>, State);
+encode(class_store, Input, [{set,SetInfo},ClassList]=State) ->
+ {Bin, _} = encode(class, Input, State),
+ {Bin, [{set,SetInfo},[Input#class{encoded=true}|ClassList]]};
+encode(class_store, Input, State) ->
+ {Bin, _} = encode(class, Input, State),
+%% {Bin, [Input#class{encoded=true}|State]};
+ {Bin, State};
+encode(object, Input, [{set,SetInfo},T]=State) when is_record(Input, object) ->
+ ClassRes = class(Input#object.typeRef, Input#object.class, [], T),
+ {BaseBin, TypeNum, C, NewState} = case ClassRes of
+ {encoded, Class, TypeNo} -> {<<>>, TypeNo, Class, State};
+ {Class, TypeNo, NewST} ->
+ {Bin, NewClassST} = encode(class, Class, NewST),
+ {Bin, TypeNo, Class, [{set,SetInfo},NewClassST]}
+ end,
+ case find_set_info(Input#object.refNo, C#class.name, SetInfo) of
+ not_found -> encode(object, BaseBin, TypeNum, Input#object.values, NewState);
+ Obj -> encode(object, BaseBin, TypeNum, Obj#object.values, NewState)
+ end;
+encode(object, Input, State) when is_record(Input, object) ->
+ ClassRes = class(Input#object.typeRef, Input#object.class, [], State),
+
+ {BaseBin, TypeNum, NewState} = case ClassRes of
+ {encoded, _Class, TypeNo} -> {<<>>, TypeNo, State};
+ {Class, TypeNo, NewST} ->
+ {Bin, NewClassST} = encode(class, Class, NewST),
+ {Bin, TypeNo, NewClassST}
+ end,
+ encode(object, BaseBin, TypeNum, Input#object.values, NewState);
+encode(class_object,Input,State)->
+ [NativeType|Values] = tuple_to_list(Input),
+ {ClassEncodingBin, EncodedRef, NewState} =
+ case type_encoding:visit(NativeType,State) of
+ {ref, Ref} ->
+%% encode_object(type_information, {ref, Ref}, State);
+ %% todo 还未验证
+ {<<>>,Ref,State};
+ {hash, Ref, Typedef , State0} ->
+ Class = typedef_to_class(Typedef,Ref),
+ {Bin,NewStateClass} = encode(class_store,Class,State0),
+ {Bin,Ref,NewStateClass}
+%% encode(type_information, {hash, Ref,Typedef }, State0)
+ end,
+ encode(object, ClassEncodingBin, EncodedRef, Values, NewState);
+%% {AccOut, _NewState} = lists:foldl(fun encode/2,{<<>>, NewState},Values),
+%% {<<ClassEncodingBin/binary,$o,EncodedRef/binary,AccOut/binary>>, _NewState};
+
+encode(method, Method, State) when is_atom(Method) ->
+ String = atom_to_list(Method),
+ encode(method, String, State);
+encode(method, Method, _State) when is_binary(Method) ->
+ CamMethod = erlang_to_camel_case(Method),
+ Size = size(CamMethod),
+ <<$m,Size:16/unsigned,CamMethod/binary>>;
+encode(method, String, _State) when is_list(String) ->
+ CamString = erlang_to_camel_case(String),
+ Length = string:len(CamString),
+ Bin = list_to_binary(CamString),
+ <<$m,Length:16/unsigned,Bin/binary>>;
+encode(reply, ok, _State) ->
+ <<$H,16#02,16#00,$R,16#01,$N>>;
+encode(reply, {ok, Object}, State) ->
+ encode(reply, Object, State);
+encode(reply, {error, {Error, Reason} }, State) ->
+ encode(fault, Error, Reason, State);
+encode(reply, Object, State) ->
+ case encode(Object, State) of
+ {Bin, _NewState} -> Bin;
+ Bin -> Bin
+ end,
+ <<$H,16#02,16#00,$R,Bin/binary>>.
+%---------------------------------------------------------------------------
+% encode/4
+%---------------------------------------------------------------------------
+encode(sub, Length, String, _State) when Length < 32 ->
+ Bin = list_to_binary(String),
+ <<Length:8,Bin/binary>>;
+encode(sub, Length, String, _State) when Length < 256 ->
+ Bin = list_to_binary(String),
+ <<16#30,Length:8,Bin/binary>>;
+encode(sub, Length, String, _State) when Length < 512 ->
+ Bin = list_to_binary(String),
+ <<16#31,(Length-256):8,Bin/binary>>;
+encode(sub, Length, String, _State) when Length < 768 ->
+ Bin = list_to_binary(String),
+ <<16#32,(Length-512):8,Bin/binary>>;
+encode(sub, Length, String, _State) when Length < ?CHUNK_SIZE ->
+ Bin = list_to_binary(String),
+ <<16#33,(Length-768):8,Bin/binary>>;
+encode(sub, Length, String, _State) when Length =:= ?CHUNK_SIZE ->
+ Bin = list_to_binary(String),
+ <<$S,Length:16,Bin/binary>>;
+encode(sub, Length, _String, [UTF8|State]) ->
+ encode(string, Length, UTF8, <<>>, State);
+encode(binary, Value, <<>>, _State) when size(Value) =< ?CHUNK_SIZE ->
+ Size = size(Value),
+ <<$B,Size:16,Value/binary>>;
+encode(binary, Value, Acc, _State) when size(Value) =< ?CHUNK_SIZE ->
+ Size = size(Value),
+ <<Acc/binary,$B,Size:16,Value/binary>>;
+encode(binary, Value, <<>>, State) ->
+ <<Chunk:?CHUNK_SIZE/binary,Rest/binary>> = Value,
+encode(binary, Rest, <<$b,?CHUNK_SIZE:16,Chunk/binary>>, State);
+encode(binary, Value, Acc, State) ->
+ <<Chunk:?CHUNK_SIZE/binary,Rest/binary>> = Value,
+ encode(binary, Rest, <<Acc/binary,$b,?CHUNK_SIZE:16,Chunk/binary>>, State);
+encode(list, List, Acc0, State) when is_binary(Acc0) ->
+ lists:foldl(fun encode_accumulate/2, {Acc0,State}, List);
+encode(list, Type, List, State) ->
+ ListLength = length(List),
+ encode(list, ListLength, Type, List, State);
+encode(vlist, List, Acc0, State) when is_binary(Acc0) ->
+ {AccOut, NewState} = lists:foldl(fun encode_accumulate/2, {Acc0,State}, List),
+ {<<AccOut/binary,$Z>>, NewState};
+encode(vlist, Type, List, State) ->
+ TypeBin = encode(Type, State),
+ case List of
+ [] -> <<$U,TypeBin/binary,$Z>>;
+ _ -> encode(vlist, List, <<$U,TypeBin/binary>>, State)
+ end;
+encode(fixedlist, ListLength, List, State) ->
+ case ListLength < 8 of
+ true ->
+ ListLengthFlag = 16#78 + ListLength,
+ case List of
+ [] -> <<ListLengthFlag:8>>;
+ _ -> encode(list, List, <<ListLengthFlag:8>>, State)
+ end;
+ false ->
+ ListLengthBin = encode(int, ListLength, State),
+ encode(list, List, <<$X,ListLengthBin/binary>>, State)
+ end;
+encode(fault, _Error, _Reason, State) ->
+ encode(fault, <<"ServiceException">>, _Error, _Reason, State);
+encode(call, Method, Args, State) ->
+ encode(call, Method, Args, fun encode_accumulate/2, State).
+%---------------------------------------------------------------------------
+% encode/5
+%---------------------------------------------------------------------------
+encode(string, Length, UTF8, Acc, _State) when Length =< ?CHUNK_SIZE ->
+ Bin = list_to_binary(xmerl_ucs:to_utf8(UTF8)),
+ <<Acc/binary,$S,Length:16,Bin/binary>>;
+encode(string, Length, UTF8, Acc, State) ->
+ {Chunk, Rest} = lists:split(?CHUNK_SIZE, UTF8),
+ ChunkBin = list_to_binary(xmerl_ucs:to_utf8(Chunk)),
+ encode(string, (Length-?CHUNK_SIZE), Rest, <<Acc/binary,$R,?CHUNK_SIZE:16,ChunkBin/binary>>, State);
+encode(list, -1, untyped, List, State) ->
+ encode(vlist, List, State);
+encode(list, -1, Type, List, State) ->
+ encode(vlist, Type, List, State);
+encode(list, Len, untyped, List, State) ->
+ encode(fixedlist, Len, List, State);
+encode(list, Len, Type, List, State) ->
+ TypeBin = encode(Type, State),
+ if
+ Len < 8 ->
+ ListLengthFlag = 16#70 + Len,
+ case List of
+ [] -> <<ListLengthFlag:8,TypeBin/binary>>;
+ _ -> encode(list, List, <<ListLengthFlag:8,TypeBin/binary>>, State)
+ end;
+ true ->
+ ListLengthBin = encode(int, Len, State),
+ encode(list, List, <<$V,TypeBin/binary,ListLengthBin/binary>>, State)
+ end;
+encode(object, BaseBin, TypeNo, Values, State) ->
+ IndexBin = if
+ TypeNo < 16 ->
+ lager:debug("[encode] encode object TypeNo ~p",[TypeNo]),
+ IndexWrap = TypeNo + 16#60,
+ <<IndexWrap:8>>;
+ true ->
+ IndexWrap = encode(int, TypeNo, State),
+ <<$O, IndexWrap/binary>>
+ end,
+ {Bin, NewState} = encode(list, Values, IndexBin, State),
+ {<<BaseBin/binary,Bin/binary>>, NewState};
+encode(call, Method, Args, Fun, State) when is_function(Fun) ->
+ MethodBin = encode(string, Method, State),
+ ArgsCount = encode(int, erlang:length(Args), State),
+ {Bin, _NewState} = lists:foldl(Fun, {<<>>, State}, Args),
+ <<$H,2,0,$C,MethodBin/binary,ArgsCount/binary,Bin/binary>>;
+encode(fault, Code, _Error, _Reason, State) ->
+ EncodedCode = encode(string,Code, State),
+ <<131,100,_L2:16/unsigned,Error/binary>> = term_to_binary(_Error),
+ EncodedError = encode(string,Error, State),
+ <<$H,16#02,16#00,$F,$H,4,"code",EncodedCode/binary,7,"message",EncodedError/binary,6,"detail",31,"Stack trace not yet implemented",$Z>>.
+
+%---------------------------------------------------------------------------
+% Utility methods
+%---------------------------------------------------------------------------
+erlang_to_camel_case(String) when is_binary(String) ->
+ AsList = binary_to_list(String),
+ AsCamel = lists:foldl(fun camelize/2,[],AsList),
+ list_to_binary(AsCamel);
+erlang_to_camel_case(String) when is_atom(String) ->
+ AsList = atom_to_list(String),
+ AsCamel = lists:foldl(fun camelize/2,[],AsList),
+ list_to_binary(AsCamel).
+
+camelize(Element,Acc) when Element == $_ -> [$_|Acc];
+camelize(Element,[$_|Acc]) -> lists:append(Acc,[Element - 16#20]);
+camelize(Element,Acc) -> lists:append(Acc,[Element]).
+
+encode_accumulate(Value, {Acc, State}) ->
+ lager:debug("[encode] encode_accumulate value ~p",[Value]),
+ case encode(Value, State) of
+ {Encoded,NewState} -> {<<Acc/binary,Encoded/binary>>,NewState};
+ Encoded -> {<<Acc/binary,Encoded/binary>>,State}
+ end.
+
+find_set_info(RefNo, SetInfo) ->
+ find_set_info(RefNo, untyped, SetInfo).
+find_set_info(_RefNo, _Type, []) ->
+ not_found;
+find_set_info(RefNo, Type, [Set|SetInfo]) ->
+ if
+ RefNo =:= Set#set.ref -> Set#set.value;
+ true ->
+ case equal(Type, Set#set.ref) of
+ true -> Set#set.value;
+ false -> find_set_info(RefNo, Type, SetInfo)
+ end
+ end.
+
+type_index(Type, [CurrentType|RestTypes]) when is_record(Type, class) ->
+ case equal(Type#class.name, CurrentType#class.name) of
+ true -> length(RestTypes);
+ false -> type_index(Type, RestTypes)
+ end;
+type_index(Type, [CurrentType|RestTypes]) ->
+ case equal(Type, CurrentType#class.name) of
+ true -> length(RestTypes);
+ false -> type_index(Type, RestTypes)
+ end.
+
+get_class(Where, ClassList) ->
+ SortClassList = lists:reverse(ClassList),
+ case Where#object.typeRef of
+ -1 ->
+ if
+ Where#object.class =:= auto -> hd(ClassList);
+ true ->
+ Index = type_index(Where#object.class, ClassList),
+ lists:nth(Index+1, SortClassList)
+ end;
+ TypeRef ->
+ lists:nth(TypeRef+1, SortClassList)
+ end.
+
+get_type_no(C, RestClasses) when is_record(C, class) ->
+ case C#class.typeNo of
+ -1 -> length(RestClasses);
+ _ -> C#class.typeNo
+ end.
+
+get_type(CListH, C, CListE) when is_record(C, class) ->
+ TypeNo = get_type_no(C, CListE),
+ case C#class.encoded of
+ true -> {encoded, C, TypeNo};
+ false -> {C, TypeNo, CListH++[C#class{encoded=true}|CListE]}
+ end.
+
+class(-1, auto, [], [C|CListE]) ->
+ get_type([], C, CListE);
+class(-1, Class, CListH, [C|CListE]) when is_record(Class, class) ->
+ case Class#class.name of
+ auto ->
+ case CListH of
+ [] -> get_type([], C, CListE);
+ [H|T] ->get_type([], H, T++[C|CListE])
+ end;
+ _ ->
+ case equal(Class#class.name, C#class.name) of
+ true -> get_type(CListH, C, CListE);
+ false -> class(-1, Class, CListH++[C], CListE)
+ end
+ end;
+class(-1, Class, CListH, [C|CListE]) ->
+ case equal(Class, C#class.name) of
+ true -> get_type(CListH, C, CListE);
+ false -> class(-1, Class, CListH++[C], CListE)
+ end;
+class(RefNo, _Class, CListH, [C|CListE]) ->
+ if
+ RefNo =:= length(CListE) -> get_type(CListH, C, CListE);
+ true -> class(RefNo, _Class, CListH++[C], CListE)
+ end.
+
+equal(S1, S2) when is_binary(S1) ->
+ if
+ S1 =:= S2 -> true;
+ true ->
+ S1List = binary_to_list(S1),
+ if
+ S1List =:= S2 -> true;
+ true -> false
+ end
+ end;
+equal(S1, S2) when is_list(S1) ->
+ if
+ S1 =:= S2 -> true;
+ true ->
+ S1Binary = list_to_binary(S1),
+ if
+ S1Binary =:= S2 -> true;
+ true -> false
+ end
+ end;
+equal(_S1, _S2) ->
+ false.
+
+wrap_class(ClassList) ->
+ Fun = fun(OldClass, AccIn) ->
+ [#class{typeNo=OldClass#type_def.native_type, name=OldClass#type_def.foreign_type, fields=OldClass#type_def.fieldnames}|AccIn]
+ end,
+ lists:foldl(Fun, [], ClassList).
+
+get_value(Where, Ref, Field) ->
+ get_value(Where, Ref, Field, [], []).
+get_value(Where, Ref, Field, ClassList) ->
+ get_value(Where, Ref, Field, wrap_class(ClassList), []).
+get_value(Where, Ref, Field, ClassList, ObjVlues) when is_record(Where, list) ->
+ get_value(Where#list.values, Ref, Field, ClassList, ObjVlues);
+get_value(Where, Ref, Field, ClassList, _ObjVlues) when is_record(Where, map) ->
+ List = dict:to_list(Where#map.dict),
+ get_value(List, Ref, Field, ClassList, Where#map.refNo);
+get_value(Where, _Ref, _Field, ClassList, _ObjVlues) when is_record(Where, type_def) ->
+ {class, [#class{typeNo=Where#type_def.native_type, name=Where#type_def.foreign_type, fields=Where#type_def.fieldnames}|ClassList]};
+get_value(Where, _Ref, _Field, ClassList, _ObjVlues) when is_record(Where, class) ->
+ {class, [Where|ClassList]};
+get_value(Where, Ref, Field, ClassList, _ObjVlues) when is_record(Where, object) ->
+ Class = get_class(Where, ClassList),
+ if
+ Where#object.refNo =:= Ref -> get_value(Class#class.fields, Ref, Field, ClassList, Where#object.values);
+ Class =:= Ref -> get_value(Class#class.fields, Ref, Field, ClassList, Where#object.values);
+ true ->
+ case equal(Class#class.name, Ref) of
+ true -> get_value(Class#class.fields, Ref, Field, ClassList, Where#object.values);
+ false -> get_value(Where#object.values, Ref, Field, ClassList, skip)
+ end
+ end;
+get_value(Where, _RefNo, _Field, _ClassList, skip) when is_binary(Where) ->
+ next;
+get_value(Where, _RefNo, Field, _ClassList, Value) when is_binary(Where) ->
+ case equal(Where, Field) of
+ true -> {return, Value};
+ false -> next
+ end;
+get_value(Where, _RefNo, _Field, _ClassList, _Value) when is_atom(Where) ->
+ next;
+get_value(Where, _RefNo, _Field, _ClassList, _Value) when is_integer(Where) ->
+ next;
+get_value({ref, _No}, _RefNo, _Field, _ClassList, _ObjVlues) ->
+ next;
+get_value({K, V}, RefNo, Field, ClassList, MapRefNo) ->
+ case is_binary(K) of
+ true ->
+ if
+ RefNo =/= MapRefNo -> R = next;
+ true -> R = get_value(K, RefNo, Field, ClassList, V)
+ end;
+ false -> R = get_value(K, RefNo, Field, ClassList, [])
+ end,
+ case R of
+ next -> get_value(V, RefNo, Field, ClassList, []);
+ _ -> R
+ end;
+get_value([], _RefNo, _Field, _ClassList, _ObjVlues) ->
+ not_found;
+get_value([CurrentField|Fields], RefNo, Field, ClassList, [Value|Values]) ->
+ R = get_value(CurrentField, RefNo, Field, ClassList, Value),
+ case R of
+ {return, _} -> R;
+ {class, NewClassList} -> get_value(Fields, RefNo, Field, NewClassList, Values);
+ _ -> get_value(Fields, RefNo, Field, ClassList, Values)
+ end;
+get_value([Item|T], RefNo, Field, ClassList, Option)->
+ R = get_value(Item, RefNo, Field, ClassList, Option),
+ case R of
+ {return, _} -> R;
+ {class, NewClassList} -> get_value(T, RefNo, Field, NewClassList, Option);
+ _ -> get_value(T, RefNo, Field, ClassList, Option)
+ end.
+
+encode_object(object, Object, State) when is_tuple(Object) ->
+ [NativeType|Values] = tuple_to_list(Object),
+ {TypeEncoding, EncodedRef, NewState} =
+ case type_encoding:visit(NativeType,State) of
+ {ref, Ref} ->
+ encode_object(type_information, {ref, Ref}, State);
+ {hash, Hash, Ref, State0} ->
+ encode(type_information, {hash, Hash, Ref}, State0)
+ end,
+ {AccOut, _NewState} = lists:foldl(fun encode/2,{<<>>, NewState},Values),
+ {<<TypeEncoding/binary,$o,EncodedRef/binary,AccOut/binary>>, _NewState};
+encode_object(type_information, {ref, Ref}, State) ->
+ {<<>>, encode(int, Ref, State), State};
+encode_object(type_information, {hash, Hash, Ref}, State) ->
+ EncodedRef = encode(int, Ref, State),
+ {<<$O,Hash:32/unsigned>>, EncodedRef, State}.
+
+typedef_to_class(Typedef,DefineNo)->
+ #class{typeNo=DefineNo, name=Typedef#type_def.foreign_type, fields=Typedef#type_def.fieldnames}.
\ No newline at end of file
diff --git a/src/java_type_defined.erl b/src/java_type_defined.erl
new file mode 100644
index 0000000..b4eda9e
--- /dev/null
+++ b/src/java_type_defined.erl
@@ -0,0 +1,21 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 09. Mar 2018 11:06 PM
+%%%-------------------------------------------------------------------
+-module(java_type_defined).
+-author("dlive").
+
+-include("java_type.hrl").
+%% API
+-export([get_list/0]).
+
+
+get_list()->
+ [
+ {null_pointer_exception,<<"java.lang.NullPointerException">>,record_info(fields,null_pointer_exception)},
+ {stack_stack_trace_element,<<"java.lang.StackTraceElement">>,record_info(fields,stack_stack_trace_element)}
+ ].
\ No newline at end of file
diff --git a/src/lists_util.erl b/src/lists_util.erl
new file mode 100644
index 0000000..fec6cf0
--- /dev/null
+++ b/src/lists_util.erl
@@ -0,0 +1,43 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2017, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 27. Dec 2017 6:09 PM
+%%%-------------------------------------------------------------------
+-module(lists_util).
+-author("dlive").
+
+%% API
+-export([join/2,del_duplicate/1]).
+
+-spec(join(List :: list(), Separator :: binary()) -> binary()).
+join(List, _Separator) when length(List) == 0 ->
+ <<"">>;
+join(List, Separator) ->
+ [First | Rst] = List,
+ Acc2 = lists:foldl(fun(Item, Acc) ->
+ if
+ is_binary(Item) ->
+ <<Acc/binary, Separator/binary, Item/binary>>;
+ is_list(Item) ->
+ Item2 = list_to_binary(Item),
+ <<Acc/binary, Separator/binary, Item2/binary>>;
+ true ->
+ Acc
+ end
+ end, First, Rst),
+ Acc2.
+
+
+del_duplicate(List) ->
+ lists:foldl(
+ fun(X, List2) ->
+ case lists:member(X, List2) of
+ true ->
+ List2;
+ _ ->
+ [X]++ List2
+ end
+ end, [], List).
diff --git a/src/request_context.erl b/src/request_context.erl
new file mode 100644
index 0000000..ea9da32
--- /dev/null
+++ b/src/request_context.erl
@@ -0,0 +1,117 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 23. May 2018 4:28 PM
+%%%-------------------------------------------------------------------
+-module(request_context).
+-author("dlive").
+
+%%-define(PER_LOG,true).
+-define(PER_LOG,false).
+
+%% API
+-export([init/0,init/1,update/2,update/3,to_log/1,test/0,trace/1,trace_end/1]).
+
+init()->
+ case ?PER_LOG of
+ true->
+ #{<<"t_b">> => time_util:timestamp_ms()};
+ _->
+ #{}
+ end.
+init(ID)->
+ case ?PER_LOG of
+ true->
+ #{<<"id">> =>ID,<<"t_b">> => time_util:timestamp_ms()};
+ _->
+ #{<<"id">> =>ID}
+ end.
+
+update(Key,Map)->
+ case ?PER_LOG of
+ true->
+ Map#{Key=>time_util:timestamp_ms()};
+ _->
+ Map
+ end.
+
+update(Key,Value,Map)->
+ Map#{Key=>Value}.
+
+to_log(Map)->
+ case ?PER_LOG of
+ true->
+ to_log2(Map);
+ _->
+ ok
+ end.
+
+to_log2(Map)->
+
+ #{
+ <<"t_b">> := Begin,
+ <<"t_lb">> := LoadBalance,
+ <<"t_send_agent">> := SendAgent,
+ <<"t_agent_b">> := AgentBegin,
+ <<"t_agent_e">> := AgentEnd,
+ <<"t_net_b">> := NetBegin,
+%% <<"t_net_bd">> := NetBeginDecode,
+ <<"t_net_e">> := NetEnd,
+ <<"t_backer_b">> := BackerBegin,
+ <<"t_backer_e1">> := BackerGet,
+ <<"t_backer_e">> := BackerEnd,
+ <<"t_gate_back">> := GateWayBack,
+%% <<"t_e">> := End,
+ <<"t_nd">> :=Node
+ } = Map,
+ Total=GateWayBack-Begin,
+ if
+ Total > 90 ->
+ performance:warning("total ~-5.10B lb ~-5.10B to_send ~-5.10B agent_b ~-5.10B agent_e ~-5.10B net_b ~-5.10B net_e ~-5.10B backer_b ~-5.10B backer_e1 ~-5.10B backer_e ~-5.10B gw_b ~-5.10B ~p",
+ [
+ Total,
+ LoadBalance - Begin,
+ SendAgent-Begin,
+ AgentBegin-SendAgent,
+ AgentEnd-AgentBegin,
+ NetBegin-AgentEnd,
+ NetEnd-NetBegin,
+ BackerBegin-NetEnd,
+ BackerGet-BackerBegin,
+ BackerEnd-BackerBegin,
+ GateWayBack-BackerEnd,
+%% End-GateWayBack,
+ Node
+ ]);
+ true->
+ performance:info("total ~-5.10B lb ~-5.10B to_send ~-5.10B agent_b ~-5.10B agent_e ~-5.10B net_b ~-5.10B net_e ~-5.10B backer_b ~-5.10B backer_e1 ~-5.10B backer_e ~-5.10B gw_b ~-5.10B ~p",
+ [
+ Total,
+ LoadBalance - Begin,
+ SendAgent-Begin,
+ AgentBegin-SendAgent,
+ AgentEnd-AgentBegin,
+ NetBegin-AgentEnd,
+ NetEnd-NetBegin,
+ BackerBegin-NetEnd,
+ BackerGet-BackerBegin,
+ BackerEnd-BackerBegin,
+ GateWayBack-BackerEnd,
+%% End-GateWayBack,
+ Node
+ ])
+ end.
+
+trace(Info)->
+%% gen_server:cast({monitor_trace,'monitor@agent_monitor.me'},{trace,Info}).
+ ok.
+
+trace_end(Info)->
+%% gen_server:cast({monitor_trace,'monitor@agent_monitor.me'},{trace_end,Info}).
+ ok.
+
+test()->
+ lager:error("a~-10.5sb",[123]).
\ No newline at end of file
diff --git a/src/time_util.erl b/src/time_util.erl
new file mode 100644
index 0000000..b6bda7a
--- /dev/null
+++ b/src/time_util.erl
@@ -0,0 +1,154 @@
+
+
+
+-module(time_util).
+
+-include_lib("kernel/include/file.hrl").
+
+
+-export([
+ get_cur_time/0,get_cur_time/1,
+ format_time_to_str/1,
+ timestamp/0,timestamp_ms/0,
+ timestamp_to_datetime/1,
+ timestamp_to_local_datetime/1,
+ get_cur_date/0,
+ datetime_to_timestamp/1,
+ datetime_string_to_timestamp/1,get_curdate_timestamp/0]).
+
+
+get_cur_time()->
+ {{Year,Month,Day},{Hour,Min,Second}}=calendar:now_to_local_time(os:timestamp()),
+ io_lib:format("~4..0w-~2..0w-~2..0w ~2..0w:~2..0w:~2..0w",[Year, Month, Day, Hour,Min,Second]).
+
+get_cur_date()->
+ {{Year,Month,Day},{Hour,Min,Second}}=calendar:now_to_local_time(os:timestamp()),
+ io_lib:format("~4..0w-~2..0w-~2..0w",[Year, Month, Day]).
+
+get_cur_time({{Year,Month,Day},{Hour,Min,Second}})->
+ io_lib:format("~4..0w-~2..0w-~2..0w ~2..0w:~2..0w:~2..0w",[Year, Month, Day, Hour,Min,Second]).
+
+format_time_to_str({{Year,Month,Day},{Hour,Min,Second}})->
+ io_lib:format("~4..0w-~2..0w-~2..0w ~2..0w:~2..0w:~2..0w",[Year, Month, Day, Hour,Min,Second]).
+
+timestamp() ->
+ {M, S, _} = os:timestamp(),
+ M * 1000000 + S.
+timestamp_ms()->
+ {M,S,W} = os:timestamp(),
+ M*1000000000+S*1000+(W div 1000).
+
+timestamp_to_datetime(Timestamp) ->
+ calendar:gregorian_seconds_to_datetime(Timestamp +
+ calendar:datetime_to_gregorian_seconds({{1970,1,1}, {0,0,0}})).
+timestamp_to_local_datetime(Timestamp) ->
+ Date=calendar:gregorian_seconds_to_datetime(Timestamp +
+ calendar:datetime_to_gregorian_seconds({{1970,1,1}, {0,0,0}})),
+ calendar:universal_time_to_local_time(Date).
+
+%% @doc 时间转时间戳
+datetime_to_timestamp(Date)->
+ [{D,T}]=calendar:local_time_to_universal_time_dst(Date),
+ S = calendar:datetime_to_gregorian_seconds({D, T}),
+ S1 = calendar:datetime_to_gregorian_seconds({{1970, 1, 1}, {0, 0, 0}}),
+ Seconds = (S - S1).
+ % {Seconds div 1000000, Seconds rem 1000000, MS}.
+
+%% @doc 时间字符串转 时间戳
+datetime_string_to_timestamp(TimeStr) ->
+ case catch parse_datetime(TimeStr) of
+ {'EXIT', _Err} ->
+ undefined;
+ TimeStamp ->
+ TimeStamp
+ end.
+
+parse_datetime(TimeStr) ->
+ [Date, Time] = string:tokens(TimeStr, "T"),
+ D = parse_date(Date),
+ {T, MS, TZH, TZM} = parse_time(Time),
+ S = calendar:datetime_to_gregorian_seconds({D, T}),
+ S1 = calendar:datetime_to_gregorian_seconds({{1970, 1, 1}, {0, 0, 0}}),
+ Seconds = (S - S1) - TZH * 60 * 60 - TZM * 60,
+ {Seconds div 1000000, Seconds rem 1000000, MS}.
+
+% yyyy-mm-dd
+parse_date(Date) ->
+ [Y, M, D] = string:tokens(Date, "-"),
+ Date1 = {list_to_integer(Y), list_to_integer(M), list_to_integer(D)},
+ case calendar:valid_date(Date1) of
+ true ->
+ Date1;
+ _ ->
+ false
+ end.
+
+% hh:mm:ss[.sss]TZD
+parse_time(Time) ->
+ case string:str(Time, "Z") of
+ 0 ->
+ parse_time_with_timezone(Time);
+ _ ->
+ [T | _] = string:tokens(Time, "Z"),
+ {TT, MS} = parse_time1(T),
+ {TT, MS, 0, 0}
+ end.
+
+parse_time_with_timezone(Time) ->
+ case string:str(Time, "+") of
+ 0 ->
+ case string:str(Time, "-") of
+ 0 ->
+ false;
+ _ ->
+ parse_time_with_timezone(Time, "-")
+ end;
+ _ ->
+ parse_time_with_timezone(Time, "+")
+ end.
+
+parse_time_with_timezone(Time, Delim) ->
+ [T, TZ] = string:tokens(Time, Delim),
+ {TZH, TZM} = parse_timezone(TZ),
+ {TT, MS} = parse_time1(T),
+ case Delim of
+ "-" ->
+ {TT, MS, -TZH, -TZM};
+ "+" ->
+ {TT, MS, TZH, TZM}
+ end.
+
+parse_timezone(TZ) ->
+ [H, M] = string:tokens(TZ, ":"),
+ {[H1, M1], true} = check_list([{H, 12}, {M, 60}]),
+ {H1, M1}.
+
+parse_time1(Time) ->
+ [HMS | T] = string:tokens(Time, "."),
+ MS = case T of
+ [] ->
+ 0;
+ [Val] ->
+ list_to_integer(string:left(Val, 6, $0))
+ end,
+ [H, M, S] = string:tokens(HMS, ":"),
+ {[H1, M1, S1], true} = check_list([{H, 24}, {M, 60}, {S, 60}]),
+ {{H1, M1, S1}, MS}.
+
+check_list(List) ->
+ lists:mapfoldl(
+ fun({L, N}, B)->
+ V = list_to_integer(L),
+ if
+ (V >= 0) and (V =< N) ->
+ {V, B};
+ true ->
+ {false, false}
+ end
+ end, true, List).
+%% @doc 获取当天零点时间戳
+get_curdate_timestamp()->
+ {M, S, T} = os:timestamp(),
+ TimestampTmp = M * 1000000 + S,
+ {{Year,Month,Day},{Hour,Min,Second}}=calendar:now_to_local_time({M, S, T}),
+ TimestampTmp - Second -(Hour*60+Min)*60.
\ No newline at end of file
diff --git a/src/type_decoding.erl b/src/type_decoding.erl
new file mode 100644
index 0000000..343725e
--- /dev/null
+++ b/src/type_decoding.erl
@@ -0,0 +1,214 @@
+% ---------------------------------------------------------------------------
+% Copyright (C) 2008 0x6e6562
+%
+% Licensed under the Apache License, Version 2.0 (the "License");
+% you may not use this file except in compliance with the License.
+% You may obtain a copy of the License at
+%
+% http://www.apache.org/licenses/LICENSE-2.0
+%
+% Unless required by applicable law or agreed to in writing, software
+% distributed under the License is distributed on an "AS IS" BASIS,
+% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+% See the License for the specific language governing permissions and
+% limitations under the License.
+% ---------------------------------------------------------------------------
+
+-module(type_decoding).
+-include("hessian.hrl").
+
+%% The encoding state contains all of the statically known tuple types.
+%% When a tuple is to be decoded at run-time, a lookup is performed against
+%% the hash value that the sender passes in.
+%% This must resolve to some type definition,
+%% otherwise no instance of the decoded type can be created.
+-record(decoding_state,{type_pool = dict:new(), reference_pool = dict:new(),obj_define_no=0}).
+
+-export([init/0,init/1]).
+-export([lookup_reference/2]).
+-export([enlist/1,enlist/2]).
+-export([hash_lookup/2,hash_store/2,hash_store/1,store_typepool/1]).
+-export([visit/2]).
+-export([resolve_native_type/2,resolve_native_type/1]).
+-export([camel_case_to_erlang/1]).
+-export([build_foreign_view/3]).
+-export([project_native_view/3]).
+
+-define(TYPEPOOL_TABLE,type_pool).
+-define(REFERENCEPOOL_TABLE,reference_pool).
+
+camel_case_to_erlang(String) when is_binary(String) ->
+ AsList = binary_to_list(String),
+ AsErlang = lists:foldl(fun decamelize/2,[],AsList),
+ list_to_atom(AsErlang).
+
+decamelize(Element,Acc) when Element >= $A, Element =< $Z ->
+ lists:append(Acc,[$_,(Element + 16#20)] );
+decamelize(Element,Acc) -> lists:append(Acc,[Element]).
+
+%% Facility to register a particular type to the pool of known types.
+%% Adds the type to the pool of known types if it doesn't already exist.
+enlist(TypeDef) -> enlist(TypeDef,init()).
+enlist(TypeDef = #type_def{foreign_type = Key},
+ State = #decoding_state{type_pool = OldPool}) ->
+ ets:insert(?TYPEPOOL_TABLE,{Key,TypeDef}),
+ State.
+
+store_typepool(TypeDef = #type_def{foreign_type = Key}) ->
+ ets:insert(?TYPEPOOL_TABLE,{Key,TypeDef}),
+ TypeDef.
+
+
+
+build_foreign_view(ForeignType,FieldNames,State) ->
+ #type_def{native_type = Native} = resolve_native_type(ForeignType,State),
+ ForeignView = [camel_case_to_erlang(Fieldname) || Fieldname <- FieldNames],
+ DefineNo = State#decoding_state.obj_define_no,
+ {#type_def{
+ defineNo = State#decoding_state.obj_define_no,
+ native_type = Native,
+ foreign_type = ForeignType,
+ fieldnames = ForeignView}, State#decoding_state{obj_define_no = DefineNo}}.
+
+% Projects the native view over tuples that in foreign order
+project_native_view(ForeignView,ForeignData,
+ #type_def{native_type = NativeType, fieldnames = NativeView}) ->
+ AsDict = dict:from_list(lists:zip(ForeignView,ForeignData)),
+ NativeData = [dict:fetch(Key,AsDict) || Key <- NativeView],
+ list_to_tuple( [NativeType] ++ NativeData).
+
+resolve_native_type(ForeignType, #decoding_state{type_pool = Pool}) ->
+ case ets:lookup(?TYPEPOOL_TABLE,ForeignType) of
+ []->
+ throw({cannot_resolve_type,ForeignType});
+ [{ForeignType,TypeDef}]->
+ TypeDef
+ end.
+resolve_native_type(ForeignType) ->
+ case ets:lookup(?TYPEPOOL_TABLE,ForeignType) of
+ []->
+ undefined;
+ [{ForeignType,TypeDef}]->
+ TypeDef
+ end.
+%% case dict:fetch(ForeignType,Pool) of
+%% error ->
+%% throw({cannot_resolve_type,ForeignType});
+%% TypeDef ->
+%% TypeDef
+%% end.
+
+%% Creates a reference for a type def that is unique within the
+%% current invocation context
+visit(TypeDef, State = #decoding_state{reference_pool = OldPool}) ->
+ Size=ets:info(?REFERENCEPOOL_TABLE,size),
+ ets:insert(?REFERENCEPOOL_TABLE,{Size,TypeDef#type_def{defineNo = Size}}),
+ State.
+%% Size = dict:size(OldPool),
+%% NewPool = dict:store(Size, TypeDef, OldPool),
+%% State#decoding_state{reference_pool = NewPool}.
+
+%% Resolves a type def based on a reference that must be have set
+%% with the current invocation context
+lookup_reference(Ref, #decoding_state{reference_pool = Pool}) ->
+ case ets:lookup(?REFERENCEPOOL_TABLE,Ref) of
+ []->
+ throw("Lookup of unknown reference");
+ [{Ref,TypeDef}]->
+ TypeDef
+ end.
+ %?LOG(Pool),
+ %?LOG(Ref),
+%% case dict:fetch(Ref,Pool) of
+%% error ->
+%%%% ?ERROR(Ref, Pool),
+%% throw("Lookup of unknown reference");
+%% TypeDef ->
+%% TypeDef
+%% end.
+
+%% Does what it says on the tin.
+hash_lookup(Hash,_State) ->
+%% init(false),
+ case ets:lookup(?REFERENCEPOOL_TABLE, Hash) of
+ [] ->
+ {not_found, Hash};
+ [{Hash,TypeDef}] ->
+ TypeDef
+ end.
+
+%% Does what it says on the tin.
+hash_store(#type_def{defineNo = Hash} = TypeDef, State) ->
+%% init(false),
+ case Hash of
+ -1->
+ Size=ets:info(?REFERENCEPOOL_TABLE,size),
+ ets:insert(?REFERENCEPOOL_TABLE,{Size,TypeDef#type_def{defineNo = Size}});
+ _ ->
+ ets:insert(?REFERENCEPOOL_TABLE,{Hash,TypeDef})
+ end,
+ State.
+hash_store(#type_def{defineNo = Hash} = TypeDef) ->
+%% init(false),
+ NewTypeDef=case Hash of
+ -1->
+ Size=ets:info(?REFERENCEPOOL_TABLE,size),
+ TypeDef2=TypeDef#type_def{defineNo = Size},
+ TypeDef2;
+ _ ->
+ TypeDef
+ end,
+ ets:insert(?REFERENCEPOOL_TABLE,{NewTypeDef#type_def.defineNo,NewTypeDef}),
+ NewTypeDef.
+
+init() -> init(false).
+
+%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
+%% Non-API functions
+
+
+%% This creates a new ETS table for the types that have been received by
+%% this instance of Hessian
+init(Delete) when is_boolean(Delete) ->
+%% case ets:info(hashes) of
+%% undefined ->
+%% io:format("init decoding table pid ~p~n",[self()]),
+%% ets:new(hashes,[public,named_table]); %% public
+%% EtsInfo ->
+%%%% io:format("type decoding etsinfo ~p~n",[EtsInfo]),
+%% if
+%% Delete == true ->
+%% ets:delete(hashes),
+%% ets:new(hashes,[public,named_table]);
+%% true ->
+%% ok
+%% end
+%% end,
+ case ets:info(?TYPEPOOL_TABLE) of
+ undefined ->
+ io:format("init decoding type_pool table pid ~p~n",[self()]),
+ ets:new(?TYPEPOOL_TABLE,[public,named_table]); %% public
+ _ ->
+%% io:format("type decoding etsinfo ~p~n",[EtsInfo]),
+ if
+ Delete == true ->
+ ets:delete(?TYPEPOOL_TABLE),
+ ets:new(?TYPEPOOL_TABLE,[public,named_table]);
+ true ->
+ ok
+ end
+ end,
+ case ets:info(?REFERENCEPOOL_TABLE) of
+ undefined ->
+ io:format("init decoding REFERENCEPOOL_TABLE table pid ~p~n",[self()]),
+ ets:new(?REFERENCEPOOL_TABLE,[public,named_table]); %% public
+ _ ->
+ if
+ Delete == true ->
+ ets:delete(?REFERENCEPOOL_TABLE),
+ ets:new(?REFERENCEPOOL_TABLE,[public,named_table]);
+ true ->
+ ok
+ end
+ end,
+ #decoding_state{}.
\ No newline at end of file
diff --git a/src/type_encoding.erl b/src/type_encoding.erl
new file mode 100644
index 0000000..6105ab3
--- /dev/null
+++ b/src/type_encoding.erl
@@ -0,0 +1,91 @@
+% ---------------------------------------------------------------------------
+% Copyright (C) 2008 0x6e6562
+%
+% Licensed under the Apache License, Version 2.0 (the "License");
+% you may not use this file except in compliance with the License.
+% You may obtain a copy of the License at
+%
+% http://www.apache.org/licenses/LICENSE-2.0
+%
+% Unless required by applicable law or agreed to in writing, software
+% distributed under the License is distributed on an "AS IS" BASIS,
+% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+% See the License for the specific language governing permissions and
+% limitations under the License.
+% ---------------------------------------------------------------------------
+
+-module(type_encoding).
+
+-include("hessian.hrl").
+
+%% The encoding state contains all of the statically known tuple types.
+%% When a tuple is to be encoded at run-time, a lookup is performed against
+%% the type tag. This must resolve to some type definition,
+%% otherwise no type information can be encoded into the output stream.
+-record(encoding_state,{pool = dict:new(), count = -1}).
+
+-export([init/0]).
+-export([enlist/1,enlist/2]).
+-export([visit/2]).
+
+%% Facility to register a particular type to the pool of known types.
+%% Adds the type to the pool of known types if it doesn't already exist.
+init()->
+ #encoding_state{}.
+
+enlist(TypeDef) -> enlist(TypeDef,#encoding_state{}).
+enlist(TypeDef = #type_def{native_type = Key},
+ State = #encoding_state{pool = OldPool}) ->
+ case dict:is_key(Key,OldPool) of
+ true ->
+ State;
+ false ->
+ NewPool = dict:store(Key, {-1, TypeDef}, OldPool),
+ State#encoding_state{pool = NewPool}
+ end.
+
+%% Facility to record the fact that an instance of a type is about to be
+%% encoded into the stream. This needs to decide whether the hash of the
+%% type def has already been written or not.
+%%
+%% If not, a reference to this needs to be generated for future instances
+%% and the hash value of the type def needs to be written out.
+%%
+%% If it already has been written out, it must be back-referenced.
+visit(NativeType, State = #encoding_state{pool = Pool}) ->
+ lager:debug("[encode] visit ~p",[NativeType]),
+ case dict:find(NativeType,Pool) of
+ {ok,{-1, TypeDef}} ->
+ %% The type needs hashing and it's reference needs updating
+ {Ref,NewTypeDef,NewState} = assign_reference(TypeDef, State),
+%% Hash = erlang:phash2(TypeDef),
+ %%%%%%%%%%%%%%%%%%%%%%%%%%
+ %% LOOK INTO THIS DEPENDENCY, MAYBE EXTRACT IT OUT
+%% type_decoding:hash_store(NewTypeDef,NewState), %% 貌似这个没用,可以去掉.
+ %%%%%%%%%%%%%%%%%%%%%%%%%%
+ {hash, Ref,NewTypeDef , NewState};
+ {ok,{Ref, TypeDef} } ->
+ {ref, Ref};
+ error ->
+ case get_deftype_public_pool(NativeType) of
+ undefined ->
+ throw("unkonw native type "++ atom_to_list(NativeType));
+ TypeDefTmp ->
+ State2 = enlist(TypeDefTmp,State),
+ visit(NativeType,State2)
+ end
+ end.
+
+%% This increments the reference count for the current scope and updates the
+%% reference in the pool of known types
+assign_reference(TypeDef = #type_def{native_type = Key},
+ #encoding_state{pool = OldPool, count = Count}) ->
+ NewCount = Count + 1,
+ NewTypeDef = TypeDef#type_def{defineNo = NewCount},
+ Value = {NewCount, NewTypeDef},
+ NewPool = dict:store(Key, Value, OldPool),
+ lager:debug("[encode] assign_reference type ~p definedNo ~p",[Key,NewCount]),
+ {NewCount,NewTypeDef,#encoding_state{pool = NewPool, count = NewCount}}.
+
+get_deftype_public_pool(NativeType)->
+ type_register:lookup_native_type(NativeType).
\ No newline at end of file
diff --git a/src/type_register.erl b/src/type_register.erl
new file mode 100644
index 0000000..6912cf2
--- /dev/null
+++ b/src/type_register.erl
@@ -0,0 +1,57 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 05. Mar 2018 2:06 PM
+%%%-------------------------------------------------------------------
+-module(type_register).
+-author("dlive").
+%% API
+-export([init/0,regiest_foreign_native/1,lookup_foreign_type/1,lookup_native_type/1]).
+-include("hessian.hrl").
+-define(FOREIGN_NATIVE_TABLE,foreign_native_table).
+-define(NATIVE_FOREIGN_TABLE,native_foreign_table).
+
+init()->
+ case ets:info(?FOREIGN_NATIVE_TABLE) of
+ undefined ->
+ io:format("init decoding foreign_native_table table pid ~p~n",[self()]),
+ ets:new(?FOREIGN_NATIVE_TABLE,[public,named_table]); %% public
+ _ ->
+ ets:delete(?FOREIGN_NATIVE_TABLE),
+ ets:new(?FOREIGN_NATIVE_TABLE,[public,named_table])
+ end,
+ case ets:info(?NATIVE_FOREIGN_TABLE) of
+ undefined ->
+ io:format("init decoding foreign_native_table table pid ~p~n",[self()]),
+ ets:new(?NATIVE_FOREIGN_TABLE,[public,named_table]); %% public
+ _ ->
+ ets:delete(?NATIVE_FOREIGN_TABLE),
+ ets:new(?NATIVE_FOREIGN_TABLE,[public,named_table])
+ end,
+ ok.
+
+
+regiest_foreign_native(TypeDef)->
+ lager:debug("regiest foreign info ~p",[TypeDef]),
+ ets:insert(?FOREIGN_NATIVE_TABLE,{TypeDef#type_def.foreign_type,TypeDef}),
+ ets:insert(?NATIVE_FOREIGN_TABLE,{TypeDef#type_def.native_type,TypeDef}).
+
+
+lookup_foreign_type(ForeignType)->
+ case ets:lookup(?FOREIGN_NATIVE_TABLE,ForeignType) of
+ []->
+ undefined;
+ [{_,TypeDef}] ->
+ TypeDef
+ end.
+
+lookup_native_type(NativeType)->
+ case ets:lookup(?NATIVE_FOREIGN_TABLE,NativeType) of
+ []->
+ undefined;
+ [{_,TypeDef}] ->
+ TypeDef
+ end.
\ No newline at end of file
diff --git a/test/de_codec_tests.erl b/test/de_codec_tests.erl
new file mode 100644
index 0000000..5cf1e04
--- /dev/null
+++ b/test/de_codec_tests.erl
@@ -0,0 +1,20 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2018, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 06. Apr 2018 4:49 PM
+%%%-------------------------------------------------------------------
+-module(de_codec_tests).
+-author("dlive").
+
+-include_lib("eunit/include/eunit.hrl").
+-include("dubbo.hrl").
+
+-record(databaseOperateRequest,{
+ param}).
+
+
+simple_test() ->
+ ?assert(true).
diff --git a/test/dubbo_config_parser_tests.erl b/test/dubbo_config_parser_tests.erl
new file mode 100644
index 0000000..3bbf79f
--- /dev/null
+++ b/test/dubbo_config_parser_tests.erl
@@ -0,0 +1,22 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2017, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 30. Dec 2017 2:52 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_config_parser_tests).
+-author("dlive").
+
+-include_lib("eunit/include/eunit.hrl").
+-include("dubbo.hrl").
+
+simple_test() ->
+ {ok,ProviderConfig} = dubbo_node_config_util:parse_provider_info("..."),
+%% io:format(user,"parse config result ~p~n",[ProviderConfig]),
+ ?assertEqual(ProviderConfig#provider_config.protocol,dubbo),
+ ?assertEqual(ProviderConfig#provider_config.host,"192.168.1.6"),
+ ?assertEqual(ProviderConfig#provider_config.port,20880),
+ ?assertEqual(ProviderConfig#provider_config.interface,<<"...">>),
+ ?assert(true).
diff --git a/test/dubbo_zookeeper_tests.erl b/test/dubbo_zookeeper_tests.erl
new file mode 100644
index 0000000..b67248d
--- /dev/null
+++ b/test/dubbo_zookeeper_tests.erl
@@ -0,0 +1,19 @@
+%%%-------------------------------------------------------------------
+%%% @author dlive
+%%% @copyright (C) 2017, <COMPANY>
+%%% @doc
+%%%
+%%% @end
+%%% Created : 26. Dec 2017 4:55 PM
+%%%-------------------------------------------------------------------
+-module(dubbo_zookeeper_tests).
+-author("dlive").
+
+-include_lib("eunit/include/eunit.hrl").
+-include("dubbo.hrl").
+exist_test() ->
+ Consumer=#consumer_config{interface = <<"com.ifcoder.demo.facade.User">>,
+ methods = [<<"a">>,<<"b">>]},
+ V= dubbo_zookeeper:gen_consumer_node_info(Consumer),
+ io:format(user,"gen consumer info:~p~n",[V]),
+ ?assert(true).
