Форум Flasher.ru - <policy-file-request/> + java-сервер

Вывел работу с полиси в отдельный поток, привязал прослушку порта 843, результат нулевой. Те сервер пишет что отправлено, клиент же не получает.

лог клиента

Код:

securityErrorHandler: [SecurityErrorEvent type="securityError" bubbles=false cancelable=false eventPhase=2 text="Error #2048"]

Лог сервера (обрамляющие кавычки вокруг ответа сервера пришпандорены в выводе лога, чтобы проще контролить что отправляется (так мы видим пробел перед последней кавычкой, говорящий что нулевой знак тоже отправился))

Код:

20.09.2011 21:29:51 ServerFlashRunnable flashrun

INFO: new Flash connection

20.09.2011 21:29:54 ServerFlashRunnable flashrun

INFO: Flash is connecting | '<policy-file-request/> '

20.09.2011 21:29:54 ServerFlashRunnable flashrun

INFO: Send to flash | '<?xml version="1.0"?><!DOCTYPE cross-domain-policy SYSTEM "http://www.macromedia.com/xml/dtd

ss-domain-policy.dtd"><cross-domain-policy><allow-access-from secure='false' domain="*" to-ports="8234" /></cross-d

-policy>

'

20.09.2011 21:29:54 ServerFlashRunnable flashrun

INFO: Flash new Connection closed

После подключения со стороны флеша вызывается этот метод

Код:

private static void flashrun(Socket gsock)

        {

                log.info("new Flash connection");



                InputStream fromguest=null;

                OutputStream toguest=null;

                try

                {

                        fromguest=gsock.getInputStream();

                        toguest=gsock.getOutputStream();

                }

                catch(IOException e)

                {

                        log.warning("Can't create Flash streams");

                }

                

                if((fromguest!=null)&&(toguest!=null))

                {        

                        Scanner in = new Scanner(fromguest);

                        PrintWriter out = new PrintWriter(toguest,true);                

                        String outcoming;

                        if(Server.Server_ch())

                        {

                                while (in.hasNextLine() )

                                {

                                        String incoming = in.nextLine();

                                        

                                                if (incoming.equals("<policy-file-request/>\0"))

                                                {

                                                        log.info("Flash is connecting | '"+incoming+"'");

                                                        outcoming=CROSS_DOMAIN_TEXT +"8234"+CROSS_DOMAIN_END_TEXT+"\n";

                                                        log.info("Send to flash | '"+outcoming+"'");

                                                        out.write(outcoming);

                                                        if (out != null) {

                                                                out.flush();

                                                                out.close();

                                                        }

                                                        if (in != null) {

                                                                in.close();

                                                        }

                                                        if (gsock != null) {

                                                                try

                                                                {

                                                                        log.info("Flash new Connection closed");

                                                                        gsock.close();

                                                                }

                                                                catch(IOException e)

                                                                {

                                                                        log.warning("Can't close Flash connection");

                                                                }

                                                        }

                                                }

                                                else

                                                {

                                                        try

                                                        {

                                                                log.info("Flash new Connection closed");

                                                                gsock.close();

                                                        }

                                                        catch(IOException e)

                                                        {

                                                                log.warning("Can't close flash connection");

                                                        }

                                                }

                                        

                                }

                        }

                        else

                        {

                                try

                                {

                                        log.info("Connection closed");

                                        gsock.close();

                                }

                                catch(IOException e)

                                {

                                        log.warning("Can't close connection");

                                }

                                

                        }

                }

        }

Код клиента взят полностью из примера из справки по работе с сокетами, только адаптирован для вывода в textarea тестового фрейма

Код тествого фрейма

Код AS3:

stop();

import MyGlobal;

var socket=new MyGlobal("127.0.0.1", 8234,stat);

Код myGlobals

Код AS3:

package {

                import flash.errors.*;

                import flash.events.*;

                import flash.net.Socket;

        public class MyGlobal extends Socket {

           private var response:String;

           private var stat;

           public function MyGlobal(host:String , port:uint, st) {

        super();

                stat=st;

        configureListeners();

        if (host && port)  {

            super.connect(host, port);

        }

    }

 

    private function configureListeners():void {

        addEventListener(Event.CLOSE, closeHandler);

        addEventListener(Event.CONNECT, connectHandler);

        addEventListener(IOErrorEvent.IO_ERROR, ioErrorHandler);

        addEventListener(SecurityErrorEvent.SECURITY_ERROR, securityErrorHandler);

        addEventListener(ProgressEvent.SOCKET_DATA, socketDataHandler);

    }

 

    private function writeln(str:String):void {

        str += "\n";

        try {

            writeUTFBytes(str);

        }

        catch(e:IOError) {

            trace(e);

        }

    }

 

    private function sendRequest():void {

        stat.htmlText="sendRequest";

        response = "";

        writeln("GET /");

        flush();

    }

 

    private function readResponse():void {

        var str:String = readUTFBytes(bytesAvailable);

        response += str;

    }

 

    private function closeHandler(event:Event):void {

        stat.htmlText="closeHandler: " + event;

        trace(response.toString());

    }

 

    private function connectHandler(event:Event):void {

        stat.text="connectHandler: " + event;

        sendRequest();

    }

 

    private function ioErrorHandler(event:IOErrorEvent):void {

        stat.htmlText="ioErrorHandler: " + event;

    }

 

    private function securityErrorHandler(event:SecurityErrorEvent):void {

        stat.htmlText="securityErrorHandler: " + event;

    }

 

    private function socketDataHandler(event:ProgressEvent):void {

        stat.htmlText="socketDataHandler: " + event;

        readResponse();

    }

 

        }

}

2bav попробовал так, пишет ошибку компилятор об том что не может найти метод write. у которого три аргумента, ошибку правда не скопипастил я.

Ps идей почему у меня такое нет совершенно. Вернее те что есть попахивают шаманизмом, вроде попробовать насильно конвертить отправляемую строку в UTF8. Если важно сервер поднят на одной машине с вебсервером, на котором лежит тот флеш файл. Веб сервер и мой сервер работают на разных портах.
PPs
Решил от нефиг делать запустить из адоб флеша, через паблиш превью. Запустилось, но реквеста не последовало, вместо этого тупо приконектилось туда куда прошу, а не на полиси порт, и гордо выдало о получении "fail" (так как я брал из примера адобовского и там в обработчике подключения так и стоит отправка чего-то, в этом чём-то сервер формата родного запроса не узнал и послал "fail"'ом клиент)... Затык где то именно в этой долбанном хендшейке.

PPPs веб сервер(у меня xampp), на котором висит флешка надо как-то настраивать?

Добавлено через 1 час 38 минут
Заработало... почувствовал себя доктором франкенштейном и до конца не понимаю, чё делаю таки сделал...
Вот готовый класс к запуску в отдельном потоке если чё.

Код:

class ServerFlashRunnable implements Runnable

{

        private ServerSocket flashsock;

        private static final Logger log=Logger.getLogger("main.thread");

        public static String CROSS_DOMAIN_TEXT = "<?xml version=\"1.0\"?>"+

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

            "<cross-domain-policy>" +

            "<allow-access-from secure='false' domain=\"*\" to-ports=\"";

        public static String CROSS_DOMAIN_END_TEXT ="\" /></cross-domain-policy>";

    public ServerFlashRunnable(ServerSocket sock)

        {

                flashsock=sock;

                

        }

        

        public void run()

        {

                log.info("Flash tread starts");

                while(Server.Server_ch())

                {

                        try

                        {

                                Socket gsock=flashsock.accept();

                                flashrun(gsock);

                        }

                        catch(IOException e)

                        {

                                log.warning("Can't accept flash connection");

                        }

                }

        }

        

        

        private static void flashrun(Socket gsock)

        {

                log.info("new Flash connection");



                InputStream fromguest=null;

                OutputStream toguest=null;

                try

                {

                        fromguest=gsock.getInputStream();

                        toguest=gsock.getOutputStream();

                }

                catch(IOException e)

                {

                        log.warning("Can't create Flash streams");

                }

                

                if((fromguest!=null)&&(toguest!=null))

                {        

                        BufferedReader in = new BufferedReader(new InputStreamReader(fromguest));

                        PrintWriter out = new PrintWriter(toguest,true);                

                        String outcoming;

                        

                        String request = "";

                        request = read(in);

                        if(Server.Server_ch())

                        {

                                if (request.contains("<policy-file-request/>") || request.contains("GET /crossdomain.xml")) {

                        out.write(CROSS_DOMAIN_TEXT +

                                "8234" +                                                                                //порт который надо открыть пихаем сюда

                                CROSS_DOMAIN_END_TEXT+"\u0000");

                }

                                try

                                {

                                        out.flush();

                            out.close();

                                        in.close();

                                        log.info("Connection closed");

                                        gsock.close();

                                }

                                catch(IOException e)

                                {

                                        log.warning("Can't close connection");

                                }

                        }

                        else

                        {

                                try

                                {

                                        log.info("Connection closed");

                                        gsock.close();

                                }

                                catch(IOException e)

                                {

                                        log.warning("Can't close connection");

                                }

                                

                        }

                }

        }

        protected static String read(BufferedReader in) {

        StringBuffer buffer = new StringBuffer();

        int codePoint;

        boolean zeroByteRead = false;

        

        try {

            do {

                codePoint = in.read();



                if (codePoint == 0 || codePoint == '\n') {

                    zeroByteRead = true;

                }

                else if (Character.isValidCodePoint(codePoint)) {

                    buffer.appendCodePoint(codePoint);

                }

            }

            while (!zeroByteRead && buffer.length() < 200);

        }

        catch (Exception e) {

            log.warning("Exception (read): " + e.getMessage());

        }

        

        return buffer.toString();

    }

}