Skip to content

Instantly share code, notes, and snippets.

View zhongwencool's full-sized avatar
🌊

zhongwencool zhongwencool

🌊
204 followers · 100 following
  • China Guǎng Zhōu
  • 18:05 (UTC +08:00)
View GitHub Profile
@zhongwencool
zhongwencool / gist:8e26a48dcf2c51028f206ee8d1abd12d
Created June 14, 2022 07:08
emqx_example.conf
## Title
## Body
## @path listeners
listeners {
## @doc TCP listeners
## @path listeners.tcp
## @type map_struct()
# tcp.name =
@zhongwencool
zhongwencool / generate_ssl_pem.sh
Created June 7, 2022 02:00
#!/bin/bash
# author:xijin.c
read -r -p "请输入文件存储目录名: " dir
cd /data
mkdir $dir
cd $dir
# 生成CA key【采用2048字节】
@zhongwencool
zhongwencool / emqx_example_en.conf
Last active May 26, 2022 08:33
## Title
## Body
listeners {
## @doc
## TCP listeners
##
## @path listeners.tcp
## @type map()
@zhongwencool
zhongwencool / test.erl
Created September 1, 2021 05:59
-module(emqx_api_spec).
%% API
-include_lib("typerefl/include/types.hrl").
%% -import(emqx_schema, [t/1, t/3, t/4, ref/1]).
-export([api_spec/0
, spec/1]).
api_spec() -> ["/plain/style", "/schema/style"].
@zhongwencool
zhongwencool / send_interval.erl
Created October 2, 2019 01:55
init([]) –>
timer:send_interval(?TIME,self(),loop_interval_event),
{ok, #state{}}.
handle_info(loop_interval_event, State) ->
NewState = do_loop_inverval_event(State),
{noreply, NewState};
@zhongwencool
zhongwencool / timeout.erl
Created October 2, 2019 01:50
init([]) –>
{ok, #state{},next_report_time()}.
handle_info(timeout,State) –>
NewState = do_report_event(State),%% maybe spawn for heavy task
{noreply,NewState,next_report_time()}.
@zhongwencool
zhongwencool / send_after.erl
Created October 2, 2019 01:41
init([]) –>
erlang:send_after(next_report_time(),self(),report_event),
{ok, #state{}}.
handle_info(report_event, State) –>
NewState = do_report_event(State),%% maybe spawn for heavy task
erlang:send_after(next_time_report(),self(),report_event),
{noreply, NewState}.
@zhongwencool
zhongwencool / send_stream_example.ex
Created January 4, 2017 02:50
defmodule Client do
use Maxwell.Builder, ~w(post)a
middleware Maxwell.Middleware.BaseUrl, "http://httpbin.org"
middleware Maxwell.Middleware.Opts, [connect_timeout: 10000, recv_timeout: 20000]
middleware Maxwell.Middleware.Json
adapter Maxwell.Adapter.Hackney
@doc """
@zhongwencool
zhongwencool / send_multipart_example.ex
Created January 4, 2017 02:45
defmodule SendMultipartClient do
use Maxwell.Builder, ~w(post)a
middleware Maxwell.Middleware.BaseUrl, "http://httpbin.org"
middleware Maxwell.Middleware.Opts, [connect_timeout: 10000, recv_timeout: 20000]
middleware Maxwell.Middleware.DecodeJson
adapter Maxwell.Adapter.Hackney
@doc """
@zhongwencool
zhongwencool / send_file_example.ex
Last active January 4, 2017 02:36
defmodule SendFileClient do
use Maxwell.Builder, ~w(post)a
middleware Maxwell.Middleware.BaseUrl, "http://httpbin.org"
middleware Maxwell.Middleware.Opts, [connect_timeout: 10000, recv_timeout: 20000]
adapter Maxwell.Adapter.Hackney
@doc """
Post whole file once