Kablosuz Doğrudan Bağlantı (P2P), uygun donanıma sahip cihazların arada bir erişim noktası olmadan kablosuz bağlantı üzerinden doğrudan birbirine bağlanmasına olanak tanır. Bu API'leri kullanarak, her cihaz Wi-Fi P2P'yi desteklediğinde diğer cihazları keşfedip onlara bağlanabilir, ardından Bluetooth bağlantısından çok daha uzun mesafelerde hızlı bir bağlantı üzerinden iletişim kurabilirsiniz. Bu, çok oyunculu oyun veya fotoğraf paylaşımı uygulaması gibi kullanıcılar arasında paylaşılan verileri paylaşan uygulamalar için kullanışlıdır.
Kablosuz P2P API'leri aşağıdaki ana bölümlerden oluşur:
- Eşleri keşfetmenize, onlara istek göndermenize ve bağlanmanıza olanak tanıyan yöntemler. Bu yöntemler
WifiP2pManagersınıfında tanımlanır. WifiP2pManageryöntem çağrılarının başarılı veya başarısız olduğunu size bildiren dinleyiciler.WifiP2pManageryöntemleri çağrılırken her yöntem, parametre olarak iletilen belirli bir dinleyiciyi alabilir.- Kablosuz P2P çerçevesi tarafından algılanan belirli etkinlikleri (ör. bağlantının kesilmesi veya yeni keşfedilen bir eş) size bildiren intent'ler.
API'lerin bu üç ana bileşenini genellikle birlikte kullanırsınız. Örneğin, discoverPeers() çağrısına bir WifiP2pManager.ActionListener sağlayarak ActionListener.onSuccess() ve ActionListener.onFailure() yöntemlerinin sizi bilgilendirmesini sağlayabilirsiniz. discoverPeers() yöntemi, eşler listesinin değiştiğini tespit ederse bir WIFI_P2P_PEERS_CHANGED_ACTION intent'i de yayınlanır.
API'ye genel bakış
WifiP2pManager sınıfı, cihazınızdaki kablosuz donanımla etkileşim kurarak eşleri keşfetme ve onlara bağlanma gibi işlemleri yapmanızı sağlayan yöntemler sunar.
Aşağıdaki işlemler kullanılabilir:
Tablo 1. Kablosuz P2P Yöntemleri
| Yöntem | Açıklama |
initialize()
|
Uygulamayı kablosuz ağ çerçevesine kaydeder. Başka bir kablosuz P2P yöntemini çağırmadan önce bunu çağırın. |
connect()
|
Belirtilen yapılandırmaya sahip bir cihazla eşler arası bağlantı başlatır. |
cancelConnect()
|
Devam eden tüm eşler arası grup görüşmelerini iptal eder. |
requestConnectInfo()
|
Cihazın bağlantı bilgilerini ister. |
createGroup()
|
Mevcut cihazın grup sahibi olduğu bir benzerler grubu oluşturur. |
removeGroup()
|
Mevcut benzerler grubunu kaldırır. |
requestGroupInfo()
|
Benzerler grubu bilgilerini ister. |
discoverPeers()
|
Eş keşfini başlatır. |
requestPeers()
|
Keşfedilen eşlerin mevcut listesini ister. |
WifiP2pManager yöntemleri, bir dinleyici iletmenize olanak tanır. Böylece kablosuz P2P çerçevesi, etkinliğinize bir çağrının durumu hakkında bildirim gönderebilir. Kullanılabilir dinleyici arayüzleri ve dinleyicileri kullanan ilgili WifiP2pManager yöntem çağrıları Tablo 2'de açıklanmıştır.
Tablo 2. Kablosuz P2P işleyiciler
| Dinleyici arayüzü | İlişkili işlemler |
WifiP2pManager.ActionListener
|
connect(), cancelConnect(),
createGroup(), removeGroup() ve
discoverPeers()
|
WifiP2pManager.ChannelListener
|
initialize()
|
WifiP2pManager.ConnectionInfoListener
|
requestConnectInfo()
|
WifiP2pManager.GroupInfoListener
|
requestGroupInfo()
|
WifiP2pManager.PeerListListener
|
requestPeers()
|
Kablosuz P2P API'leri, belirli kablosuz P2P etkinlikleri gerçekleştiğinde (ör. yeni bir eş bulunduğunda veya bir cihazın kablosuz bağlantı durumu değiştiğinde) yayınlanan intent'leri tanımlar. Bu intent'leri işleyen bir yayın alıcısı oluşturarak uygulamanızda bu intent'leri almak için kaydolabilirsiniz:
Tablo 3. Kablosuz P2P Intent'leri
| Amaç | Açıklama |
WIFI_P2P_CONNECTION_CHANGED_ACTION
|
Cihazın kablosuz bağlantısının durumu değiştiğinde yayınlanır. |
WIFI_P2P_PEERS_CHANGED_ACTION
|
discoverPeers() numarasını aradığınızda anons yapın. Bu intent'i uygulamanızda işliyorsanız güncel bir eş listesi almak için genellikle requestPeers() yöntemini çağırırsınız.
|
WIFI_P2P_STATE_CHANGED_ACTION
|
Cihazda kablosuz P2P etkinleştirildiğinde veya devre dışı bırakıldığında yayınlanır. |
WIFI_P2P_THIS_DEVICE_CHANGED_ACTION
|
Cihazın adı gibi ayrıntıları değiştiğinde yayınlanır. |
Kablosuz P2P intent'leri için yayın alıcısı oluşturma
Yayın alıcı, Android sistemi tarafından yayınlanan intent'leri almanıza olanak tanır. Böylece uygulamanız, ilgilendiğiniz etkinliklere yanıt verebilir. Kablosuz P2P intent'lerini işlemek için yayın alıcısı oluşturmanın temel adımları şunlardır:
BroadcastReceiversınıfını genişleten bir sınıf oluşturun. Sınıfın kurucusu içinWifiP2pManager,WifiP2pManager.Channelve bu yayın alıcısının kaydedileceği etkinliğe ait parametreleri kullanacaksınız. Bu sayede yayın alıcısı, etkinliğe güncellemeler gönderebilir, ayrıca gerektiğinde kablosuz donanımına ve iletişim kanalına erişebilir.Yayın alıcısında, ilgilendiğiniz intent'leri
onReceive()yönteminde kontrol edin. Alınan amaca bağlı olarak gerekli işlemleri gerçekleştirin. Örneğin, yayın alıcısı birWIFI_P2P_PEERS_CHANGED_ACTIONintent'i alırsa o anda keşfedilen eşlerin listesini almak içinrequestPeers()yöntemini çağırabilirsiniz.
Aşağıdaki kodda, tipik bir yayın alıcısının nasıl oluşturulacağı gösterilmektedir. Yayın alıcısı, bağımsız değişken olarak bir WifiP2pManager nesnesi ve bir etkinlik alır ve yayın alıcısı bir intent aldığında gerekli işlemleri uygun şekilde gerçekleştirmek için bu iki sınıfı kullanır:
Kotlin
/** * A BroadcastReceiver that notifies of important Wi-Fi p2p events. */ class WiFiDirectBroadcastReceiver( private val manager: WifiP2pManager, private val channel: WifiP2pManager.Channel, private val activity: MyWifiActivity ) : BroadcastReceiver() { override fun onReceive(context: Context, intent: Intent) { val action: String = intent.action when (action) { WifiP2pManager.WIFI_P2P_STATE_CHANGED_ACTION -> { // Check to see if Wi-Fi is enabled and notify appropriate activity } WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION -> { // Call WifiP2pManager.requestPeers() to get a list of current peers } WifiP2pManager.WIFI_P2P_CONNECTION_CHANGED_ACTION -> { // Respond to new connection or disconnections } WifiP2pManager.WIFI_P2P_THIS_DEVICE_CHANGED_ACTION -> { // Respond to this device's wifi state changing } } } }
Java
/** * A BroadcastReceiver that notifies of important Wi-Fi p2p events. */ public class WiFiDirectBroadcastReceiver extends BroadcastReceiver { private WifiP2pManager manager; private Channel channel; private MyWiFiActivity activity; public WiFiDirectBroadcastReceiver(WifiP2pManager manager, Channel channel, MyWifiActivity activity) { super(); this.manager = manager; this.channel = channel; this.activity = activity; } @Override public void onReceive(Context context, Intent intent) { String action = intent.getAction(); if (WifiP2pManager.WIFI_P2P_STATE_CHANGED_ACTION.equals(action)) { // Check to see if Wi-Fi is enabled and notify appropriate activity } else if (WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION.equals(action)) { // Call WifiP2pManager.requestPeers() to get a list of current peers } else if (WifiP2pManager.WIFI_P2P_CONNECTION_CHANGED_ACTION.equals(action)) { // Respond to new connection or disconnections } else if (WifiP2pManager.WIFI_P2P_THIS_DEVICE_CHANGED_ACTION.equals(action)) { // Respond to this device's wifi state changing } } }
Android 10 ve sonraki sürümleri çalıştıran cihazlarda aşağıdaki yayın intent'leri yapışkan değildir:
WIFI_P2P_CONNECTION_CHANGED_ACTION- Uygulamalar, mevcut bağlantı bilgilerini almak için
requestConnectionInfo(),requestNetworkInfo()veyarequestGroupInfo()kullanabilir. WIFI_P2P_THIS_DEVICE_CHANGED_ACTION- Uygulamalar, geçerli bağlantı bilgilerini almak için
requestDeviceInfo()kullanabilir.
Kablosuz P2P uygulaması oluşturma
Kablosuz P2P uygulaması oluşturmak için uygulamanız için bir yayın alıcısı oluşturup kaydetmeniz, eşleri keşfetmeniz, bir eşe bağlanmanız ve bir eşe veri aktarmanız gerekir. Aşağıdaki bölümlerde bunun nasıl yapılacağı açıklanmaktadır.
İlk kurulum
Kablosuz P2P API'lerini kullanmadan önce uygulamanızın donanıma erişebildiğinden ve cihazın kablosuz P2P protokolünü desteklediğinden emin olmanız gerekir. Kablosuz P2P destekleniyorsa WifiP2pManager örneği alabilir, yayın alıcınızı oluşturup kaydedebilir ve kablosuz P2P API'lerini kullanmaya başlayabilirsiniz.
Cihazdaki kablosuz donanımını kullanma izni isteyin ve Android manifest dosyasında uygulamanızın doğru minimum SDK sürümüne sahip olduğunu beyan edin:
<uses-sdk android:minSdkVersion="14" /> <uses-permission android:name="android.permission.ACCESS_WIFI_STATE" /> <uses-permission android:name="android.permission.CHANGE_WIFI_STATE" /> <uses-permission android:name="android.permission.CHANGE_NETWORK_STATE" /> <uses-permission android:name="android.permission.INTERNET" /> <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" /> <!-- If your app targets Android 13 (API level 33) or higher, you must declare the NEARBY_WIFI_DEVICES permission. --> <uses-permission android:name="android.permission.NEARBY_WIFI_DEVICES" <!-- If your app derives location information from Wi-Fi APIs, don't include the "usesPermissionFlags" attribute. --> android:usesPermissionFlags="neverForLocation" /> <uses-permission android:name="android.permission.ACCESS_FINE_LOCATION" <!-- If any feature in your app relies on precise location information, don't include the "maxSdkVersion" attribute. --> android:maxSdkVersion="32" />Yukarıdaki izinlerin yanı sıra aşağıdaki API'ler de konum modunun etkinleştirilmesini gerektirir:
Kablosuz P2P'nin açık ve desteklenip desteklenmediğini kontrol edin. Bunu kontrol etmek için en iyi yer, yayın alıcınızın
WIFI_P2P_STATE_CHANGED_ACTIONintent'ini aldığı yerdir. Etkinliğinize kablosuz P2P durumu hakkında bildirim gönderin ve buna göre tepki verin:Kotlin
override fun onReceive(context: Context, intent: Intent) { ... val action: String = intent.action when (action) { WifiP2pManager.WIFI_P2P_STATE_CHANGED_ACTION -> { val state = intent.getIntExtra(WifiP2pManager.EXTRA_WIFI_STATE, -1) when (state) { WifiP2pManager.WIFI_P2P_STATE_ENABLED -> { // Wifi P2P is enabled } else -> { // Wi-Fi P2P is not enabled } } } } ... }
Java
@Override public void onReceive(Context context, Intent intent) { ... String action = intent.getAction(); if (WifiP2pManager.WIFI_P2P_STATE_CHANGED_ACTION.equals(action)) { int state = intent.getIntExtra(WifiP2pManager.EXTRA_WIFI_STATE, -1); if (state == WifiP2pManager.WIFI_P2P_STATE_ENABLED) { // Wifi P2P is enabled } else { // Wi-Fi P2P is not enabled } } ... }
Etkinliğinizin
onCreate()yönteminde birWifiP2pManagerörneği alın veinitialize()yöntemini çağırarak uygulamanızı kablosuz P2P çerçevesine kaydedin. Bu yöntem, uygulamanızı kablosuz P2P çerçevesine bağlamak için kullanılan birWifiP2pManager.Channeldöndürür. Ayrıca, etkinliğinize referansla birlikteWifiP2pManagerveWifiP2pManager.Channelnesnelerini içeren bir yayın alıcısı örneği oluşturmanız gerekir. Bu sayede, yayın alıcınız etkinliğinizi ilginç etkinlikler hakkında bilgilendirebilir ve buna göre güncelleyebilir. Ayrıca, gerekirse cihazın kablosuz ağ durumunu değiştirmenize de olanak tanır:Kotlin
val manager: WifiP2pManager? by lazy(LazyThreadSafetyMode.NONE) { getSystemService(Context.WIFI_P2P_SERVICE) as WifiP2pManager? } var channel: WifiP2pManager.Channel? = null var receiver: BroadcastReceiver? = null override fun onCreate(savedInstanceState: Bundle?) { ... channel = manager?.initialize(this, mainLooper, null) channel?.also { channel -> receiver = WiFiDirectBroadcastReceiver(manager, channel, this) } }
Java
WifiP2pManager manager; Channel channel; BroadcastReceiver receiver; ... @Override protected void onCreate(Bundle savedInstanceState){ ... manager = (WifiP2pManager) getSystemService(Context.WIFI_P2P_SERVICE); channel = manager.initialize(this, getMainLooper(), null); receiver = new WiFiDirectBroadcastReceiver(manager, channel, this); ... }
Bir intent filtresi oluşturun ve yayın alıcınızın kontrol ettiği intent'leri ekleyin:
Kotlin
val intentFilter = IntentFilter().apply { addAction(WifiP2pManager.WIFI_P2P_STATE_CHANGED_ACTION) addAction(WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION) addAction(WifiP2pManager.WIFI_P2P_CONNECTION_CHANGED_ACTION) addAction(WifiP2pManager.WIFI_P2P_THIS_DEVICE_CHANGED_ACTION) }
Java
IntentFilter intentFilter; ... @Override protected void onCreate(Bundle savedInstanceState){ ... intentFilter = new IntentFilter(); intentFilter.addAction(WifiP2pManager.WIFI_P2P_STATE_CHANGED_ACTION); intentFilter.addAction(WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION); intentFilter.addAction(WifiP2pManager.WIFI_P2P_CONNECTION_CHANGED_ACTION); intentFilter.addAction(WifiP2pManager.WIFI_P2P_THIS_DEVICE_CHANGED_ACTION); ... }
Yayın alıcısını etkinliğinizin
onResume()yöntemine kaydedin ve etkinliğinizinonPause()yönteminde kaydını silin:Kotlin
/* register the broadcast receiver with the intent values to be matched */ override fun onResume() { super.onResume() receiver?.also { receiver -> registerReceiver(receiver, intentFilter) } } /* unregister the broadcast receiver */ override fun onPause() { super.onPause() receiver?.also { receiver -> unregisterReceiver(receiver) } }
Java
/* register the broadcast receiver with the intent values to be matched */ @Override protected void onResume() { super.onResume(); registerReceiver(receiver, intentFilter); } /* unregister the broadcast receiver */ @Override protected void onPause() { super.onPause(); unregisterReceiver(receiver); }
WifiP2pManager.Channelaldıktan ve bir yayın alıcısı ayarladıktan sonra uygulamanız, kablosuz P2P yöntem çağrıları yapabilir ve kablosuz P2P intent'leri alabilir.WifiP2pManageriçindeki yöntemleri çağırarak kablosuz P2P özelliklerini kullanan uygulamanızı uygulayın.
Sonraki bölümlerde, eşleri keşfetme ve eşlere bağlanma gibi yaygın işlemlerin nasıl yapılacağı açıklanmaktadır.
Benzerlerinizi keşfedin
Menzil içinde ve bağlantı için kullanılabilir olan eşleri algılamak üzere discoverPeers() yöntemini çağırın. Bu işlevin çağrısı eşzamansızdır ve bir WifiP2pManager.ActionListener oluşturduysanız işlemin başarılı veya başarısız olduğu onSuccess() ve onFailure() ile uygulamanıza bildirilir. onSuccess() yöntemi yalnızca keşif işleminin başarılı olduğunu bildirir ve keşfettiği gerçek eşler (varsa) hakkında bilgi vermez. Aşağıdaki kod örneğinde bunun nasıl ayarlanacağı gösterilmektedir.
Kotlin
manager?.discoverPeers(channel, object : WifiP2pManager.ActionListener { override fun onSuccess() { ... } override fun onFailure(reasonCode: Int) { ... } })
Java
manager.discoverPeers(channel, new WifiP2pManager.ActionListener() { @Override public void onSuccess() { ... } @Override public void onFailure(int reasonCode) { ... } });
Keşif işlemi başarılı olur ve eşleri algılarsa sistem, WIFI_P2P_PEERS_CHANGED_ACTION intent'ini yayınlar. Eşlerin listesini almak için bu intent'i bir yayın alıcısında dinleyebilirsiniz. Uygulamanız WIFI_P2P_PEERS_CHANGED_ACTION intent'ini aldığında requestPeers() ile keşfedilen eşlerin listesini isteyebilirsiniz. Aşağıdaki kodda bunun nasıl ayarlanacağı gösterilmektedir.
Kotlin
override fun onReceive(context: Context, intent: Intent) { val action: String = intent.action when (action) { ... WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION -> { manager?.requestPeers(channel) { peers: WifiP2pDeviceList? -> // Handle peers list } } ... } }
Java
PeerListListener myPeerListListener; ... if (WifiP2pManager.WIFI_P2P_PEERS_CHANGED_ACTION.equals(action)) { // request available peers from the wifi p2p manager. This is an // asynchronous call and the calling activity is notified with a // callback on PeerListListener.onPeersAvailable() if (manager != null) { manager.requestPeers(channel, myPeerListListener); } }
requestPeers() yöntemi de eşzamansızdır ve WifiP2pManager.PeerListListener arayüzünde tanımlanan onPeersAvailable() ile eşlerin listesi mevcut olduğunda etkinliğinizi bilgilendirebilir. onPeersAvailable() yöntemi, bağlanılacak eşi bulmak için yineleyebileceğiniz bir WifiP2pDeviceList sağlar.
Benzerlerle bağlantı kurma
Olası eşlerin listesini alıp bağlanılacak cihazı seçtikten sonra cihaza bağlanmak için connect() yöntemini çağırın. Bu yöntem çağrısı, bağlanılacak cihazla ilgili bilgileri içeren bir WifiP2pConfig nesnesi gerektirir.
WifiP2pManager.ActionListener, bağlantının başarılı veya başarısız olduğunu size bildirebilir. Aşağıdaki kodda bir cihazla nasıl bağlantı oluşturulacağı gösterilmektedir.
Kotlin
val device: WifiP2pDevice = ... val config = WifiP2pConfig() config.deviceAddress = device.deviceAddress channel?.also { channel -> manager?.connect(channel, config, object : WifiP2pManager.ActionListener { override fun onSuccess() { //success logic } override fun onFailure(reason: Int) { //failure logic } } )}
Java
//obtain a peer from the WifiP2pDeviceList WifiP2pDevice device; WifiP2pConfig config = new WifiP2pConfig(); config.deviceAddress = device.deviceAddress; manager.connect(channel, config, new ActionListener() { @Override public void onSuccess() { //success logic } @Override public void onFailure(int reason) { //failure logic } });
Verileri aktar
Bağlantı kurulduktan sonra soketlerle cihazlar arasında veri aktarabilirsiniz. Veri aktarımının temel adımları şunlardır:
ServerSocketoluşturun. Bu soket, belirtilen bir bağlantı noktasında istemciden bağlantı bekler ve bağlantı gerçekleşene kadar engeller. Bu nedenle, bu işlemi bir arka plan iş parçacığında yapın.- İstemci oluşturun
Socket. İstemci, sunucu cihazına bağlanmak için sunucu yuvasının IP adresini ve bağlantı noktasını kullanır. - İstemciden sunucuya veri gönderme İstemci yuvası, sunucu yuvasına başarıyla bağlandığında istemciden sunucuya bayt akışlarıyla veri gönderebilirsiniz.
- Sunucu yuvası, istemci bağlantısı bekler (
accept()yöntemiyle). Bu çağrı, bir istemci bağlanana kadar engellenir. Bu nedenle, bu çağrıyı başka bir iş parçacığında yapın. Bağlantı kurulduğunda sunucu cihaz, istemciden veri alabilir.
Kablosuz P2P Demosu'ndan değiştirilen aşağıdaki örnekte, bu istemci-sunucu yuvası iletişiminin nasıl oluşturulacağı ve JPEG resimlerin bir hizmetle istemciden sunucuya nasıl aktarılacağı gösterilmektedir. Çalışan bir örneğin tamamını görmek için demoyu derleyip çalıştırın.
Kotlin
class FileServerAsyncTask( private val context: Context, private var statusText: TextView ) : AsyncTask<Void, Void, String?>() { override fun doInBackground(vararg params: Void): String? { /** * Create a server socket. */ val serverSocket = ServerSocket(8888) return serverSocket.use { /** * Wait for client connections. This call blocks until a * connection is accepted from a client. */ val client = serverSocket.accept() /** * If this code is reached, a client has connected and transferred data * Save the input stream from the client as a JPEG file */ val f = File(Environment.getExternalStorageDirectory().absolutePath + "/${context.packageName}/wifip2pshared-${System.currentTimeMillis()}.jpg") val dirs = File(f.parent) dirs.takeIf { it.doesNotExist() }?.apply { mkdirs() } f.createNewFile() val inputstream = client.getInputStream() copyFile(inputstream, FileOutputStream(f)) serverSocket.close() f.absolutePath } } private fun File.doesNotExist(): Boolean = !exists() /** * Start activity that can handle the JPEG image */ override fun onPostExecute(result: String?) { result?.run { statusText.text = "File copied - $result" val intent = Intent(android.content.Intent.ACTION_VIEW).apply { setDataAndType(Uri.parse("file://$result"), "image/*") } context.startActivity(intent) } } }
Java
public static class FileServerAsyncTask extends AsyncTask { private Context context; private TextView statusText; public FileServerAsyncTask(Context context, View statusText) { this.context = context; this.statusText = (TextView) statusText; } @Override protected String doInBackground(Void... params) { try { /** * Create a server socket and wait for client connections. This * call blocks until a connection is accepted from a client */ ServerSocket serverSocket = new ServerSocket(8888); Socket client = serverSocket.accept(); /** * If this code is reached, a client has connected and transferred data * Save the input stream from the client as a JPEG file */ final File f = new File(Environment.getExternalStorageDirectory() + "/" + context.getPackageName() + "/wifip2pshared-" + System.currentTimeMillis() + ".jpg"); File dirs = new File(f.getParent()); if (!dirs.exists()) dirs.mkdirs(); f.createNewFile(); InputStream inputstream = client.getInputStream(); copyFile(inputstream, new FileOutputStream(f)); serverSocket.close(); return f.getAbsolutePath(); } catch (IOException e) { Log.e(WiFiDirectActivity.TAG, e.getMessage()); return null; } } /** * Start activity that can handle the JPEG image */ @Override protected void onPostExecute(String result) { if (result != null) { statusText.setText("File copied - " + result); Intent intent = new Intent(); intent.setAction(android.content.Intent.ACTION_VIEW); intent.setDataAndType(Uri.parse("file://" + result), "image/*"); context.startActivity(intent); } } }
İstemcide, bir istemci yuvası ile sunucu yuvasına bağlanın ve verileri aktarın. Bu örnekte, istemci cihazın dosya sistemindeki bir JPEG dosyası aktarılmaktadır.
Kotlin
val context = applicationContext val host: String val port: Int val len: Int val socket = Socket() val buf = ByteArray(1024) ... try { /** * Create a client socket with the host, * port, and timeout information. */ socket.bind(null) socket.connect((InetSocketAddress(host, port)), 500) /** * Create a byte stream from a JPEG file and pipe it to the output stream * of the socket. This data is retrieved by the server device. */ val outputStream = socket.getOutputStream() val cr = context.contentResolver val inputStream: InputStream = cr.openInputStream(Uri.parse("path/to/picture.jpg")) while (inputStream.read(buf).also { len = it } != -1) { outputStream.write(buf, 0, len) } outputStream.close() inputStream.close() } catch (e: FileNotFoundException) { //catch logic } catch (e: IOException) { //catch logic } finally { /** * Clean up any open sockets when done * transferring or if an exception occurred. */ socket.takeIf { it.isConnected }?.apply { close() } }
Java
Context context = this.getApplicationContext(); String host; int port; int len; Socket socket = new Socket(); byte buf[] = new byte[1024]; ... try { /** * Create a client socket with the host, * port, and timeout information. */ socket.bind(null); socket.connect((new InetSocketAddress(host, port)), 500); /** * Create a byte stream from a JPEG file and pipe it to the output stream * of the socket. This data is retrieved by the server device. */ OutputStream outputStream = socket.getOutputStream(); ContentResolver cr = context.getContentResolver(); InputStream inputStream = null; inputStream = cr.openInputStream(Uri.parse("path/to/picture.jpg")); while ((len = inputStream.read(buf)) != -1) { outputStream.write(buf, 0, len); } outputStream.close(); inputStream.close(); } catch (FileNotFoundException e) { //catch logic } catch (IOException e) { //catch logic } /** * Clean up any open sockets when done * transferring or if an exception occurred. */ finally { if (socket != null) { if (socket.isConnected()) { try { socket.close(); } catch (IOException e) { //catch logic } } } }