सर्विस में सॉकेट क्लाइंट और ब्रॉडकास्टसीवर के माध्यम से यूआई को अपडेट करना

उद्देश्य:
क्लाइंट एप्लिकेशन को "सॉकेट्स" पर बनाएं, ताकि जब मुख्य गतिविधि बंद हो जाए, तो काम जारी रहे और कनेक्शन खो न जाए।

समाधान:
एंड्रॉइड में सेवाओं की मदद से ऐसा करना संभव है, एक सेवा क्या है और यह कैसे काम करती है, इसके बारे में बहुत सारे लेख लिखे गए हैं, इसलिए मैं विवरण में नहीं जाऊंगा और कार्यान्वयन के साथ आगे बढ़ूंगा।

हमारे आवेदन 3 सबसे महत्वपूर्ण वर्गों के होते हैं:

• MainActivity - गतिविधि जिसमें हम अपने सॉकेट क्लाइंट के काम का प्रदर्शन देखेंगे
• ServiceExchange - स्वयं सेवा
• सॉकेटसेन - हमारे अतुल्यकालिक सॉकेट क्लाइंट

MainActivity:

@Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); this.startService(new Intent(this, ServiceExchange.class)); //   } } private BroadcastReceiver broadcastReceiver = new BroadcastReceiver() { @Override public void onReceive(Context context, Intent intent) { onDataFromService(intent); } }; public void onResume() { super.onResume(); registerReceiver(broadcastReceiver, new IntentFilter(ServiceExchange.BROADCAST_ACTION)); } @Override public void onPause() { super.onPause(); unregisterReceiver(broadcastReceiver); } public void onDataFromService(Intent intent) { Log.d("onDataFromService", intent.getStringExtra("text")); } 

यहां हम अपनी सेवा शुरू करते हैं, और श्रोता "ब्रॉडकास्टइवर" को लॉन्च करते हैं, जो हमें सेवा से ऑनडेटाफ्रॉम सर्विस सेवा पर संदेश भेजेगा।
ServiceExchange.BROADCAST_ACTION को हमारे संदेश के साथ टैग किया जाना चाहिए, अन्यथा वे खो जाएंगे।

ServiceExchange:

 public class ServiceExchange extends Service { private Intent intent; public static final String BROADCAST_ACTION = "com.rheit.base.event"; //    @Override public void onCreate() { super.onCreate(); intent = new Intent(BROADCAST_ACTION); createConnect(); } Handler myUpdateHandler = new Handler() { public void handleMessage(Message msg) { switch (msg.what) { case config.ERR_SOCKET_SERVER_UNAVAILABLE: //    createConnect(); //  sendBroadcast((Intent) msg.obj); //    UI break; case config.CODE_SOCKET_SERVER_ANSWER: //     //        sendBroadcast((Intent) msg.obj); //    UI break; case config.CODE_SOCKET_SERVER_CONNECTED: //     //        sendBroadcast((Intent) msg.obj); //    UI break; default: break; } super.handleMessage(msg); } }; @Override public IBinder onBind(Intent arg0) { Log.v(this.getClass().getName(), "---> Service binded."); return null; } @Override public void onDestroy() { Toast.makeText(this, "Service destoyed", Toast.LENGTH_LONG).show(); Log.v(this.getClass().getName(), "Service destoyed."); } private void createConnect() { if (ServerTask == null || ServerTask.getStatus().equals(AsyncTask.Status.FINISHED)) { ServerTask = new SocketAsync(myUpdateHandler); ServerTask.execute(); config.SOCKET_MESSAGE = ServerCommands.login("name", "pass"); } } } 

सेवा सॉकेटसेन्स क्लास के माध्यम से सर्वर से कनेक्शन के नियंत्रण को लागू करती है, और सॉकेटएस्क्यू से ब्रॉडकास्टरीवर के माध्यम से मेनएक्टिविटी को डेटा ट्रांसफर करती है।

SocketAsync:

 class SocketAsync extends AsyncTask<Void, Integer, Void> { public Socket socket; public String message; public Handler threadHandler; public Context parent; public SocketAsync(Handler threadHandler) { this.threadHandler = threadHandler; } @Override protected Void doInBackground(Void... params) { try { if (config.SOCKET_CONNECTED == false) { InetAddress serverAddr = InetAddress .getByName(config.SERVER_ADDR); socket = new Socket(serverAddr, config.SERVER_PORT); config.SOCKET_CONNECTED = true; Intent intent = new Intent(ServiceExchange.BROADCAST_ACTION); intent.putExtra("SERVER_STATUS", true); Message threadMessage = new Message(); threadMessage.what = com.rheit.config.CODE_SOCKET_SERVER_CONNECTED; threadMessage.obj = intent; threadHandler.sendMessage(threadMessage); } } catch (Exception e) { Intent intent = new Intent(ServiceExchange.BROADCAST_ACTION); intent.putExtra("SERVER_STATUS", false); Message threadMessage = new Message(); threadMessage.what = com.rheit.config.ERR_SOCKET_SERVER_UNAVAILABLE; threadMessage.obj = intent; threadHandler.sendMessage(threadMessage); Log.e(SocketAsync.class.toString(), "ERR_SOCKET_SERVER_UNAVAILABLE doInBackground"); } Thread threadWrite = new Thread(new Runnable() { @Override public void run() { send(socket); } }); threadWrite.start(); //    while (socket != null && socket.isConnected()) { Message m = new Message(); m.what = config.CODE_SOCKET_SERVER_ANSWER; try { BufferedReader input = new BufferedReader( new InputStreamReader(socket.getInputStream())); String st = null; st = input.readLine(); if (st == null) { threadWrite.stop(); socket.close(); socket = null; } else { m.obj = st; myUpdateHandler.sendMessage(m); } } catch (IOException e) { e.printStackTrace(); } } threadWrite.stop(); return null; } protected void send(Socket socket) { while (socket != null && socket.isConnected()) { if (config.SOCKET_MESSAGE != null) { Log.d("Send Message", config.SOCKET_MESSAGE); try { PrintWriter out = new PrintWriter(new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())), true); out.println(config.SOCKET_MESSAGE); } catch (Exception e) { Log.e("TCP", "S: Error", e); return; } config.SOCKET_MESSAGE = null; } } } protected void onProgressUpdate(Integer... values) { super.onProgressUpdate(values); if (values.length > 0) { Log.d("onProgressUpdate", values[0].toString()); } } @Override protected void onPostExecute(Void result) { super.onPostExecute(result); if (socket == null || !socket.isConnected()) { config.SOCKET_CONNECTED = false; try { Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); } Intent intent = new Intent(ServiceExchange.BROADCAST_ACTION); intent.putExtra("SERVER_STATUS", false); Message threadMessage = new Message(); threadMessage.what = com.rheit.config.ERR_SOCKET_SERVER_UNAVAILABLE; threadMessage.obj = intent; threadHandler.sendMessage(threadMessage); Log.e(SocketAsync.class.toString(), "ERR_SOCKET_SERVER_UNAVAILABLE onPostExecute"); } } Handler myUpdateHandler = new Handler() { public void handleMessage(Message msg) { switch (msg.what) { case config.CODE_SOCKET_SERVER_ANSWER: Intent intent = new Intent(ServiceExchange.BROADCAST_ACTION); intent.putExtra("text", "test"); Message threadMessage = new Message(); threadMessage.what = com.rheit.config.CODE_SOCKET_SERVER_ANSWER; threadMessage.obj = intent; threadHandler.sendMessage(threadMessage); break; default: break; } super.handleMessage(msg); } }; } 

जब हमने सॉकेटसेन्स टास्क शुरू किया, तो हमने सर्वर से कनेक्ट करना शुरू किया; यदि हम कनेक्ट होते हैं, तो हम यूआई को एक संदेश भेजते हैं, जो इसके माध्यम से कनेक्ट होता है:

 Intent intent = new Intent(ServiceExchange.BROADCAST_ACTION); intent.putExtra("SERVER_STATUS", true); Message threadMessage = new Message(); threadMessage.what = com.rheit.config.CODE_SOCKET_SERVER_CONNECTED; threadMessage.obj = intent; threadHandler.sendMessage(threadMessage); 

तब यह हमारे द्वारा बनाए गए myUpdateHandler में ServiceExchange में हो जाता है , जो बदले में UI को sendBroadcast के माध्यम से डेटा पास करता है:

 case config.CODE_SOCKET_SERVER_CONNECTED: //     //        sendBroadcast((Intent) msg.obj); //    UI break; 

जिसके बाद हमारा डेटा MainActivity को ट्रांसफर कर दिया जाता है:

 private BroadcastReceiver broadcastReceiver = new BroadcastReceiver() { @Override public void onReceive(Context context, Intent intent) { onDataFromService(intent); } }; public void onDataFromService(Intent intent) { Log.d("onDataFromService", intent.getStringExtra("text")); } 

जब हम अपना एप्लिकेशन बंद करते हैं, तो unregisterReceiver फ़ंक्शन श्रोता को नष्ट कर देता है और हमारे सॉकेट क्लाइंट से ट्रांसफर की जाने वाली हर चीज़ खो जाती है, इसके लिए मैं बाहर से आने वाले डेटा की सलाह देता हूं, डेटाबेस को लिखता हूं और इस बात की सूचना देता हूं कि आपको डेटाबेस से कुछ पढ़ने की जरूरत है।