Desenvolver um projetinho em java

[Leo_Mancini]

ola a todos eu estou com sérios problemas num projeto em Java que necessita usar sockets para conectar e threads.....
Vamos lá eu preciso criar um servidor que tem o compartilhamento de um arquivo texto que permita a leitura e a escrita deste arquivo com as seguintes regras:
- ao receber uma solicitação, o servidor deverá criar uma thread para atende-la
- vários leitores podem acessar ao mesmo tempo o arquivo.
- se um escritor acessar o arquivo ninguém mais pode acessá-lo. Enquanto houver leitura o servidor enfileirará os escritores e, havendo novos leitores, eles devem ser enfileirados depois do escritor.
- se houver solicitações enquanto o arquivo estiver sendo escrito elas devem respeitar uma fila (FIFO).

 

bom ate agora eu tenho isso aqui, de um grande parça, alguém pode me ajudar como devo prosseguir com o mais algo???

 

import java.io.*;

import java.net.ServerSocket;
import java.net.Socket;
 
public class Servidor implements Runnable {
 
    private DataInputStream in;
    private DataOutputStream out;
    private ServerSocket server;
    private Socket cliente;
        
   
    private volatile boolean stopped = false;
 
    @Override
    public void run() {
        try {
            //Cria servidor
            server = new ServerSocket(8080);
            System.out.println("Servidor Criado.");
            while(!stopped){
                if (server != null) {
                    cliente = server.accept();
                    new Thread(new ListenerSocket(cliente)).start();            
                }
            }
        } catch (IOException ex){
            System.out.println("Erro: " + ex.getMessage());
        }
    }
 
    private class ListenerSocket implements Runnable {
       
        public ListenerSocket(Socket cliente) {
            try {
                in = new DataInputStream(cliente.getInputStream());
                System.out.println("IP: " + cliente.getInetAddress().getHostAddress() + " conectou-se!");
 
                System.out.println("Aguardando");
                String acao = in.readUTF();
 
                //Chama Método
                //acaoRequerida(acao);
 
            } catch (IOException ex){
                System.out.println("Erro: " + ex.getMessage());
            }
        }  
 
        @Override
        public void run() {
            //throw new UnsupportedOperationException("Not supported yet.");
            //To change body of generated methods, choose Tools | Templates.
        }        
       
    }
 
}