👷 ▫️ 🌛 जीवन या आलस्य के लिए रिमोट कंट्रोल के साथ

ध्यान आकर्षित करने के लिए एक तस्वीर, वास्तविक जीवन से समानता दूर है

मैं एक और लेख लिखूंगा। पहले से उल्लेख किए गए फ़ोल्डर "प्रोजेक्ट्स / 4 फ़न" से आपकी एक परियोजना के बारे में। यह परियोजना 4Fun के रूप में शुरू हुई, और 4Use के रूप में समाप्त हुई। यही है, यह समय-समय पर आज तक उपयोग किया जाता है। और ऐसा था ...

समस्या एक

हम सभी को तेली देखना बहुत पसंद है। वैसे तो लगभग सभी को प्यार होता है। मैं कोई अपवाद नहीं हूं। लेकिन एक तेली को देखने के लिए, आपके पास यह होना चाहिए। लेकिन मुझे इससे कुछ समस्याएं थीं। मेरे पास यह (तेली) नहीं है। और वह वहां नहीं था क्योंकि आमतौर पर टेली किराए के अपार्टमेंट से जुड़ी होती थी जिसमें मैं रहता था। लेकिन तब मैं टीवी के बिना एक अपार्टमेंट में आया था। और इस समस्या को किसी तरह हल करना पड़ा।

निर्णय एक

अपने जीवन में एक पर्याप्त ~~प्यासा~~ व्यक्ति होने के नाते, मैंने एक टैली नहीं खरीदने का फैसला किया, लेकिन एक टीवी ट्यूनर - यह शायद पहला विचार है जो एक समान स्थिति में कंप्यूटर तकनीशियन के दिमाग में आना चाहिए। सोचा - किया हुआ। मेरे एक साथी सिर्फ एक टीवी ट्यूनर को बेचना चाहते थे। यहाँ ऐसा है, लगभग:

सामान्य तौर पर, मैंने इसे खरीदा। हाँ, यह केवल था ...

दूसरी समस्या

यह पता चला कि रिमोट कंट्रोल अनियमित रूप से खो गया था और इसे बहाल नहीं किया जा सकता था। और मैं चैनलों को स्विच करना चाहता हूं और सोफे पर पड़ी ध्वनि (साधारण और समझने योग्य खुशियाँ) को समायोजित करना चाहता हूं। फिर मस्तिष्क विभाग जुड़े समाधान खोजने के लिए जिम्मेदार है। तुरंत स्पष्ट रूप से स्पष्ट था - एक और रिमोट कंट्रोल खोजने के लिए और किसी तरह ट्यूनर के साथ दोस्त बनाने के लिए। लेकिन यह फिट नहीं था, क्योंकि देशी रिमोट कंट्रोल के साथ, सिग्नल रिसीवर खो गया था (ऐसा लगता है, यह बहुत समय पहले था)। ठीक है, किसी तरह यह प्रोग्रामर या कुछ में नहीं है - "हमारे पास अपना रास्ता है" (ग)। इसलिए, यह भीख माँगता है ...

दूसरा फैसला

टीवी देखने के लिए, मैं अपने मूल ट्यूनर ऐप का उपयोग करता हूं - बीहोल्डटीवी। आप ऊपर और नीचे कुंजियों का उपयोग करके इसमें चैनल स्विच कर सकते हैं, ध्वनि को दाईं / बाईं ओर समायोजित कर सकते हैं, आदि। इसलिए, निम्नलिखित सोचा गया था: कंप्यूटर पर एक सर्वर लिखें जो किस्ट्रोक्स का अनुकरण करेगा, और मोबाइल पर क्लाइंट सर्वर की आवश्यक कुंजी के कोड भेज देगा, और सब कुछ ठीक हो जाएगा। तो अंत में यह (अच्छा) निकला।

सर्वर को Windows के तहत C ++ और WinAPI में लिखा गया था। यह सरल है: हम "मैं टीवी सेट को नियंत्रित करने के लिए एक सर्वर हूं" फॉर्म के यूडीपी संदेशों के माध्यम से प्रसारण के लिए धारा शुरू करता हूं और ग्राहकों को कनेक्ट करने के लिए प्रतीक्षा करता हूं। इसलिए कोई भी क्लाइंट सर्वर की लोकेशन का पता लगा सकेगा, और किसी हार्डकोड आईपी की जरूरत नहीं होगी। और इसलिए यह सही है (मुझे लगता है)।

क्लाइंट कनेक्ट होता है, सर्वर आने वाली कमांड को सुनना शुरू कर देता है। जैसे ही मैंने कुछ सुना, यह एक कीस्ट्रोक का अनुकरण करता है। सब कुछ सरल है और एक फाइल में फिट बैठता है:

सर्वर कोड

// Roco.cpp : Defines the entry point for the console application. // #include "stdafx.h" #include <winsock2.h> #pragma comment(lib, "Ws2_32.lib") void broadcastThreadFunction(void *context) { const SOCKET *broadcastSocket = (SOCKET*)context; sockaddr_in broadcastSocketServiceInfo; ZeroMemory(&broadcastSocketServiceInfo, sizeof(broadcastSocketServiceInfo)); broadcastSocketServiceInfo.sin_family = AF_INET; broadcastSocketServiceInfo.sin_addr.s_addr = htonl(INADDR_BROADCAST); broadcastSocketServiceInfo.sin_port = htons(28777); static const char broadcastMessage[] = "ROCO-BROADCAST-MESSAGE"; do { const int result = sendto(*broadcastSocket, broadcastMessage, sizeof(broadcastMessage), 0, (SOCKADDR*)&broadcastSocketServiceInfo, sizeof(broadcastSocketServiceInfo)); if (result == SOCKET_ERROR && ::WSAGetLastError() == WSAENOTSOCK) { break; } ::Sleep(300); } while (true); _endthread(); } int _tmain(int argc, _TCHAR* argv[]) { if (argc >= 2 && _tcscmp(argv[1], _T("/silent")) == 0) { ::ShowWindow(::GetConsoleWindow(), SW_HIDE); } WSADATA wsaData; ZeroMemory(&wsaData, sizeof(wsaData)); printf("Initializing network... "); int result = ::WSAStartup(MAKEWORD(2,2), &wsaData); if (result == NO_ERROR) { printf("Done.\n"); printf("Creating broadcast socket... "); const SOCKET broadcastSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); if (broadcastSocket != INVALID_SOCKET) { printf("Done.\n"); static const BOOL onValue = TRUE; setsockopt(broadcastSocket, SOL_SOCKET, SO_BROADCAST, (const char*)&onValue, sizeof(onValue)); printf("Starting broadcast thread... "); HANDLE broadcastThreadHandle =(HANDLE)_beginthread(broadcastThreadFunction, 0, (void*)&broadcastSocket); if (broadcastThreadHandle != INVALID_HANDLE_VALUE) { printf("Done.\n"); printf("Creating listen socket... "); const SOCKET listenSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if (listenSocket != INVALID_SOCKET) { printf("Done.\n"); printf("Binding listen socket... "); sockaddr_in listenSocketServiceInfo; ZeroMemory(&listenSocketServiceInfo, sizeof(listenSocketServiceInfo)); listenSocketServiceInfo.sin_family = AF_INET; listenSocketServiceInfo.sin_addr.s_addr = htonl(INADDR_ANY); listenSocketServiceInfo.sin_port = htons(28666); result = bind(listenSocket, (SOCKADDR*)&listenSocketServiceInfo, sizeof(listenSocketServiceInfo)); if (result != SOCKET_ERROR) { printf("Done.\n"); printf("Listening for incoming connection... "); result = listen(listenSocket, SOMAXCONN); if (result != SOCKET_ERROR) { printf("Done.\n"); unsigned connectionIndex = 0; do { printf("Accepting incoming connection #%d... ", connectionIndex + 1); ::ResumeThread(broadcastThreadHandle); SOCKET commandSocket = accept(listenSocket, NULL, NULL); if (commandSocket != INVALID_SOCKET) { printf("Done.\n"); ::SuspendThread(broadcastThreadHandle); printf("Sending PING to command socket... "); static const char ping[] = "PING"; result = send(commandSocket, ping, sizeof(ping), 0); if (result != SOCKET_ERROR && result == sizeof(ping)) { printf("Done.\n"); printf("Receiving PONG from command socket... "); static char pong[sizeof("PONG")]; pong[0] = '\0'; result = recv(commandSocket, pong, sizeof(pong), 0); if (result != SOCKET_ERROR && result == sizeof(pong) && strcmp(pong, "PONG") == 0) { printf("Done.\n"); unsigned commandIndex = 0; do { printf("Waiting for command #%d...\n", commandIndex + 1); static char command[2]; ZeroMemory(command, sizeof(command)); result = recv(commandSocket, command, sizeof(command), 0); if (result != SOCKET_ERROR && result == sizeof(command)) { enum { CC_KEY_DOWM = 1, CC_KEY_UP = 0 }; const char commandCode = command[0]; const char keyCode = command[1]; static const char res = 1; switch (commandCode) { case CC_KEY_DOWM: { printf("KEY_DOWN(%d)\n", keyCode); keybd_event(keyCode, 0, 0, 0); send(commandSocket, &res, sizeof(res), 0); } break; case CC_KEY_UP: { printf("KEY_UP(%d)\n", keyCode); keybd_event(keyCode, 0, KEYEVENTF_KEYUP, 0); send(commandSocket, &res, sizeof(res), 0); } break; default: { printf("Invalid command received - %d!\n", commandCode); } break; } } else { printf("Could not receive command from socket (error - %d)!\n", ::WSAGetLastError()); break; } ++commandIndex; } while (true); } else { printf("\nCould not receive PONG from command socket (error - %d)!\n", ::WSAGetLastError()); } } else { printf("\nCould not sent PING to command socket (error - %d)!\n", ::WSAGetLastError()); } } else { printf("\nCould not accept incoming connection (error - %d)!\n", ::WSAGetLastError()); } ++connectionIndex; } while (true); } else { printf("\nCould not listen for incoming connection (error - %d)!\n", ::WSAGetLastError()); } } else { printf("\nCould not bind listen socket (error - %d)!\n", ::WSAGetLastError()); } closesocket(listenSocket); } else { printf("\nCould not create listen socket (error - %d)!\n", ::WSAGetLastError()); } } else { printf("\nCould not start broadcast thread!\n"); } ::ResumeThread(broadcastThreadHandle); closesocket(broadcastSocket); ::WaitForSingleObject(broadcastThreadHandle, INFINITE); } else { printf("\nCould not create broadcast socket (error - %d)!\n", ::WSAGetLastError()); } ::WSACleanup(); } else { printf("\nWSAStartup failed (error - %d)!", result); } return 0; }

सर्वर प्रमुख के साथ शुरू होता है। सर्वर एक कंसोल उपयोगिता है (लॉग देखने के लिए सुविधाजनक, यदि वह है), तो लॉन्च के ठीक बाद इस लाइन की आवश्यकता है:

 ::ShowWindow(::GetConsoleWindow(), SW_HIDE);

मेरे पास एंड्रॉइड पर एक मोबाइल है, इसलिए क्लाइंट ने जावा पर मूल लिखा है। परिणाम एक ऐसा सुपर-मेगा इंटरफ़ेस है:

क्लाइंट स्रोत भी काफी सरल है। हम इंटरफ़ेस को प्रोग्रामेटिक रूप से जेनरेट करते हैं, प्रत्येक बटन के लिए सर्वर पर कुंजी कोड भेजते हैं। क्लाइंट शुरू करते समय, हम सर्वर के स्थान की तलाश करते हैं, कनेक्ट करते हैं। यह इस तरह दिखता है:

ग्राहक कोड

 package com.dummy.roco; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetSocketAddress; import java.net.Socket; import java.util.Timer; import java.util.TimerTask; import android.net.wifi.WifiManager; import android.net.wifi.WifiManager.MulticastLock; import android.os.Bundle; import android.os.StrictMode; import android.os.Vibrator; import android.app.Activity; import android.app.AlertDialog; import android.content.Context; import android.content.DialogInterface; import android.view.KeyEvent; import android.view.MotionEvent; import android.view.View; import android.view.ViewGroup.LayoutParams; import android.widget.Button; import android.widget.LinearLayout; public class RemoteControlActivity extends Activity { protected static class ButtonInfo { public final String text_; public final int code_; public ButtonInfo(final String text, final int code) { text_ = text; if (code != 0) { code_ = code; } else { code_ = text.codePointAt(0); } } } protected static class CommandButton extends Button { protected ButtonInfo buttonInfo_; protected Socket commandSocket_; protected Vibrator vibrator_; protected Timer commandTimer_; protected final int COMMAND_DELAY = 200; public CommandButton(final Context context, final ButtonInfo buttonInfo, final Socket commandSocket, final Vibrator vibrator) { super(context); buttonInfo_ = buttonInfo; commandSocket_ = commandSocket; vibrator_ = vibrator; setText(buttonInfo_.text_); setTextSize(getTextSize()); setOnTouchListener(new OnTouchListener() { @Override public boolean onTouch(View v, MotionEvent event) { switch (event.getAction()) { case MotionEvent.ACTION_DOWN: startCommandTimer(); break; case MotionEvent.ACTION_UP: stopCommandTimer(); break; } return false; } }); } protected void sendCommand(final int commandCode, final int buttonCode) { final byte command[] = { (byte) commandCode, (byte) buttonCode }; try { commandSocket_.getOutputStream().write(command); } catch (Exception exception) { exception.printStackTrace(); } } public void startCommandTimer() { vibrator_.vibrate(10); sendCommand(CC_KEY_DOWM, buttonInfo_.code_); commandTimer_ = new Timer(); commandTimer_.schedule(new TimerTask() { @Override public void run() { sendCommand(CC_KEY_DOWM, buttonInfo_.code_); } }, COMMAND_DELAY, COMMAND_DELAY); } public void stopCommandTimer() { commandTimer_.cancel(); commandTimer_.purge(); commandTimer_ = null; sendCommand(CC_KEY_UP, buttonInfo_.code_); vibrator_.vibrate(10); } } protected static final ButtonInfo buttonInfos_[][] = { { new ButtonInfo("1", 0), new ButtonInfo("2", 0), new ButtonInfo("3", 0) }, { new ButtonInfo("4", 0), new ButtonInfo("5", 0), new ButtonInfo("6", 0) }, { new ButtonInfo("7", 0), new ButtonInfo("8", 0), new ButtonInfo("9", 0) }, { new ButtonInfo("¾", 8), new ButtonInfo("↑", 38), new ButtonInfo("¤", 77) }, { new ButtonInfo("←", 37), new ButtonInfo("®", 13), new ButtonInfo("→", 39) }, { new ButtonInfo("§", 32), new ButtonInfo("↓", 40), new ButtonInfo("«", 27) } }; protected static final int CC_KEY_DOWM = 1; protected static final int CC_KEY_UP = 0; protected final Socket commandSocket_ = new Socket(); protected Vibrator vibrator_; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); vibrator_ = (Vibrator) getSystemService(VIBRATOR_SERVICE); final LinearLayout mainLayout = new LinearLayout(this); mainLayout.setOrientation(LinearLayout.VERTICAL); for (int i = 0; i < buttonInfos_.length; ++i) { final LinearLayout rowLayout = new LinearLayout(this); rowLayout.setOrientation(LinearLayout.HORIZONTAL); for (int j = 0; j < buttonInfos_[i].length; ++j) { final CommandButton button = new CommandButton(this, buttonInfos_[i][j], commandSocket_, vibrator_); final LinearLayout.LayoutParams layoutParams = new LinearLayout.LayoutParams( LayoutParams.MATCH_PARENT, LayoutParams.MATCH_PARENT); layoutParams.weight = 1.0f; rowLayout.addView(button, layoutParams); } final LinearLayout.LayoutParams layoutParams = new LinearLayout.LayoutParams( LayoutParams.MATCH_PARENT, LayoutParams.MATCH_PARENT); layoutParams.weight = 1.0f; mainLayout.addView(rowLayout, layoutParams); } setContentView(mainLayout, new LayoutParams(LayoutParams.MATCH_PARENT, LayoutParams.MATCH_PARENT)); MulticastLock multicastLock = null; DatagramSocket broadcastSocket = null; try { StrictMode.setThreadPolicy(new StrictMode.ThreadPolicy.Builder() .permitAll().build()); final WifiManager wifiManager = (WifiManager) getSystemService(Context.WIFI_SERVICE); if (wifiManager != null) { multicastLock = wifiManager .createMulticastLock("ROCO-MulticastLock"); } if (multicastLock != null) { multicastLock.acquire(); } broadcastSocket = new DatagramSocket(28777); broadcastSocket.setBroadcast(true); broadcastSocket.setSoTimeout(1000); final byte[] datagramPacketData = new byte["ROCO-BROADCAST-MESSAGE\0" .length()]; final DatagramPacket datagramPacket = new DatagramPacket( datagramPacketData, datagramPacketData.length); broadcastSocket.receive(datagramPacket); if (new String(datagramPacketData) .compareTo("ROCO-BROADCAST-MESSAGE\0") != 0) { throw new Exception("Could not get ROCO server address!"); } commandSocket_.setSoTimeout(500); commandSocket_.connect(new InetSocketAddress(datagramPacket .getAddress().getHostAddress(), 28666), commandSocket_ .getSoTimeout()); final byte ping[] = new byte["PING\0".length()]; commandSocket_.getInputStream().read(ping); if (new String(ping).compareTo("PING\0") != 0) { throw new Exception( "Could not receive PING from command socket!"); } commandSocket_.getOutputStream().write( new String("PONG\0").getBytes()); } catch (Exception exception) { final AlertDialog alertDialog = new AlertDialog.Builder(this) .create(); alertDialog.setCancelable(false); alertDialog.setTitle("Roco: Error"); alertDialog .setMessage("Could not connect to the server!\nError - '" + exception.toString() + "'\n\nExiting..."); alertDialog.setButton(AlertDialog.BUTTON_POSITIVE, "OK", new DialogInterface.OnClickListener() { @Override public void onClick(DialogInterface dialog, int which) { dialog.dismiss(); finish(); } }); alertDialog.show(); } finally { if (broadcastSocket != null) { broadcastSocket.close(); } if (multicastLock != null && multicastLock.isHeld()) { multicastLock.release(); } } } @Override protected void onDestroy() { try { commandSocket_.close(); } catch (Exception exception) { exception.printStackTrace(); } super.onDestroy(); } @Override public boolean onKeyDown(int keyCode, KeyEvent event) { if ((keyCode == KeyEvent.KEYCODE_BACK)) { finish(); } return super.onKeyDown(keyCode, event); } }

परियोजना बहुत पहले लिखी गई थी, और व्यावसायिकता अभी भी खड़ा नहीं है। अब, शायद, मैं सब कुछ इतना अनाड़ी नहीं लिखूंगा (शायद आधिकारिक एपीआई का उपयोग करके, जिसे मैंने परियोजना लिखने के बाद सीखा)। फिर भी, सब कुछ stably काम करता है और समय-समय पर उपयोग किया जाता है।

एक दिलचस्प साइड इफेक्ट है - यदि आप टैली नहीं देखते हैं, लेकिन, कहते हैं, YouTube, तो खिलाड़ी को रोका जा सकता है। और ठहराव भी।

सामान्य तौर पर, यह शांत, उपयोगी, सस्ता और हंसमुख निकला।

प्रोजेक्ट को रोको कहा जाता है। कौन अनुमान लगाता है कि ऐसा क्यों है - टिप्पणियों में लिखें। गौरव और सम्मान पाया।

वैसे, हाल ही में मैं शायद ही कभी घड़ी। ज्यादातर डाउनलोड की गई फिल्में या ऑनलाइन। यह अच्छा है कि मैंने तब इसे नहीं खरीदा था। लेकिन अब मैं खरीदने के बारे में सोच रहा हूं। किसी तरह का विरोधाभास निकला ...

जीवन या आलस्य के लिए रिमोट कंट्रोल के साथ - प्रगति का इंजन

समस्या एक

निर्णय एक

दूसरी समस्या

दूसरा फैसला

More articles: