我需要重復(fù)將數(shù)據(jù)發(fā)布到 php 并取回它們，但使應(yīng)用程序仍然可響應(yīng)。我的代碼可以工作，但一段時(shí)間后（大約 1 分鐘）我的應(yīng)用程序停止響應(yīng)。起初，我嘗試將 POST() 函數(shù)添加到 onResponse() 函數(shù)（onRespose 調(diào)用 POST 函數(shù)，一次又一次地發(fā)出新請(qǐng)求），但這凍結(jié)了我的應(yīng)用程序，所以我添加了每 1 毫秒調(diào)用一次函數(shù)的計(jì)時(shí)器...編輯后，我的應(yīng)用程序與以前一樣工作（僅在連接到電腦時(shí)才有效），如果我打開應(yīng)用程序并且我的手機(jī)未連接到電腦，應(yīng)用程序會(huì)在 1 分鐘后崩潰，所以我仍然遇到與開始時(shí)相同的問題。如果有人發(fā)現(xiàn)錯(cuò)誤請(qǐng)告訴我哪里。。..我編輯的代碼：.MainActivity.javapublic class MainActivity extends AppCompatActivity implements Sync.CallBack { final String URL = "***"; final String KEY = "***"; Data data; RequestQueue requestQueue; TextView textView; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); data = new Data(); data.key = KEY; data.pressed = "0"; textView = findViewById(R.id.status); requestQueue = Volley.newRequestQueue(this); StartSync(); } public void btnClick(View view) { data.pressed = "1"; } @Override public void onCallBack(String data) { textView.setText(data); } public void StartSync(){ Sync thread = new Sync(this,data,this); thread.start(); }}Sync.javapublic class Sync extends Thread{ private Context context; boolean wait = false; final String URL = "***"; public CallBack listener; RequestQueue requestQueue; public Data data; public interface CallBack{ void onCallBack(String data); } public Sync(CallBack listener,Data data,Context context){ this.listener = listener; this.data = data; this.context = context; requestQueue = Volley.newRequestQueue(context); }; @Override public void run() { while(true){ wait = true; POST(); while(wait){} } }
1 回答
RISEBY
TA貢獻(xiàn)1856條經(jīng)驗(yàn) 獲得超5個(gè)贊
好吧，我可以給你一個(gè)如何實(shí)現(xiàn)這一點(diǎn)的例子，但你確實(shí)需要研究我將使用的東西。
創(chuàng)建線程來(lái)發(fā)送和接收數(shù)據(jù)
public class myReceiveThread extends Thread{
public gotNewData listener;
//Create an interface to pass data to Activity
public interface gotNewData(){
void gotNewDataToDisplay(String data); //or int or data or what ever.
}
//CTor
public myThread(gotNewData listener){
this.listener = listener;
}
@Override
public void run(){
while(myAppisRunnung == true){
//Receive Data
listener.gotNewDataToDisplay("New Data");
}
}
}
在主要活動(dòng)中：
//In Main activity
public class MainActivity extends AppCompactActiity implements gotNewData{
//what ever
public void startThread(){
myReceiveThread thread = new myReceiveThread(this);
thread.start();
}
@Override
public void gotNewDataToDisplay(String data){
someTextView.setText(data);
}
}
創(chuàng)建發(fā)送線程
public class mySendingThread extends Thread{
private BlockingQueue<String> toSendMessages= new BlockingQueue<>();
Public mySendingThread (BlockingQueue<String> toSendMessages){
this.toSendMessages = toSendMessages;
}
@Override
public void run(){
while(myAppisRunnung == true){
String message= toSendMessages.take();
//Send message
}
}
}
在主要活動(dòng)中
public void startSendThread(){
mySendingThread threadSend = new mySendingThread(MessageQueue);
thread.start();
}
在 mainActivity 中，您需要一個(gè)BlockingQueue<String> MessageQueue 并且可以添加您想要的每條消息。
添加回答
舉報(bào)
0/150
提交
取消