【Erlang聊天室之二】C#與Erlang的羣通訊

該節依然不是聊天室的代碼

Erlang寫服務器，鏈接全部的客戶端，只要收到一個客戶端的消息，就會羣發到其餘客戶端。

C#寫客戶端，能夠多個客戶端，發送消息到服務器。

 

1.Erlang服務器

知識點：

Erlang使用{packet,N}後，會自動在數據前面增長N個字節。

{active,true},{active,false},{active,once}，分別是主動、被動、半阻塞三種模式：

% {active,true} 建立一個主動套字節(非阻塞)；

% {active,false} 建立一個被動套字節(阻塞),若是爲false表必須手工處理阻塞,不然阻塞在此處沒法收聽,當前我沒法處理；

% {active, once} 建立一個一次性被動套字節(阻塞),只收聽一次後堵塞，必須調用inet:setopts(Socket, [{active, once}]),後纔可收聽下一條，建立一個主動套字節僅接收一條消息,如想接收下一條必須再次激活(半阻塞)。

1. active（主動消息接收）：非阻塞。當數據到達時系統會向控制進程發送{tcp, Socket, Data}消息。控制進程沒法控制消息流；

2. passive（被動消息接收）：阻塞。控制進程必須主動調用recv()來接收消息。能夠控制消息流；

3. active once（混合消息接收）：半阻塞。這種模式是主動的但僅針對一個消息，在控制進程收到一個消息後，必須顯式調用inet:setopts(Socket, [{active, once}])來從新

激活以接收下一個消息。能夠進行流量控制。這種模式相對於被動模式來講，有個優勢是能夠同時等待多個socket的數據。

http://www.2cto.com/kf/201304/202413.html

http://blog.csdn.net/pkutao/article/details/8572216

-module(hjh_server).
-compile(export_all).
%%http://hideto.iteye.com/blog/226639

start_nano_server() ->
    %%註冊一個進程到pid
    register(pid,spawn(fun()->clients([]) end)),
　　%%監聽30087的端口
    {ok, LSocket} = gen_tcp:listen(30087, [binary, {packet, 0},  %% (6)
                          {reuseaddr, true},
                          {active, false}]),
    loop(LSocket).

loop(LSocket) ->
    %%鏈接，獲得客戶端的Socket 
   {ok, Socket} = gen_tcp:accept(LSocket),  %% (7)
    spawn(fun()->handle_client(Socket) end),
    pid!{connect,Socket},
    loop(LSocket).

handle_client(CSocket)->
　　%%接受數據，若爲{ok,Data}則發送
    case gen_tcp:recv(CSocket,0) of
        {ok,Data}->
            io:format("Socket success:~w~n",[Data]),
            pid!{data,Data},
            handle_client(CSocket);
        {error,_}->
           pid!{disconnect,CSocket}
    end.

clients(Sockets)->
    receive
        {connect,Socket}->
            io:format("Socket connected:~w~n",[Socket]),
            NewSockets=[Socket | Sockets];
        {disconnect,Socket}->
            io:format("Socket disconnected:~w~n",[Socket]),
            NewSockets=lists:delete(Socket,Sockets);
        {data,Data}->
            send_data(Sockets,Data),
            NewSockets=Sockets
    end,
    clients(NewSockets).

%%羣發送，Sockets是全部保存的Socket。
send_data(Sockets,Data)->
    SendData=fun(Socket)->
        gen_tcp:send(Socket,Data)
    end,
    lists:foreach(SendData,Sockets).

 

2.C#客戶端

public partial class Form1 : Form
    {
        Socket socket;
        private static byte[] result = new byte[1024];
        public Form1()
        {
            InitializeComponent();
            IPAddress ip = IPAddress.Parse("127.0.0.1");
            socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream,
                ProtocolType.Tcp);
            socket.Connect(new IPEndPoint(ip, 30087));
            socket.Send(Encoding.UTF8.GetBytes("TTTT"));
            Thread thread = new Thread(ReceiveMessage);
            thread.IsBackground = true;
            thread.Start();
        }

        private void button1_Click(object sender, EventArgs e)
        {
            String str;
            if (textBox2 != null || !textBox2.Equals(""))
            {
                str = textBox2.Text;
                textBox1.Text += str + Environment.NewLine;
                socket.Send(Encoding.UTF8.GetBytes(str));
            }
        }

        private void ReceiveMessage()
        {
            while (true)
            {
                try
                {
                    int receiveNumber = socket.Receive(result);
                    AddText("接受服務器端消息：" + 
                        Encoding.UTF8.GetString(result, 0, receiveNumber));
                }
                catch (Exception ex)
                {
                    AddText(ex.Message);
                    socket.Shutdown(SocketShutdown.Both);
                    socket.Close();
                    break;
                }

            }
        }

        private delegate void MessageDelegate(string message);
        private void AddText(string message)
        {
            if (textBox1.InvokeRequired)
            {
                MessageDelegate d = new MessageDelegate(AddText);
                textBox1.Invoke(d, new object[] { message });
            }
            else
            {
                textBox1.Text += message + Environment.NewLine;
            }

        }

    }

 

 

 代碼：http://download.csdn.net/detail/hjhjava/6709501