سلام
مشکلی که من دارم اینه که udp میخوام هر 20 میلی ثانیه دیتای که بهش وارد میشه رو بگیره
این کار وقتی دیتا 100ثانیه هست مشکلی نداره
ولی وقتی دیتای که وارد udp میشه رو میگره بعد یه مدت دیگه نمیتونه بگیره
مشکل کار من از کجاس؟؟
package com.example.ehsancompany.upd_ehsan;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
public class MainActivity extends AppCompatActivity {
EditText editTextAddress, editTextPort;
Button buttonConnect;
TextView textViewState, textViewRx;
UdpClientHandler udpClientHandler;
UdpClientThread udpClientThread;
private static final String TAG = "MainActivity";
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
buttonConnect = (Button) findViewById(R.id.connect);
textViewState = (TextView)findViewById(R.id.state);
textViewRx = (TextView)findViewById(R.id.received);
buttonConnect.setOnClickListener(buttonConnectOnCl ickListener);
udpClientHandler = new UdpClientHandler(this);
final Handler handler = new Handler();
handler.postDelayed(new Runnable() {
public void run() {
// udpClientThread = null;
// udpClientThread = new UdpClientThread("192.168.16.254",8080, udpClientHandler);
// udpClientThread.start();
handler.postDelayed(this, 10);
}
}, 10);
}
View.OnClickListener buttonConnectOnClickListener =
new View.OnClickListener() {
@Override
public void onClick(View arg0) {
udpClientThread = new UdpClientThread("192.168.16.254",8080, udpClientHandler);
udpClientThread.start();
buttonConnect.setEnabled(false);
}
};
private void updateState(String state){
textViewState.setText(state);
}
private void updateRxMsg(String rxmsg){
textViewRx.setText(rxmsg);
}
private void clientEnd(){
udpClientThread = null;
textViewState.setText("clientEnd()");
udpClientThread = new UdpClientThread("192.168.16.254",8080, udpClientHandler);
udpClientThread.start();
// buttonConnect.setEnabled(true);
}
public static class UdpClientHandler extends Handler {
public static final int UPDATE_STATE = 0;
public static final int UPDATE_MSG = 1;
public static final int UPDATE_END = 2;
private MainActivity parent;
public UdpClientHandler(MainActivity parent) {
super();
this.parent = parent;
}
@Override
public void handleMessage(Message msg) {
switch (msg.what){
case UPDATE_STATE:
parent.updateState((String)msg.obj);
break;
case UPDATE_MSG:
parent.updateRxMsg((String)msg.obj);
break;
case UPDATE_END:
parent.clientEnd();
break;
default:
super.handleMessage(msg);
}
}
}
public class UdpClientThread extends Thread{
String dstAddress;
int dstPort;
private boolean running;
MainActivity.UdpClientHandler handler;
DatagramSocket socket;
InetAddress address;
public UdpClientThread(String addr, int port, MainActivity.UdpClientHandler handler) {
super();
dstAddress = addr;
dstPort = port;
this.handler = handler;
}
public void setRunning(boolean running){
this.running = running;
}
private void sendState(String state){
handler.sendMessage(
Message.obtain(handler,
MainActivity.UdpClientHandler.UPDATE_STATE, state));
}
@Override
public void run() {
sendState("connecting...");
running = true;
try {
socket = new DatagramSocket();
address = InetAddress.getByName(dstAddress);
// send request
byte[] buf = new byte[256];
DatagramPacket packet = new DatagramPacket(buf, buf.length, address, dstPort);
socket.send(packet);
sendState("connected");
// get response
packet = new DatagramPacket(buf, buf.length);
socket.receive(packet);
String line = new String(packet.getData(), 0, packet.getLength());
handler.sendMessage(
Message.obtain(handler, MainActivity.UdpClientHandler.UPDATE_MSG, line));
} catch (SocketException e) {
e.printStackTrace();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
if(socket != null){
socket.close();
handler.sendEmptyMessage(MainActivity.UdpClientHan dler.UPDATE_END);
}
}
}
}
}
پاسخ با نقل قول
نوشته شده توسط مهدی کرامتی
