0

onCreate()代码开始TimerTask：

@Override
public void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.main);
Log.e(LOG_TAG, "Start Repeat Timer");
    TimerTask task = new RepeatingTask();
    Timer timer = new Timer();
    timer.scheduleAtFixedRate(task, 0, 3000);
    Log.e(LOG_TAG, "Started Repeat Timer");
}

定时器任务代码：

public class RepeatingTask extends TimerTask {
     //private int len = 0; 
     //private byte[] input = new byte[len];

     public RepeatingTask() {
            Log.e(LOG_TAG, "In RepeatingTask()");
            Log.e(LOG_TAG, "Before inputJSON String");

            String hello = "hello world";
            //String inputJSON = getStringFromBuffer(new InputStreamReader(socket.getInputStream()));
            try {
                    inputJSON = ConvertByteArrayToString(readBytes(inputStr));
                    sendBytes(ConvertStringToByteArray(inputJSON), 0, ConvertStringToByteArray(inputJSON).length);
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            //Convert 
            Log.e(LOG_TAG, "After inputJSON String:" + inputJSON); 


         //LOOK HERE FIRST  
         //inputJSON is what is received back from the server - Take the inputJSON 
         //String and use regular expressions HERE to remove all the other characters in the 
         //string except the payload JSON.
         //refreshViewModels(inputJSON);
     }

     @Override
     public void run() { 
          /*try {
              Log.e(LOG_TAG, "IN REPEATINGTHREAD-INPUTJSON");
              //outputstrwr.write(outputJSONserv);  //UNCOMMENT IF NEED TO SEND DATA TO GET JSON BACK
              //inputJSON = ConvertByteArrayToString(getBytesFromInputStream(inputStr));
              inputJSON = ConvertByteArrayToString(getFileBytes(inputStr));
          } catch (IOException e) {
              // TODO Auto-generated catch block
              e.printStackTrace();
          }

          Log.e(LOG_TAG, "IN REPEATINGTHREAD-INPUTJSON2:" + inputJSON);
          refreshViewModels(inputJSON);*/

      try {
          Log.e(LOG_TAG, "IN REPEATINGTHREAD-INPUTJSON");
          //outputstrwr.write(outputJSONserv);  //UNCOMMENT IF NEED TO SEND DATA TO GET JSON BACK
          //byte[] = myByteArray = readBytes(inputStr);
          sendBytes(ConvertStringToByteArray(outputJSONserv), 0, ConvertStringToByteArray(outputJSONserv).length);
          //sendBytes(myByteArray, 0, myByteArray.length);
          Log.e(LOG_TAG, "AFTER SENDING DATA");
          //inputJSON = ConvertByteArrayToString(getBytesFromInputStream(inputStr));
                  inputJSON = ConvertByteArrayToString(readBytes(inputStr));
                  Log.e(LOG_TAG, "IN REPEATINGTHREAD-INPUTJSON2:" + inputJSON);
          } 
      catch (IOException e) {
                  // TODO Auto-generated catch block
                  e.printStackTrace();
          }

      Log.e(LOG_TAG, "IN REPEATINGTHREAD-INPUTJSON3:" + inputJSON);
      refreshViewModels(inputJSON); 
     }
}

inputStrInputStream用于读取字节并将它们转换为字符串。

ConvertByteArrayToString()只需将字节数组转换为String&ConvertStringToByteArray()将 a 转换String为 aByte[]以便可以使用 . 发送数据sendBytes(byte[], int, int)。

我试图弄清楚为什么我的代码卡在这个 try/catch 语句中而没有抛出任何异常：

try {
                    inputJSON = ConvertByteArrayToString(readBytes(inputStr));
                    sendBytes(ConvertStringToByteArray(inputJSON), 0, ConvertStringToByteArray(inputJSON).length);
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }

这是我的sendBytes()方法：

 public void sendBytes(byte[] myByteArray, int start, int len) throws IOException {
        if (len < 0)
            throw new IllegalArgumentException("Negative length not allowed");
        if (start < 0 || start >= myByteArray.length)
            throw new IndexOutOfBoundsException("Out of bounds: " + start);
        // Other checks if needed.

        // May be better to save the streams in the support class;
        // just like the socket variable.
        OutputStream out = socket.getOutputStream(); 
        DataOutputStream dos = new DataOutputStream(out);

        dos.writeInt(len);
        if (len > 0) {
            dos.write(myByteArray, start, len);
        }
    }

这是getPayloadStr()方法：

    public String getPayloadStr(String profileString) {
        Log.e("LOG_TAG", "Profile Str:"+profileString);
        Pattern pattern = Pattern.compile(".*?payload\":(.*)\\}");

        Log.e("LOG_TAG", "I got here 1");
        Matcher matcher = pattern.matcher(profileString);
        Log.e("LOG_TAG", "I got here 12");
        //Matcher m = responseCodePattern.matcher(firstHeader);
        matcher.matches();
        matcher.groupCount();
        //matcher.group(0);
        Log.e("LOG_TAG", "I got here 2"+matcher.group(1));
        return matcher.group(1);
    }

这是我的readBytes()方法：

  public byte[] readBytes(InputStream in) throws IOException {
        // Again, probably better to store these objects references in the support class
        in = socket.getInputStream();
        DataInputStream dis = new DataInputStream(in);

        int len = dis.readInt();
        byte[] data = new byte[len];
        if (len > 0) {
            dis.readFully(data);
        }
        return data;
    }

任何正确方向的帮助或指示将不胜感激。通过聊天提供的任何帮助也将不胜感激。如果需要，可以在聊天会话中发布或查看整个文件。

4

1 回答 1

0

我的想法是：

  • 将其留空并设置断点以 run() -希望已命中，否则您将在日志中看到 IN REPEATINGTHREAD-INPUTJSON 消息。如果不是，那么我不知道问题出在哪里，因为代码似乎没问题。
  • 如果您看到，则问题出在构造函数中（问题1已隔离）

我认为这是问题所在：

int len = dis.readInt();

读取它是一种阻塞方法，因此您在 Even dispatcher 线程或 Main 线程或 Ui 线程中的代码 - 忘记了该平台上的名称是什么 - 可能正在等待，直到他可以读取 4 个字节。

根据此处的评论和代码请求，它是：

@Override
    public void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.main);
        Log.e(LOG_TAG, "Start Repeat Timer");

        Thread thInitializer = new Thread() {
            @Override
            public void run() {
                TimerTask task = new RepeatingTask(); // here will block until is readed from socket, but will not block the UI

                //after read is done you can set  breakpoint to next statement, but it will repet the run method of the RepeatingTask in each 3 sec
                Timer timer = new Timer();
                timer.scheduleAtFixedRate(task, 0, 3000);
                Log.e(LOG_TAG, "Started Repeat Timer");
            }
        };
        thInitializer.start();
        // UI initialization is done, background thread is running an trying to initialize the network stuff        
    }
于 2012-08-28T22:00:32.533 回答