我正试图用牛仔websocket处理程序创建一个聊天室。我希望来自每一个的消息也会被转发到其他的套接字，就像聊天组一样。我不知道如何实现这一点？
浏览 3提问于2021-02-05得票数 1
回答已采纳
因此，我创建了一个包含两个函数的gen_server，第一个函数是处理注册，第二个函数是查找注册进程的Pids。之后，我打开了两个erlang控制台，注册了两个具有相同属性的进程(每个控制台请求服务器注册一个进程)--我的服务器代码如下：gen_server:start_linkgetpids(Pid, Name) ->
gen_server:call(Pid, {getpids, Name}).= gproc:lookup_pids({p,
浏览 2提问于2017-01-29得票数 0
回答已采纳
我正在使用yaws (Erlang框架)进行套接字通信。我可以使用websocket_send从服务器向用户发送消息，但是我需要指定用户的PID，这意味着我可以向该用户发送消息。但是，我想向所有连接的用户发送消息。有什么办法吗？
浏览 1提问于2013-03-29得票数 3
回答已采纳
Erlang：
但是如果我想把它扩展到一个简单的聊天服务器中呢？但是目前没有一个gen_server客户端知道其他任何一个客户端的存在！
什么是符合OTP的合理模式，使一个gen_server能够为所有其他
浏览 0提问于2014-07-26得票数 2
回答已采纳
我知道gen_event，但它在一个单一的事件管理器进程中处理事件，而我希望每个订阅者都是一个独立的、自治的进程。因此，我想扩展supervisor (引擎盖下的gen_server )，使其能够向其所有子进程发送cast消息。State) -> Pids:cast(Pid, Message) || Pid <- Pids],
浏览 0提问于2011-08-30得票数 9
回答已采纳
I有一个由另一个服务器(即gen_server )启动的gen_server (my_gen_server.erl)现在，follows:handle_info({reconnecting， my_gen_server正在接收来自ejabberd和ServerPid的消息，我的处理方式是：ejabberd ServerPid}=Msg
浏览 0提问于2021-03-08得票数 1
回答已采纳
有两个OTP应用程序:一个服务器(一个实例)和一个客户机(多个实例)。服务器和客户端应用程序都包含负责处理消息的gen_servers (分别为chat_server.erl和chat_client.erl )。当客户端connects时，它发送其gen_server进程的pid。这样，我们就可以将客户端pids存储在服务器状态以区分它们和发送/广播消息。服务器处理来自客户端的强制转换，通过给定的名称查找收件人的pid，并向它/向每
浏览 4提问于2014-01-17得票数 2
3回答
我正在研究Erlang文档，试图了解设置OTP gen_server和主管的基本知识。每当我的gen_server崩溃时，我的主管也会崩溃。实际上，每当命令行出现错误时，我的主管就会崩溃。我希望当gen_server崩溃时会重新启动它。我希望命令行错误对我的服务器组件没有任何影响。我的上司根本不应该崩溃。-behaviour(gen_server).
-export([echo/1, crash/0]).echo(Text)
浏览 0提问于2010-05-05得票数 10
回答已采纳
用户向服务器发送http请求以更新其状态。服务器上的http请求进程将用户状态消息保存在内存中。服务器每分钟将所有消息发送到远程服务器并清除内存。如果用户立即多次更新其状态，则最后一条消息将覆盖前一条消息。重要的是，在读取所有消息和清除消息之间，没有其他进程能够写入状态消息。gen_server和一个小弟弟。dict:存储/3将更新或创建状态。gen_server用ram_copies解决了'transaction‘问题.
浏览 1提问于2010-01-28得票数 13
回答已采纳
我目前正在以一个合理的剪辑学习Erlang，但是我有一个关于gen_server的问题。如果一个gen_server进程崩溃，并必然由主管重新启动，它将收到一个新的pid。在这些过程中，有什么好的惯用方法来“更新”Pid呢？
作为对一些实际应用程序的练习，我正在编写一个锁服务器，其中客户端可以使用任意密钥请求锁。理想情况下，我希望有一个单独的进程来处理特定锁的锁定和释放，这样我就可以使用gen_server中的超时值参数来终止进程，如果在N个时间之后没有人请求它，那么只有当前相关的锁才会
浏览 6提问于2010-11-14得票数 2
我目前正在用erlang编写一个软件，它现在基于gen_server行为。SERVER的调用，其处理方式如下： {ok, Socket} = ssl:connect("remoteserver.com现在，这可以很好地处理我在shell中的测试，但是如果我们必须调用1000次mymod:update(Value)并且ssl:connect/4不能正常工作(即到达超时)，会发生什么呢？此时，我的gen_serv
浏览 4提问于2012-08-18得票数 2
回答已采纳
我有一个主管，启动了许多gen_server。每个gen_server都有大量的数据加载，这需要很长时间。我想知道当错误发生时，存储在gen_server的状态中的数据和它的进程字典是否会被保存到下一次启动时，这样我就不需要再次初始化它们了？
浏览 0提问于2011-07-30得票数 5
我看到了一些示例，显示您可以在shell中与此匹配以获得分配给var的Pid，因此，如果我创建了一个gen_server，如：start_link() ->test
因此，我的问题是，您可以在不将消息注册到shell中的一个原子或变量的情况下，以<0.0.0>的形式向Pids发送消息吗？实验和搜索被证明是徒劳的..。
浏览 1提问于2014-12-01得票数 5
回答已采纳
我不明白如何连接到Erlang应用程序，因为它不返回Pid。.app application,simple_app, {description,"something"}, {modules,[proc]}}-module(simple_app).
-behaviour
浏览 1提问于2020-07-28得票数 0
回答已采纳
如何锁定多线程的瞬态API请求？有没有做过一些基准测试，对于多个并发请求，瞬态API能处理多少？如果管理不当，似乎会造成一些严重的瓶颈。
另外，如何使用内置在cron中的WP来强制使用瞬态API？例如，我从页面加载(另一个独立函数)收集统计信息，但如果没有访问一个页面，则不会更新瞬态页面/帖子，您将如何使用瞬态API循环所有页面/帖子以强制更新？这个cron也可以有效地处理我的第一个问题，以避免多线程处理<
浏览 0提问于2011-04-03得票数 1
回答已采纳
例如，假设我有一个实现gen_server行为的模块，它实现了 {reply, result(Foo), State}我可以通过从其他进程执行gen_server:call (服务器，{foo，Foo})来达到这个处理程序(我猜如果一个gen_server尝试gen_server:call本身，它就会死锁)。但是gen_server:call会阻塞响应(或超时)。如果我不想阻止你的回应呢？
浏览 0提问于2015-02-17得票数 2
1回答
“外部力量”(由一个长期运行的gen_server处理)能够改变这个数组，所以我不能简单地硬编码它。我的问题是如何“托管”这个数组。我的第一个实现是一个简单的gen_server，它保存一个数组的副本，并将其发送给任何需要它的人。请求它的进程然后可以遍历它并获得他们想要的索引。我目前的实现有一个处理数组状态的中央gen_server，以及处理实际请求的子对象。当状态改变时，中央gen_server更新子进程。当一个进程想要找到它的散列结果时，它将其索引
浏览 2提问于2012-02-02得票数 5
回答已采纳
有人能解释一下gen_server:start()和gen_server:start_link()之间的区别吗？
有人告诉我这是关于多线程的东西。编辑：，如果我的gen_server是从多个线程调用的，它会同时执行它们吗？还是会在这些线程之间创建并发性？
浏览 0提问于2016-07-12得票数 11
回答已采纳
2回答
我实现了一个gen_server和主管：test_server和test_sup。我想从shell/CLI中测试它们。我编写了他们的start_link函数，以便在本地注册他们的名字。但是，如果我尝试使用test_sup做同样的事情，那么在我的"CLI进程“(使用registered/0)中不会注册新的名称/Pids。为什么我可以生一个gen_server，而不是一个主管？
我使用的代码可以在中找到。我使用的是echo_server
浏览 2提问于2010-05-07得票数 5
回答已采纳
在回复之前，我尝试进行一个递归调用来处理_ call /3。但这似乎是不可能的，因为会引发timeout退出异常。下面您可以看到代码和错误。-module(test).start_link() -> gen_server:call(Pid, first_call).]}}
in function gen_serve
浏览 2提问于2016-09-06得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
