Форум Flasher.ru - XMLSocket и сервер на C#

Форум Flasher.ru (http://www.flasher.ru/forum/index.php)

- ActionScript 1.0/2.0 (http://www.flasher.ru/forum/forumdisplay.php?f=93)

- - XMLSocket и сервер на C# (http://www.flasher.ru/forum/showthread.php?t=96471)

XMLSocket и сервер на C#

Простой клиент во флеше на AS2:

Код:

import flash.net;

import flash.events;

_global.sock = new XMLSocket();

sock.onConnect = function(success) {

        if (success)

        textBox1.text = "Статус: Подключен";

        else

        textBox1.text = "Статус: Отключен";

};

sock.onClose = function() {

        textBox1.text = "Статус: Закрыт сервером";

};

sock.onXML = function(XMLtext) {

        trace("onXML"+XMLtext);

};

sock.onData = function(XMLdata) {

        trace("onData"+XMLdata);

};

btConnect.onRelease=function(){

        sock.connect("oxy",8087);

}

btClose.onRelease=function(){

        sock.close();

        textBox1.text = "Статус: Закрыт пользователем";

}

btSend.onRelease=function(){

        sock.send("sended");

}

и сервер на C# на ассинхронном сокете,
консольное приложение Program.cs:

Код:

using System;

using System.Collections.Generic;

using System.Text;

using kostasoft;



namespace MultiSocketDemo

{

    class Program

    {

        static void Main(string[] args)

        {

            serverSoket sock = new serverSoket(8087);

            sock.Start();

            Console.ReadLine();

        }

    }

}

Класс для работы с сокетами serverSoket.cs:

Код:

using System;

using System.Collections.Generic;

using System.Text;

using System.Net.Sockets;

using System.Net;





namespace kostasoft

{

    class serverSoket

    {

        private Socket _serverSocket;

        private int _port;

        private List<ConnectionInfo> _connections = new List<ConnectionInfo>();

        private class ConnectionInfo

        {

            public Socket Socket;

            public byte[] Buffer;

        }



        public serverSoket(int port) 

        { 

            _port = port;

        }



        private void SetupServerSocket()

        {

            // Получаем информацию о локальном компьютере

            IPHostEntry localMachineInfo =

                Dns.GetHostEntry(Dns.GetHostName());

            IPEndPoint myEndpoint = new IPEndPoint(

               localMachineInfo.AddressList[0], _port);



            Console.WriteLine("Запускаем сервер на ip: " + localMachineInfo.AddressList[0].ToString() + ":" + _port.ToString());

            // Создаем сокет, привязываем его к адресу

            // и начинаем прослушивание

            _serverSocket = new Socket( myEndpoint.Address.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

            _serverSocket.Bind(myEndpoint);

            _serverSocket.Listen((int) SocketOptionName.MaxConnections);

        }



        public void Start()

        {

            SetupServerSocket();

            for (int i = 0; i < 10; i++)

                _serverSocket.BeginAccept(new AsyncCallback(AcceptCallback), _serverSocket);

        }



        private void AcceptCallback(IAsyncResult result)

        {

            ConnectionInfo connection = new ConnectionInfo();

            try

            {

                // Завершение операции Accept

                Socket s = (Socket)result.AsyncState;

                connection.Socket = s.EndAccept(result);

                connection.Buffer = new byte[255];

                lock (_connections) _connections.Add(connection);

                // Начало операции Receive и новой операции Accept

                connection.Socket.BeginReceive(connection.Buffer,

                    0, connection.Buffer.Length, SocketFlags.None,

                    new AsyncCallback(ReceiveCallback),

                    connection);

                _serverSocket.BeginAccept(new AsyncCallback(

                    AcceptCallback), result.AsyncState);

            }

            catch (SocketException exc)

            {

                CloseConnection(connection);

                Console.WriteLine("Socket exception: " +

                    exc.SocketErrorCode);

            }

            catch (Exception exc)

            {

                CloseConnection(connection);

                Console.WriteLine("Exception: " + exc);

            }

        }



        private void ReceiveCallback(IAsyncResult result)

        {

            ConnectionInfo connection =

                (ConnectionInfo)result.AsyncState;

            try

            {

                int bytesRead =

                    connection.Socket.EndReceive(result);

                if (0 != bytesRead)

                {

                    string readData = Encoding.UTF8.GetString(connection.Buffer, 0, bytesRead);

                    string writeData = "ansver\u000A\u0000";

                    readData = readData.Substring(0, bytesRead-1);

                    Console.WriteLine(readData);



                    Console.WriteLine(writeData);

                    byte[] msg = Encoding.UTF8.GetBytes(writeData);

                    lock (_connections)

                    {

                        foreach (ConnectionInfo conn in

                            _connections)

                        {

                            if (connection != conn)

                            {

                                conn.Socket.Send(msg, msg.Length, 0);//SocketFlags.None);

                            }

                        }

                    }

                    connection.Socket.BeginReceive(

                        connection.Buffer, 0,

                        connection.Buffer.Length, SocketFlags.None,

                        new AsyncCallback(ReceiveCallback),

                        connection);

                }

                else CloseConnection(connection);

            }

            catch (SocketException exc)

            {

                CloseConnection(connection);

                Console.WriteLine("Socket exception: " +

                    exc.SocketErrorCode);

            }

            catch (Exception exc)

            {

                CloseConnection(connection);

                Console.WriteLine("Exception: " + exc);

            }

        }



        private void CloseConnection(ConnectionInfo ci)

        {

            ci.Socket.Close();

            lock (_connections) _connections.Remove(ci);

        } 

    }

}

Проблема: клиент передает данные серверу, сервер их получает, в ответ отсылает строку клиенту, а в клиенте не вызывается событие onData или onXML. Отсылаемую строку заканчиваю 0. В чем может быть трабла?
ЗЫ: Асинхронный сокет в таком виде использую, т.к. он наиболее быстрый при большом кол-ве коннектов.

К ночи тупить начал...:D
Код, приведеный выше для сервера отсылает сообщение, принятое от одного клиента, всем другим подключеным клиентам. Чтобы он отправлял тому же клиенту, надо отправлять в этом же коннекшене. Короче, функция ReceiveCallback должна быть такая:

Код:

private void ReceiveCallback(IAsyncResult result)

        {

            ConnectionInfo connection =

                (ConnectionInfo)result.AsyncState;

            try

            {

                int bytesRead = connection.Socket.EndReceive(result);

                if (0 != bytesRead)

                {

                    string readData = Encoding.UTF8.GetString(connection.Buffer, 0, bytesRead);

                    readData = readData.Substring(0, bytesRead-1);

                    Console.WriteLine(readData);



                    string writeData = "ansver\u0000";

                    Console.WriteLine(writeData);

                    byte[] msg = Encoding.UTF8.GetBytes(writeData);

                    connection.Socket.Send(msg, msg.Length, SocketFlags.None);

                    connection.Socket.BeginReceive(

                        connection.Buffer, 0,

                        connection.Buffer.Length, SocketFlags.None,

                        new AsyncCallback(ReceiveCallback),

                        connection);

                }

                else CloseConnection(connection);

            }

            catch (SocketException exc)

            {

                CloseConnection(connection);

                Console.WriteLine("Socket exception: " +

                    exc.SocketErrorCode);

            }

            catch (Exception exc)

            {

                CloseConnection(connection);

                Console.WriteLine("Exception: " + exc);

            }

        }

Во флеше клиент не на AS2, а на AS1. И flash.events нет в AS2/AS1, а в пакете flash.net есть только FileReference, не относящийся к сокетами совершенно никак. Т.е. два импорта нафиг не нужны.

Спасибо, учту. Я больше по сям, флешь ковырять жизнь заставила (уж больно красивый клиент можно забацать, c# отдыхает, тем более для других платформ).
В догонку еще вопрос нарисовался (опять ближе к ночи :D ) :
Какую строку должен передать сервер клиенту на запрос о политике безопасности по тому же порту, по которому будет дальнейшая работа (в моем случае 8087)? Нужно, чтоб клиент работал не только из прожекта, но и загруженый из html или запущеный как swf. (Для линукса, например, есть адобовский плеер).
Я так понимаю, строка должна содержать xml, но точные данные для моего случая не могу подобрать.

Сам себе ночью пишу и сам себе же утром отвечаю...
В serverSocket.cs добавляем:

Код:

private const string policyRequest = "<policy-file-request/>";

...

if (recData.IndexOf(policyRequest) != -1)

                    {

                        data = "<?xml version=\"1.0\"?>";

                        data += "<!DOCTYPE cross-domain-policy SYSTEM \"http://www.macromedia.com/xml/dtds/cross-domain-policy.dtd\">";

                        data += "<cross-domain-policy>";

                        data += "<allow-access-from domain=\"*\" to-ports=\"*\" />";

                        data += "</cross-domain-policy>\u0000";    

                    }

, где recData - принятые данные
data - отправляемые данные

Осталось разобраться с полноэкранным режимом клиента на флеше, если грузим его из html. Использую в Publish setting на вкладке html опцию template как Flash Only - Allow Full Screen. В тексте программы пишу:

Код:

fscommand("fullscreen", true);

fscommand("showmenu", false);

Для прожекта работает на полный экран, для html - нет!
IDE - Flash CS3

Мммм… так и не должно работать (слава богу). Правда, в девятой (9,0,28,0) версии плеера появилось свойство displayState у Stage.
http://livedocs.adobe.com/flash/9.0/main/00002149.html

Изменил на

Код:

Stage.displayState = "fullscreen";

Stage.showMenu = false;

Все равно не пашет, хотя для прожекта работало как и с фскомандами...
В хтмл и в жаваскрипте все поменялось автоматически, когда выставил Allow Full Screen...

А версия плеера-то какая?

Мммм, попробуй разместить все на хосте и оттуда посмотреть.