server.erl
-module(server).
-export([start/0,start/1,process/1]).
-define(defPort, 8888).
start() -> start(?defPort).
start(Port) ->
case gen_tcp:listen(Port, [binary, {packet, 0}, {active, false}]) of
{ok, LSock} -> server_loop(LSock);
{error, Reason} -> exit({Port,Reason})
end.
%% main server loop - wait for next connection, spawn child to process it
server_loop(LSock) ->
case gen_tcp:accept(LSock) of
{ok, Sock} ->
spawn(?MODULE,process,[Sock]),
server_loop(LSock);
{error, Reason} ->
exit({accept,Reason})
end.
%% process current connection
process(Sock) ->
Req = do_recv(Sock),
io:format("~p~n", [Req]),
Resp = "Hello, " ++ Req ++ "!",
do_send(Sock,Resp),
gen_tcp:close(Sock).
%% send a line of text to the socket
do_send(Sock,Msg) ->
case gen_tcp:send(Sock, Msg) of
ok -> ok;
{error, Reason} -> exit(Reason)
end.
%% receive data from the socket
do_recv(Sock) ->
case gen_tcp:recv(Sock, 0) of
{ok, Bin} -> binary_to_list(Bin);
{error, closed} -> exit(closed);
{error, Reason} -> exit(Reason)
end.
Client.as
package {
import flash.display.Sprite;
import flash.events.*;
import flash.net.Socket;
import flash.text.*;
public class Client extends Sprite
{
private var socket:Socket;
private var myField:TextField;
public function Client()
{
socket = new Socket();
myField = new TextField();
// 添加事件处理回调函数
socket.addEventListener(ProgressEvent.SOCKET_DATA, onSocketData);
socket.connect("localhost", 8888);
socket.writeUTFBytes("hideto");
socket.flush();
myField.x = 20;
myField.y = 30;
myField.text = "test";
myField.autoSize = TextFieldAutoSize.LEFT;
addChild(myField);
}
// 事件处理回调函数
private function onSocketData(event:ProgressEvent):void {
while(socket.bytesAvailable) {
myField.text = socket.readUTFBytes(socket.bytesAvailable);
}
}
}
}
编译运行:
server.erl在Eshell里编译并启动
Eshell > c(server).
Eshell > server:start().
"hideto" %% 打印接受到的来自AS client的消息
Client.as在Flex Builder 3里编译运行
client.html里显示一个TextField,value为“test”,但是过了一会value变为“Hello, hideto!”,这是因为ActionScript里Socket连接都是
异步的,不能直接从Socket连接中读取数据,而是通过事件处理函数进行读取处理,数据读取完毕后更新TextField的value,所以会看到value由“test”改为“Hello, hideto!”
分享到:
相关推荐
erlang与delphi多客户端通讯,同时支持flash客户端,开通了843端口。
基于Erlang的即时通讯系统的设计与实现
安装Erlang和RabbitMQ,linux系统下的哦,有红色字体标注!已踩坑
ErlangB和ErlangC计算工具(exe可执行文件+excel两个) ErlangB和ErlangC计算工具(exe可执行文件+excel两个)
Windows下Erlang与C构建的节点通讯完整例子,包含cnode工程项目,erlang引用例子。 配套文章:http://blog.csdn.net/mycwq/article/details/40836273
主要介绍了Erlang中的socket编程简单例子,本文给出了TCP服务器echo示例、Tcp 的echo客户端示例、UDP server示例、UDP client 示例,需要的朋友可以参考下
rabbitmq和erlang,rabbitmq和erlang,rabbitmq和erlang,rabbitmq和erlang,rabbitmq和erlang,rabbitmq和erlang,rabbitmq和erlang,rabbitmq和erlang,rabbitmq和erlang
rabbitMQ是一个在AMQP协议标准基础上完整的,可服用的企业消息系统。它遵循Mozilla Public License开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器,Rabbit MQ 是建立在Erlang OTP平台上。
erlang学习3erlang学习3erlangerlang学erlang学习3习3学习3
erlang入门电子书 erlang编程 Introducing Erlang,作者Simon.St.Laurent
handlersocket是基于mysql的nosql解决方案,与普通的nosql方案比较,具有更大的灵活性,可以使用mysql的索引。性能相比于mysql的批量操作方式,具有5倍左右的提升(我测试的,可能是内存设置的不多)。...
Erlang23_3,windows32为64位,linux版本
erlang-jose, Erlang和Elixir的JSON对象签名和加密( JOSE ) Erlang和Elixir的JSON对象签名和加密( JOSE ) 。安装将 jose 添加到 mix.exs 中的项目依赖项defp deps do [ {:jose, "~> 1.8"} ]
erlang 安装包
使用Erlang编写出的应用运行时通常由成千上万个轻量级进程组成,并通过消息传递相互通讯。进程间上下文切换对于Erlang来说仅仅 只是一两个环节,比起C程序的线程切换要高效得多得多了。 使用Erlang来编写分布式应用...
erlang的timer和实现机制 Erlang程序设计
本资源为在centos7上安装rabbitmq所需的安装包(包括了erlang和rabbitmq两个文件)
Erlang及其应用Erlang及其应用Erlang及其应用
Centos7安装erlang和RabbitMq
Erlang和RabbitMQ安装包