doujiang1001 2015-08-25 09:29
浏览 80
已采纳

Erlang / Golang端口示例中的缓冲区大小

I have a crude Erlang-to-Golang port example, passing data from Erlang to Golang and echoing the response.

Problem is the amount of data I can transfer seems to be limited to 2^8 bytes (see below). I thought the problem was probably on the Golang side (not creating a big enough buffer) but replacing bufio.NewReader with bufio.NewReaderSize didn't work. So am now thinking the problem is maybe on the Erlang side.

What do I need to do to increase the buffer size / be able to echo a message larger than 2^8 bytes ?

TIA

justin@justin-ThinkPad-X240:~/work/erlang_golang_port$ erl -pa ebin
Erlang/OTP 17 [erts-6.4.1] [source] [64-bit] [smp:4:4] [async-threads:10] [kernel-poll:false]

Eshell V6.4.1  (abort with ^G)
1> port:start("./echo").
<0.35.0>
2> port:ping(65000).
65000
3> port:ping(66000).
** exception error: bad argument
     in function  port:call_port/1 (port.erl, line 20)
4> port:start("./echo").
<0.40.0>
5> port:ping(66000).    
65536

Go

package main

import (
    "bufio"
    "os"
)

const Delimiter = '
'

func main() {
    // reader := bufio:NewReader(os.Stdin)
    reader := bufio.NewReaderSize(os.Stdin, 1677216) // 2**24;
    bytes, _ := reader.ReadBytes(Delimiter)
    os.Stdout.Write(bytes[:len(bytes)-1])
}

Erlang

-module(port).

-export([start/1, stop/0, init/1]).

-export([ping/1]).

-define(DELIMITER, [10]).

start(ExtPrg) ->
    spawn(?MODULE, init, [ExtPrg]).

stop() ->
    myname ! stop.

ping(N) ->
    Msg=[round(65+26*random:uniform()) || _ <- lists:seq(1, N)],
    call_port(Msg).

call_port(Msg) ->
    myname ! {call, self(), Msg},
    receive
    {myname, Result} ->
        length(Result)
    end.

init(ExtPrg) ->
    register(myname, self()),
    process_flag(trap_exit, true),
    Port = open_port({spawn, ExtPrg}, []),
    loop(Port).

loop(Port) ->
    receive
    {call, Caller, Msg} ->
        Port ! {self(), {command, Msg++?DELIMITER}},
        receive
        {Port, {data, Data}} ->
            Caller ! {myname, Data}
        end,
        loop(Port);
    stop ->
        Port ! {self(), close},
        receive
        {Port, closed} ->
            exit(normal)
        end;
    {'EXIT', Port, _Reason} ->
        exit(port_terminated)
    end.
  • 写回答

2条回答 默认 最新

  • donglin6313 2015-08-25 12:20
    关注

    If you use start_link instead, you'll see that the port crashes after the first command:

    1> port:start('go run port.go').
    <0.118.0>
    2> port:ping(65000).
    65000
    ** exception error: port_terminated
    

    If you change the Go code to run in a loop, this crash can be avoided:

    func main() {
        for {
            // reader := bufio:NewReader(os.Stdin)
            reader := bufio.NewReaderSize(os.Stdin, 1677216) // 2**24;
            bytes, _ := reader.ReadBytes(Delimiter)
            os.Stdout.Write(bytes[:len(bytes)-1])
        }
    }
    

    Now we can see another interesting result:

    33> c(port).
    {ok,port}
    40> port:ping(66000).
    65536
    41> port:ping(66000).
    464
    42> port:ping(66000).
    65536
    43> port:ping(66000).
    464
    

    Now we can see that no data is actually lost, it's just buffered in the port. Since you have not specified a framing protocol (using {packet, N} or {line, N} you are responsible yourself for collecting the data. It also seems that the internal buffer size of an Erlang port is 64K (although I found no documentation of this and no way to change it).

    If you change your receive to get all data before returning, you'll every byte each time:

    loop(Port) ->
        receive
        {call, Caller, Msg} ->
            Port ! {self(), {command, Msg++?DELIMITER}},
            Caller ! {myname, receive_all(Port, 10)},
            loop(Port);
        stop ->
            Port ! {self(), close},
            receive
            {Port, closed} ->
                exit(normal)
            end;
        {'EXIT', Port, _Reason} ->
            exit(port_terminated)
        end.
    
    receive_all(Port, Timeout) -> receive_all(Port, Timeout, []).
    
    receive_all(Port, Timeout, Data) ->
        receive
        {Port, {data, New}} ->
            receive_all(Port, Timeout, [New|Data])
        after Timeout ->
            lists:flatten(lists:reverse(Data))
        end.
    

    Running this, we get:

    1> c(port).
    {ok,port}
    2>
    3> port:start('go run port.go').
    <0.311.0>
    4> port:ping(66000).
    66000
    5> port:ping(66000).
    66000
    6> port:ping(66000).
    66000
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 MapReduce结果输出到HBase,一直连接不上MySQL
  • ¥15 扩散模型sd.webui使用时报错“Nonetype”
  • ¥15 stm32流水灯+呼吸灯+外部中断按键
  • ¥15 将二维数组,按照假设的规定,如0/1/0 == "4",把对应列位置写成一个字符并打印输出该字符
  • ¥15 NX MCD仿真与博途通讯不了啥情况
  • ¥15 win11家庭中文版安装docker遇到Hyper-V启用失败解决办法整理
  • ¥15 gradio的web端页面格式不对的问题
  • ¥15 求大家看看Nonce如何配置
  • ¥15 Matlab怎么求解含参的二重积分?
  • ¥15 苹果手机突然连不上wifi了?