java and flash

[danmc977]

Hi guys, first post, be nice :)

Was just wondering if anyone could tell me how to change the following java server into a multi-threaded one, it has threading capabilities already I believe, so im sure theres something im missing but my java isnt that good:

gruchalski.com » Archive » XMLSocket.send / Socket.writeUTFBytes doesn’t work?

Thanks
Dan

[KevinWorkman]

That's not really how this works. Not many people are going to click on external links, and even fewer people are going to wade through a whole program worth of code.

We can answer specific questions about specific code (in SSCCE form), but general questions like this aren't really answerable.

[danmc977]

@KevinWorkman Thanks for the reply, I understand that someone isnt going to wade through a big program and basically do my work for me, I think you misunderstood my request, I was hoping someone could help me with multithreading;
The link I gave is the only working server I have found that correctly serves a policy file to a flash client, but currently it doesnt allow multiple connections from clients.

So I was wondering if someone could help me out with multithreading, in regards to the link I have posted.

But anyway thanks for the reply

Dan

[KevinWorkman]

If I were you, I'd start by reading through this and trying out some simple examples: Lesson: Concurrency (The Java™ Tutorials > Essential Classes)

[danmc977]

@KevinWorkman again thanks for the reply, ive read through the link you posted, and believe me when I say ive read through quite a few tutorials etc when trying to sort this out, but no matter what I read or try I can't get it to work.
The link I posted already includes threading capabilities, but i just can't work out how to get it to work, really would appreciate any help here.

Thanks
Dan

[toadaly]

The server is already multi-threaded and already accepts multiple clients at a time. Have you tried using it? If so, what issue are you having?

[danmc977]

Thanks for the reply @toadaly

The server accepts a connection from one client, and can receive and send data from this client, but if another client connects, the server will only send data received to the sending client, not all clients.

I want the server to receive data from any client and then output it to all clients.

Really appreciate your help

Thanks
Dan

[toadaly]

Ok. What you need to do then, is create a Set of Socket's. Each time a new client Socket is created, add it to the set. Then create a java.util.BlockingQueue (I'd probably use a simple ArrayBlockingQueue), and a service thread. The service thread will block on queue.take().

When one of the client handler threads receives data, you will call queue.put() with whatever message you're wanting to send to the clients. This will cause the service queue to kick into action. In the service queue, you will loop through the Set of Sockets calling 'getOutputStream' and writing to the output stream. Flush after each write, but do not close the stream.

You must handle exceptions carefully. If the write command throws an exception, then you want to close that socket down (which should cause the associated client thread to throw an exception - which you must handle and return from the thread), and also remove that Socket from the Set.

Good luck!

[danmc977]

Ok thanks, ill look into this

Dan