VPF::Проблема с Socket - Форум программистов

romanTheRoman

Дата 9.3.2011, 04:25 (ссылка)

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

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 14
Регистрация: 16.2.2011

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

Здравствуйте.
Нужно написать аналог ICQ.

Для этого я начал писать серверную часть:

Код


class Server extends Thread {
    public Socket socket;
    public int id;
    
    public static void main(String args[]) {
     int port = 27015;
     if (args.length != 0) {
         port = Integer.parseInt(args[0]);
     }
     
        try {      
            ServerSocket server = new ServerSocket(port, 0, InetAddress.getByName("localhost"));
            System.out.println("server is started with port " + port);

            while (true) {
                new Server(server.accept()); 
            }
        }
        catch (Exception e) {
         System.out.println(e);
     }
    }
    
    public Server(Socket s) {
//     System.out.println("Server()");
     this.socket = s;
     this.id++;
     
        setDaemon(true);
        setPriority(NORM_PRIORITY);
        start();    
    }
    
    public void run() {
     try {
//         System.out.println("run()");
         InputStream iStream = socket.getInputStream();
         OutputStream oStream = socket.getOutputStream();
         
         byte m[] = new byte[1024]; 
         iStream.read(m);
         String iMsg = new String(m);
         iMsg = cleanString(iMsg);
    
         String type = iMsg.substring(0, iMsg.indexOf('\n'));         
         iMsg = iMsg.replaceFirst(type + "\n", "");
         
         String addresser = iMsg.substring(0, iMsg.indexOf('\n'));
         iMsg = iMsg.replaceFirst(addresser + "\n", "");
         
         String addressee = iMsg.substring(0, iMsg.indexOf('\n'));     
         iMsg = iMsg.replaceFirst(addressee + "\n", ""); 
             
         String oMsg = "message == " + iMsg;
         
         System.out.println("message received");
         System.out.println("type == " + type);
         System.out.println("addresser == " + addresser);
         System.out.println("addressee == " + addressee);
         System.out.println("message == " + iMsg);
         
         byte b[];
         b = oMsg.getBytes();
         oStream.write(b);
     }
     catch (Exception e) {
         System.out.println(e);
     }      
    }   
    //remove some invisible-zero-shit characters
    private String cleanString(String str) {
        String cleaner = "";
        cleaner += (char) 0;
        str = str.replaceAll(cleaner, "");
        
        return str;
    }
}

И клиентскую:

Код


public class Client extends Thread {
    Socket socket;
    
    String host;
    int port;
    
    public Client(String h, int p) {
        this.host = h;
        this.port = p;
        
        setDaemon(true);
        setPriority(NORM_PRIORITY);
        start();
    }
    
    public void setConnection() {
        try {
            socket = new Socket(host, port);
        }
        catch (Exception e) {
         System.out.println(e);
        }    
    }
    
    public void send(String type, String addresser, String addressee, String msg) {
        try {    
            msg = "1\n" + addresser + "\n" + addressee + "\n" + msg;
            
            byte b[] = msg.getBytes();
            //System.out.println(b.length);
            socket.getOutputStream().write(b);

        }
        catch (Exception e) {
            System.out.println("send() " + e);
        } 
    }
    
    public String receive() {
        byte b[] = new byte[1024]; 
        String msg = "";
    
        try {        
            socket.getInputStream().read(b); 
            
            msg = new String(b);    
        }
        catch (Exception e) {
            System.out.println("receive() " + e);
        }
            
        return cleanString(msg);    
    }
    
    //remove some invisible-zero-shit characters
    private String cleanString(String str) {
        String cleaner = "";
        cleaner += (char) 0;
        str = str.replaceAll(cleaner, "");
        
        return str;
    }
}

Проблема в том, что я с клиентской частью на одной машине не могу подключиться к серверной части на другой машине (на последней есть выделенный айпи).
Но в то же время, если сервер и клиент на одной машине, то все пупцом.
При запуске клиента оно ждет какое-то время, а потом выдает исключение :
java.net.ConnectException: Connection timed out: connect

Чито делать, в чем проблемы?

LSD

Дата 9.3.2011, 12:03 (ссылка)

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

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

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

Цитата(romanTheRoman @ 9.3.2011, 04:25

)

Чито делать, в чем проблемы?

На клиенте открываешь консоль и пытаешься соединится телнетом с сервером:

Код


telnet host_ip 27015

Если соединится не удастся, значит проблемы с настройками сети. Надо проверять, что порт на сервере открыт. Что у клиента правильно настроена сеть. Клинент кстати не за прокси сидит?

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

romanTheRoman

Дата 9.3.2011, 19:03 (ссылка)

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

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 14
Регистрация: 16.2.2011

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

На сервере открыт порт.
У меня тоже открыт порт (провайдер тоже должен пропускать, так как я использую порт 27015, который обычно используют в Counter-Strike).
Когда найду вторую машину с внешним айпи, то попробую между ними.

Еще вопрос:
Я запускаю у себя сервер на порт 27015.
Запускаю клиент с каким-то левым айпи адресом хоста (не моим) и с портом 27015.
Когда отсылаю сообщение на тот левый хост, то мой сервер, который стоит у меня на компе, принимает сообщение.
Почему?

Temdegon

Дата 10.3.2011, 03:50 (ссылка)

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

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 429
Регистрация: 11.10.2008
Где: Minsk

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

Код


ServerSocket server = new ServerSocket(port, 0, InetAddress.getByName("localhost"));

А нафиг ты localhost указываешь?
Я так понимаю, что если указал локалхост, то сервер и будет слушать только локахлост, а все остальные сетевые интерфейсы будет игнорировать. Убери последний аргумент, и все должно заработать.

Добавлено через 9 минут и 9 секунд

Цитата

Еще вопрос:
Я запускаю у себя сервер на порт 27015.
Запускаю клиент с каким-то левым айпи адресом хоста (не моим) и с портом 27015.
Когда отсылаю сообщение на тот левый хост, то мой сервер, который стоит у меня на компе, принимает сообщение.
Почему?

Возможно туда каким-то образом попадает null вместо левого хоста. Тогда все логично - сокет будет коннектиться к localhost.

romanTheRoman

Дата 10.3.2011, 23:43 (ссылка)

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

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 14
Регистрация: 16.2.2011

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

Я делал по примеру, из-за этого и была проблема.
Теперь все отлично работает, после того, как я убрал третий аргумент.
Спасибо.

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