【发布时间】:2017-03-03 05:31:09
【问题描述】:
我正在尝试在我的套接字路由器中侦听消息,将消息发送到内存中的进程、生成的 Runner 模块,然后将结果广播到客户端。
在 Phoenix 之外的独立测试中,此代码有效。使用 Phoenix,我收到此错误
~/chatroom:.mix phoenix.server
Compiling 2 files (.ex)
== Compilation error on file web/models/runner.ex ==
** (CompileError) web/models/runner.ex:8: undefined function send/3
(stdlib) lists.erl:1338: :lists.foreach/2
(stdlib) erl_eval.erl:670: :erl_eval.do_apply/6
(elixir) lib/kernel/parallel_compiler.ex:117: anonymous fn/4 in Kernel.ParallelCompiler.spawn_compilers/1
我的 lobby_channel.ex:
defmodule Chatroom.LobbyChannel do
require Runner
use Phoenix.Channel
{:ok, pid: spawn(fn -> Runner.input() end)}
def join("lobby", _payload, socket) do
{:ok, socket}
end
def handle_in("new_message", payload, socket) do
case payload["message"] do
"hello" -> broadcast! socket, "new_message", payload
"jump" -> send pid, {:jump, self, [avatar: avatar, socket: socket]}
_ -> nil
end
{:noreply, socket}
end
receive do
{:result, mover, socket} -> broadcast! socket, "new_message", [name: "State", message: "5"]
end
end
Runner.ex,存储在 web/models/runner.ex
defmodule Runner do
def spawn do
%{maxJump: 100}
end
def input do
receive do
{:run, sender, data} -> send sender, run(sender[:avatar]), data[:socket]
{:jump, sender, data} -> send sender, jump(sender[:avatar]), data[:socket]
end
input
end
defp run(mover) do
mover = case mover.y do
1 ->
Map.merge(mover, %{y: 0})
_ -> mover
end
Map.merge(mover, %{x: mover.x + 1})
end
defp jump(mover) do
case {mover.y} do
{0} ->
Map.merge(mover, %{y: mover.y + 1})
_ ->
mover
end
end
end
为什么我不能发送这些消息?
【问题讨论】: