2

Здравствуйте!

Не нашел толковых ответов на эту тему.

На данный момент для взаимодействия с "железякой" используются сокеты. Я создаю сокет(DatagramSocket) на одном мне нужном порту(можно выбирать и случайный), все дальнейшие операции должны производиться именно с этого порта. Таймаут выставлен в 1 секунду. Во все остальные части(другие потоки) я передаю именно этот созданный экземпляр сокета.

Взаимодействую с ними следующими образами:

  1. Периодический опрос(раз в 4 секунды) - этого требует устройство иначе оно выходит из режима "захвата". Использую встроенный механизм Android - Timer;
  2. Когда нужно получить какие-то данные с устройства или передать на него я создаю Thread, с помощью него отправляю запрос и получаю ответ. После того как работа законченна, тред останавливается(не зацикливаю);
  3. Поток который должен крутится постоянно и воспринимать только нужные пакеты данных, остальные игнорировать. Его запускаю и он просто должен крутится(В нем то и вся проблема, до этого обходился без него).

Проблема следующая: при введение пункта 3, приложение перестает работать, как-будто сокет постоянно занят. Пример кода(класс из вышеупомянутого пункта 3):

import android.os.Handler
import android.os.Message
import com.controller.labaratory.controller.App
import com.controller.labaratory.controller.models.Container
import java.net.*

/**
 * Created by ivan on 03/08/17.
 */
class DataPacketThread(val handler: Handler,
                       val socket: DatagramSocket,
                       val addres: InetAddress):Thread() {


    override fun run() {
        super.run()
        while (!socket.isClosed){
            try{
                //socket.soTimeout=0
                var buffer:ByteArray = kotlin.ByteArray(1024)
                val packet = DatagramPacket(buffer, buffer.size)

                socket?.receive(packet)

                val odin:Byte = -1

                if (!(buffer[0] == odin)){
                    if(packet.data[0].toInt() == 4){
                        val responseByteArray:ByteArray = byteArrayOf(1,33,
                                packet.data[2],packet.data[3])

                        val packetResponseAnswer = DatagramPacket(responseByteArray,
                                responseByteArray.size, addres, 1026)
                        socket?.send(packetResponseAnswer)

                        handler?.sendMessage(
                                Message.obtain(
                                        handler,
                                        App.UdpClientHandler.DATA_PACKET_RECEIVE,
                                        HandlerContainer(825, Container(
                                                packet.length,
                                                packet.data))))
                    }

                }
            } catch (e:SocketTimeoutException){
                e.printStackTrace()
            } catch (e:SocketException){
                e.printStackTrace()
            }

        }
    }

    fun end(){
        socket.close()
    }
}
5
  • 1
    поставьте небольшой слип в конце тела while
    – Lex Hobbit
    4 авг 2017 в 9:50
  • Спасибо, поставил. В принципе, помогло. Но видимо подводный камень в том, что в момент когда потоком(из пункта 3) занят сокет, другие не могут к нему обратится. То есть существует вероятность, "наслаивания"?Я верно понимаю? 4 авг 2017 в 10:13
  • правильно понимаете
    – Lex Hobbit
    4 авг 2017 в 12:39
  • Вам просто надо организовать всю вашу кухню либо в одном потоке, либо использовать single thread executor для запуска заданий последовательно. developer.android.com/reference/java/util/concurrent/… 8 авг 2017 в 8:57
  • В одном потоке попытался сделать. Возникло две трудности. 1. Задачи(запросы) друг друга перебивали. 2. Недостаточно быстро отвечает, там где нужна скорость. Я начал копать в сторно nio: ru.stackoverflow.com/questions/703286/… 8 авг 2017 в 9:08

1 ответ 1

0

Смог разделить прием и посылку пакетов по двум разным потокам(Thread). Ключевой код:

...
socket = new DatagramSocket(null);
socket.setReusedAdress(true);
socket.bind(new InetSocketAddress("your ip", port))
...   

Таким образом можно работать с одним и тем же сокет-портом из разных потоков, без блокировки.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.