Форум программистов, компьютерный форум, киберфорум
Наши страницы
Программирование Android
Войти
Регистрация
Восстановить пароль
 
Xme1ez
0 / 0 / 0
Регистрация: 08.12.2014
Сообщений: 37
1

Сокеты - краш при вызове openConnection

10.04.2017, 17:03. Просмотров 319. Ответов 3
Метки нет (Все метки)

Приветсвую, встала задача передачи сообщения с телефона (android 6) на ПК, которые подключены к одной сети WiFi. Почитав google пришел к выводу, что это можно реализовать через Socket. Еще погуглив нашел пример для Android(клиент) и ПК(Сервер). Собрав код воедино для двух проектов столкнулся с проблемкой, после нажатия кнопки open (подключится к серверу) приложение крашится. После небольших тестов обнаружил, что ошибка возникает после вызова метода openConnection() в классе MainActivity.java (строка 60). Почему так происходит ума не приложу... Буду благодарен за любую помощь.
Вот исходники кода из созданных проектов:
MainActivity.java
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
package com.xme1ez.client;
 
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import java.net.Socket;
 
 
 
 
public class MainActivity extends AppCompatActivity {
 
    private static final String LOG_TAG = "myServerApp";
 
    // ip адрес сервера, который принимает соединения
    private String mServerName = "192.168.0.80";
 
    // номер порта, на который сервер принимает соединения
    private int mServerPort = 80;
 
    // сокет, через которий приложения общается с сервером
    private Socket mSocket = null;
 
    private Button mButtonOpen  = null;
    private Button mButtonSend  = null;
    private Button mButtonClose = null;
    private LaptopServer mServer = null;
    private TextView mTextView = null;
 
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        mButtonOpen = (Button) findViewById(R.id.button_open_connection);
        mButtonSend = (Button) findViewById(R.id.button_send_connection);
        mButtonClose = (Button) findViewById(R.id.button_close_connection);
        mButtonSend.setEnabled(false);
        mButtonClose.setEnabled(false);
        mTextView = (TextView) findViewById(R.id.textView);
 
 
        mButtonOpen.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
        /* создаем объект для работы с сервером*/
                mServer = new LaptopServer();
                mTextView.setText("Object mServer Created");
        /* Открываем соединение. Открытие должно происходить в отдельном потоке от ui */
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            mTextView.setText("Before connection");
                            mServer.openConnection();
                            mTextView.setText("Connection is opened");
                    /*
                        устанавливаем активные кнопки для отправки данных
                        и закрытия соедиения. Все данные по обновлению интерфеса должны
                        обрабатывается в Ui потоке, а так как мы сейчас находимся в
                        отдельном потоке, нам необходимо вызвать метод  runOnUiThread()
                    */
                            runOnUiThread(new Runnable() {
 
                                @Override
                                public void run() {
                                    mButtonSend.setEnabled(true);
                                    mButtonClose.setEnabled(true);
                                }
                            });
                        } catch (Exception e) {
 
                            Log.e(LOG_TAG, "Exception: "+Log.getStackTraceString(e));
                            mTextView.setText("Connection failed");
                            mServer = null;
                        }
                    }
                }).start();
            }
        });
 
        mButtonSend.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                if (mServer == null) {
                    Log.e(LOG_TAG, "Сервер не создан");
                    mTextView.setText("Сервер не создан");
                }else{
                    mTextView.setText("Сервер создан");
                }
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        try {
                    /* отправляем на сервер данные */
                            mServer.sendData("Send text to server".getBytes());
                            mTextView.setText("Sended");
                        } catch (Exception e) {
                            Log.e(LOG_TAG, e.getMessage());
                        }
                    }
                }).start();
            }
        });
 
        mButtonClose.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
            /* Закрываем соединение */
                mServer.closeConnection();
            /* устанавливаем неактивными кнопки отправки и закрытия */
                mButtonSend.setEnabled(false);
                mButtonClose.setEnabled(false);
            }
        });
    }
}
LaptopServer.java
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
package com.xme1ez.client;
 
import android.util.Log;
import android.widget.TextView;
import java.io.IOException;
import java.net.Socket;
 
public class LaptopServer {
 
    private static final String LOG_TAG = "myServerApp";
 
    // ip адрес сервера, который принимает соединения
    private String mServerName = "192.168.0.10";
 
    // номер порта, на который сервер принимает соединения
    private int mServerPort = 6789;
 
    // сокет, через которий приложения общается с сервером
    private Socket mSocket = null;
 
    public LaptopServer() {}
 
    /**
     * Открытие нового соединения. Если сокет уже открыт, то он закрывается.
     *
     * @throws Exception
     *      Если не удалось открыть сокет
     */
    public void openConnection() throws Exception {
 
    /* Освобождаем ресурсы */
        //closeConnection();
 
        try {
        /*
            Создаем новый сокет. Указываем на каком компютере и порту запущен наш процесс,
            который будет принамать наше соединение.
        */
            mSocket = new Socket(mServerName,mServerPort);
 
        } catch (IOException e) {
            throw new Exception("Невозможно создать сокет: "+e.getMessage());
        }
    }
 
    /**
     * Метод для закрытия сокета, по которому мы общались.
     */
    public void closeConnection() {
 
    /* Проверяем сокет. Если он не зарыт, то закрываем его и освобдождаем соединение.*/
        if (mSocket != null && !mSocket.isClosed()) {
 
            try {
                mSocket.close();
            } catch (IOException e) {
                Log.e(LOG_TAG, "Невозможно закрыть сокет: " + e.getMessage());
            } finally {
                mSocket = null;
            }
 
        }
        mSocket = null;
    }
 
    /**
     * Метод для отправки данных по сокету.
     *
     * @param data
     *          Данные, которые будут отправлены
     * @throws Exception
     *          Если невозможно отправить данные
     */
    public void sendData(byte[] data) throws Exception {
 
    /* Проверяем сокет. Если он не создан или закрыт, то выдаем исключение */
        if (mSocket == null || mSocket.isClosed()) {
            throw new Exception("Невозможно отправить данные. Сокет не создан или закрыт");
        }
 
    /* Отправка данных */
        try {
            mSocket.getOutputStream().write(data);
            mSocket.getOutputStream().flush();
        } catch (IOException e) {
            throw new Exception("Невозможно отправить данные: "+e.getMessage());
        }
    }
 
    @Override
    protected void finalize() throws Throwable {
        super.finalize();
        closeConnection();
    }
}
Androidmanifest.xml
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
          package="com.xme1ez.client">
    <uses-permission android:name="android.permission.INTERNET" />
    <application
            android:allowBackup="true"
            android:icon="@mipmap/ic_launcher"
            android:label="@string/app_name"
            android:supportsRtl="true"
            android:theme="@style/AppTheme">
        <activity android:name=".MainActivity">
            <intent-filter>
                <action android:name="android.intent.action.MAIN"/>
 
                <category android:name="android.intent.category.LAUNCHER"/>
            </intent-filter>
        </activity>
    </application>
 
</manifest>
Вот код Server'a
Server.java
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
import java.io.IOException;
import java.net.ServerSocket;
 
public class Server implements Runnable {
 
    /*
     * Реалезация шаблона Singleton
     * {@link https://en.wikipedia.org/wiki/Singleton_pattern}
     */
    private static volatile Server instane = null;
 
    /* Порт, на который сервер принимает соеденения */
    private final int SERVER_PORT = 6789;
 
    /* Сокет, который обрабатывает соединения на сервере */
    private ServerSocket serverSoket = null;
 
    private Server() {}
 
    public static Server getServer() {
 
        if (instane == null) {
            synchronized (Server.class) {
                if (instane == null) {
                    instane = new Server();
                }
            }
        }
        return instane;
    }
 
 
    @Override
    public void run() {
 
        try {
            /* Создаем серверный сокет, которые принимает соединения */
            serverSoket = new ServerSocket(SERVER_PORT);
            System.out.println("Start server on port: "+SERVER_PORT);
 
            /*
             * старт приема соединений на сервер
             */
            while(true) {
 
                ConnectionWorker worker = null;
 
                try {
                    /* ждем нового соединения  */
                    worker = new ConnectionWorker(serverSoket.accept());
                    System.out.println("Get client connection");
 
                    /* создается новый поток, в котором обрабатывается соединение */
                    Thread t = new Thread(worker);
                    t.start();
 
                } catch (Exception e) {
                    System.out.println("Connection error: "+e.getMessage());
                }
            }
        } catch (IOException e) {
            System.out.println("Cant start server on port "+SERVER_PORT+":"+e.getMessage());
        } finally {
            /* Закрываем соединение */
            if (serverSoket != null) {
                try {
                    serverSoket.close();
                } catch (IOException e) {
                }
            }
        }
    }
}
ConnectionWorker.java
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
import java.io.IOException;
import java.io.InputStream;
import java.net.Socket;
 
 
public class ConnectionWorker implements Runnable {
    /* сокет, через который происходит обмен данными с клиентом*/
    private Socket clientSocket = null;
 
    /* входной поток, через который получаем данные с сокета */
    private InputStream inputStream = null;
 
    public ConnectionWorker(Socket socket) {
        clientSocket = socket;
    }
 
    @Override
    public void run() {
 
        /* получаем входной поток */
        try {
            inputStream = clientSocket.getInputStream();
        } catch (IOException e) {
            System.out.println("Cant get input stream");
        }
 
        /* создаем буфер для данных */
        byte[] buffer = new byte[1024*4];
 
        while(true) {
 
            try {
                /*
                 * получаем очередную порцию данных
                 * в переменной count хранится реальное количество байт, которое получили
                 */
                int count = inputStream.read(buffer,0,buffer.length);
 
                /* проверяем, какое количество байт к нам прийшло */
                if (count > 0) {
                    System.out.println(new String(buffer,0,count));
                } else
                    /* если мы получили -1, значит прервался наш поток с данными  */
                    if (count == -1 ) {
                        System.out.println("close socket");
                        clientSocket.close();
                        break;
                    }
            } catch (IOException e) {
                System.out.println(e.getMessage());
            }
        }
    }
}
MainApp.java
Java
1
2
3
4
5
6
7
public class MainApp {
    public static void main(String[] args) {
        Server server = Server.getServer();
        Thread t = new Thread(server);
        t.start();
    }
}
0
Similar
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
10.04.2017, 17:03
Ответы с готовыми решениями:

Краш при создании активности
public class Main_Activity extends Activity { private class LogIn extends AsyncTask&lt;Void, Void,...

Краш при воспроизведении звуков менее одной секунды
Делаю приложение ,в нем к нескольким кнопкам привязаны звуки , некоторые из них менее одной...

Краш при вызове UIImagePickerController
Всем привет вот такая дикая ошибка Snapshotting a view that has not been rendered results in an...

Краш при вызове LoadLibraryA
Всем привет! Вот код: .586 .model flat, stdcall extern LoadLibraryA@4:near includelib...

Краш при вызове setSource для QQuickWidget
Доброго времени суток! Пытаюсь запилить вменяемое меню. Пока что застрял на месте &quot;нажал на...

3
Pablito
2812 / 2236 / 754
Регистрация: 12.05.2014
Сообщений: 7,821
Завершенные тесты: 1
10.04.2017, 17:10 2
где лог ошибки?

Добавлено через 1 минуту
это не голая java, тут все начинается не с метода main()
а, грубо говоря, из onCreate() активити
0
Xme1ez
0 / 0 / 0
Регистрация: 08.12.2014
Сообщений: 37
10.04.2017, 17:15  [ТС] 3
как получить лог ошибки для android-проекта, если он компилируется без ошибок, а ошибка возникает на этапе выполнения приложения?
0
Pablito
2812 / 2236 / 754
Регистрация: 12.05.2014
Сообщений: 7,821
Завершенные тесты: 1
10.04.2017, 17:28 4
Что не так я делаю в адаптере?
0
MoreAnswers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
10.04.2017, 17:28

Краш приложения при вызове метода из другого класса через экземпляр
Привет Хочу вызвать метод из другого класса. Для это создаю экземпляр этого класса через...

При попытке openConnection() у Database выдает java.lang.NullPointerException
У меня возникла след. проблема. Было прога на Java для использования БД Oracle использовалсь...

Ошибка при вызове деструктора (при вызове delete в деструкторе)
Не могу найти ошибку, при вызове деструктора от класса, который был создан при помощи конструктора...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
4
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2019, vBulletin Solutions, Inc.
Рейтинг@Mail.ru