65 lines
2.5 KiB
Lua
65 lines
2.5 KiB
Lua
function plugin_ctx_new(sess, plug_env, sess_context)
|
|
print("now lua plugin create sess ctx, plugin id", plug_env.id)
|
|
sess_context.count = 0
|
|
sess_context.payload_len = 0
|
|
msg = {}
|
|
msg.data = "this is lua plugin message"
|
|
session_mq.publish_message(sess, plug_env.topic_id, msg)
|
|
end
|
|
|
|
function plugin_ctx_free(sess, sess_context, plug_env)
|
|
print("now lua plugin begin to free sess ctx")
|
|
print("total packet count is", sess_context.count)
|
|
print("total paylaod length is", sess_context.payload_len)
|
|
end
|
|
|
|
function on_message_fn(sess, topic_id, msg, sess_context, env)
|
|
sess_context.count = sess_context.count + 1
|
|
print("lua plugin call on message fn", sess_context.count)
|
|
payload, payload_len = session.get_payload(sess)
|
|
sess_context.payload_len = sess_context.payload_len + payload_len
|
|
print(payload)
|
|
end
|
|
|
|
function free_message(sess, msg, msg_free_arg)
|
|
print("message need to free is", msg.data)
|
|
print("free arg data is", msg_free_arg.data)
|
|
end
|
|
|
|
function plugin_load(stellar, plug_env)
|
|
print("now begin to load lua example plugin")
|
|
|
|
plug_env.st = stellar
|
|
plug_env.id = session_plugin.register(stellar, plugin_ctx_new, plugin_ctx_free, plug_env)
|
|
plug_env.data = "this is lua example plug env data"
|
|
|
|
--[[ 获取TCP topic, 并完成订阅 ]]
|
|
tcp_topic_id = session_mq.get_topic_id(stellar, "TCP")
|
|
print("lua plugin get TCP topic id is", tcp_topic_id)
|
|
session_mq.subscribe_topic(stellar, tcp_topic_id, on_message_fn, plug_env.id)
|
|
plug_env.tcp_topic_id = tcp_topic_id
|
|
|
|
--[[ 创建TOPIC_SESSION_STAT, 并完成函数注册 ]]
|
|
msg_free_arg = {}
|
|
msg_free_arg.data = "this is lua plugin message free arg data"
|
|
test_topic_id = session_mq.get_topic_id(stellar, "LUA_TOPIC_SESSION_STAT")
|
|
if (test_topic_id < 0)
|
|
then
|
|
--[[ 该消息未创建, 创建该topic ]]
|
|
test_topic_id = session_mq.create_topic(stellar, "LUA_TOPIC_SESSION_STAT", free_message, msg_free_arg)
|
|
print("create topic is", test_topic_id)
|
|
else
|
|
--[[ 如果该消息已经注册, 更新其注册函数 ]]
|
|
session_mq.update_topic(stellar, test_topic_id, free_message, msg_free_arg)
|
|
print("topic already created, id is", test_topic_id)
|
|
end
|
|
plug_env.tcp_topic_id = tcp_topic_id
|
|
plug_env.topic_id = test_topic_id
|
|
end
|
|
|
|
function plugin_unload(plug_env)
|
|
print("now unload lua example plugin")
|
|
print("plugin env data is", plug_env.data)
|
|
print("now destory topic id is", plug_env.topic_id)
|
|
session_mq.destory_topic(plug_env.st, plug_env.topic_id)
|
|
end |