- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我修改了 this server使用 gen_tcp:recv
为了将数据包的字节数限制为 50。我注释掉了行 inet:setopts(Socket, [{active, once}]),
因为 gen_tcp:recv
应该是 {active,false}
.这是客户端 erl shell
2> cp3:client().
exit
3>
4> cp3:server().
Started Server:
<0.46.0>
Accept Server:
Pid <0.48.0>
Connection accepted
Accept Server:
Loop Server:
5>
{tcp_closed, Socket}
关闭如果
gen_tcp:recv
不创建一个?
-module(cp3).
-export([client/0, server/0,start/0,accept/1,enter_loop/1,loop/1]).
client() ->
{ok, Socket} = gen_tcp:connect("localhost", 4001,[list, {packet, 0}]),
ok = gen_tcp:send(Socket, "packet"),
receive
{tcp,Socket,String} ->
io:format("Client received = ~p~n",[String]),
io:format("Client result = ~p~n",[String]),
gen_tcp:close(Socket)
after 1000 ->
exit
end.
server() ->
Pid = spawn(fun()-> start() end),
Pid.
start() ->
io:format("Started Server:~n"),
{ok, Socket} = gen_tcp:listen(4001, [binary, {packet, 0},{reuseaddr, true},{active, false}]),
accept(Socket).
accept(ListenSocket) ->
io:format("Accept Server:~n"),
case gen_tcp:accept(ListenSocket) of
{ok, Socket} ->
Pid = spawn(fun() ->
io:format("Connection accepted ~n", []),
enter_loop(Socket)
end),
io:format("Pid ~p~n",[Pid]),
gen_tcp:controlling_process(Socket, Pid),
Pid ! ack,
accept(ListenSocket);
Error ->
exit(Error)
end.
enter_loop(Socket) ->
%% make sure to acknowledge owner rights transmission finished
receive ack -> ok end,
loop(Socket).
loop(Socket) ->
%% set socket options to receive messages directly into itself
%%inet:setopts(Socket, [{active, once}]),
io:format("Loop Server:~n"),
case gen_tcp:recv(Socket, 50) of
{ok, Data} ->
case Data of
<<"packet">> ->
io:format("Server replying = ~p~n",[Data]),
gen_tcp:send(Socket, Data),
loop(Socket)
end;
{error, Reason} ->
io:format("Error on socket ~p reason: ~p~n", [Socket, Reason])
end.
最佳答案
我不是很清楚你的问题,但上面的代码不起作用。希望以下内容可以解决您的问题。您的 tcp 收到 case gen_tcp:recv(Socket, 50) of
有一个错误。它正在等待读取 50 个字节。查看 gen_tcp:recv/2 的文档.将长度(packer 6 的长度,但最好是)更改为 0 以接收所有字节。
该值不限制数据的大小,但在收到长度为 50 的数据之前不会发送数据。相反,您可能需要接受然后检查它。
关于Erlang: gen_tcp:recv() 没有收到客户端发来的数据包?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/15612140/
我想将主机名和端口从命令行传递给 gen_tcp.connect。 defmodule MyComm.Application do use Application def main(args
在浏览 erlang 应用程序的代码时,我遇到了一个有趣的设计问题。让我描述一下情况,但由于 PIA,我无法发布任何代码,抱歉。 代码结构为 OTP 应用程序,其中两个 gen_server 模块负责
这个问题在这里已经有了答案: Erlang server, Java client - TCP messages get split? (3 个回答) 7年前关闭。 我正在使用 this 中的 soc
有没有办法从 Erlang 中的套接字读取整行,或者我是否需要在 gen_tcp:recv 之上手动实现行缓冲? ? 最佳答案 你有没有试过使用 inet:setopts(Socket, [{pack
我修改了 this server使用 gen_tcp:recv为了将数据包的字节数限制为 50。我注释掉了行 inet:setopts(Socket, [{active, once}]),因为 gen
我很感兴趣 gen_tcp:accept 函数的限制是什么?我的意思是什么是最大并发连接数?或者如何配置? (gen_tcp 设置、ulimit 或其他)get_tcp 每秒可以接受多少连接? 最佳答
简单的问题... 这段代码.. client() -> SomeHostInNet = "localhost" % to make it runnable on one machine
我写了一个简单的http客户端,遇到以下问题,我复制粘贴了do_recv来自官方文档,但它的工作方式很奇怪: do_recv(Sock, Bs) -> case gen_tcp:recv(So
我们有一个 gen_server 进程,它通过创建被动套接字并将其借用给其他进程来管理客户端的被动套接字池。任何其他进程都可以借用套接字,使用该套接字向服务器发送请求,通过 gen_tcp:recv
我有一个监听 Ip:Port 的 TCP 服务器。 listen(Ip, Port) -> Opts = [ binary, {active, false}, {packe
我正在实现一个接受许多并发连接的服务器。 我使用了这个结构: loop(Sock) -> case gen_tcp:accept(Sock) of {ok, CSock} ->
我正在尝试学习 Erlang 来做一些简单但可扩展的网络编程。我基本上想编写一个程序来完成互联网 Backbone 上的服务器所做的事情——但规模较小。我想尝试建立一个带有 Web 可访问服务器的 I
在我输入 gen_ 然后在 erlang shell 中输入 Tab 后,我得到了 gen_server、gen_event,但我没有得到gen_tcp。如何在 Erlang shell 中使用 ge
下面是解释如何使用 gen_tcp 的一个示例的一部分。然而,几乎所有的教程都只会向您展示一个回显服务器,而不会解析真实世界的 HTTP 请求。 handle_connect(Socket,
如何使用 gen_tcp 在 erlang 中发送形式为 [Integer, String] 的消息。 例如:我希望使用 gen_tcp:send/2 通过套接字发送形式为 [25, "Hello"]
我遇到了一个问题。我在 Erlang/OTP 上有一个 iOS 客户端和一个 tcp 服务器。客户端假设通过 GCDAsynchSocket 向服务器发送和接收消息。如果我需要发送消息但它不能作为接受
我正在尝试使用 Erlang gen_tcp 在 Elixir 中通过 TCP 连接接受数据 {:ok, socket} = :gen_tcp.connect("127.0.0.1" ,2000,[:
一些教程,包括这个 Learn You Some Erlang一,显示 OTP 主管将打开并拥有一个 TCP 监听套接字并将其共享给将接受连接的多个工作人员的应用程序。 我的问题是,如何在没有 ter
我正在尝试使用 gen_tcp 模块。有服务器端代码的示例,我遇到了麻烦。 %% First, I bind server port and wait for peer connection {ok,
编辑于 2015-11-25 02:10 我的 ejabberd 版本是 14.12 和 erlang R17B,所以这段代码似乎没用,因为 R17B 中的 erlang:system_info(ot
我是一名优秀的程序员,十分优秀!