VPF::Сокетное соединение - ошибка - Форум программистов

YuraDoc

Дата 21.3.2008, 16:37 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 140
Регистрация: 1.4.2006
Где: Zhytomir, Ukraine

Репутация: нет
Всего: нет

Ребята расскажите пожалуйста как создать класс для работы с сокетными соединениями, да так чтобы с ним было приятно работать.

Вот написанный мною клиент
У меня при попытки получения сообщения выдается:

java.io.EOFException
        at java.io.DataInputStream.readUnsignedShort(DataInputStream.java:322)
        at java.io.DataInputStream.readUTF(DataInputStream.java:572)
        at java.io.DataInputStream.readUTF(DataInputStream.java:547)
        at main.Client.recv(Client.java:69)
        at main.Client.run(Client.java:77)

Код


public class Client extends Thread{

    private String message;
    private StreamConnection streamConn;
    public static final String PROTOCOL = "socket";
    private String serverPort, serverHostName, serverURI;
    
    public Client(String uri){
        serverURI = uri;
    }

    public Client(String server, String port) throws IOException{
        serverHostName = server;
        serverPort = port;
        serverURI = buildServerURI();
    }

    private String buildServerURI(){
        StringBuffer uri = new StringBuffer(PROTOCOL);
        uri.append("://");
        uri.append(serverHostName);
        uri.append(":");
        uri.append(serverPort);
        return uri.toString();
    }

    private void setMessage(String msg){
        message = msg;
    }

    public String getMessage(){
        return message;
    }
    
    public synchronized void send(String msg) {
    setMessage(msg);
        start();
    //notify();
    }

    private void send() throws IOException {
        /*
        if (getMessage() == null) {
        wait();
        }
        */
        //streamConn = (StreamConnection) Connector.open(serverURI);
        streamConn.openDataOutputStream().writeUTF(getMessage() + "\r\n");
        //streamConn.close();
    }
    
    private String recv() throws IOException{
        
        return streamConn.openDataInputStream().readUTF();
    }
    
    public synchronized void run() {
        //while (true) {
            try {
                streamConn = (StreamConnection) Connector.open(serverURI);
                send();
                setMessage(recv());
                streamConn.close();
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        //}
    }
}

Спасибо.

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java ME (J2ME) \| Следующая тема »