ภาพรวม Wi-Fi Direct (เพียร์ทูเพียร์ หรือ P2P)

Wi-Fi Direct (P2P) ช่วยให้อุปกรณ์ที่มีฮาร์ดแวร์ที่เหมาะสมเชื่อมต่อกันโดยตรงผ่าน Wi-Fi ได้โดยไม่ต้องใช้จุดเข้าใช้งานกลาง เมื่อใช้ API เหล่านี้ คุณจะค้นหาและเชื่อมต่อกับอุปกรณ์อื่นๆ ได้เมื่ออุปกรณ์แต่ละเครื่องรองรับ Wi-Fi P2P จากนั้นสื่อสารผ่านการเชื่อมต่อที่รวดเร็วในระยะทางที่ไกลกว่าการเชื่อมต่อบลูทูธ ซึ่งมีประโยชน์สำหรับแอปพลิเคชันที่แชร์ข้อมูลระหว่างผู้ใช้ เช่น เกมที่มีผู้เล่นหลายคนหรือแอปพลิเคชันการแชร์รูปภาพ

Wi-Fi P2P API ประกอบด้วยส่วนหลักๆ ต่อไปนี้

  • เมธอดที่ช่วยให้คุณค้นพบ ขอ และเชื่อมต่อกับคู่สนทนา ซึ่งจะกำหนดไว้ในคลาส WifiP2pManager
  • โปรแกรมฟังที่ให้คุณได้รับการแจ้งเตือนเกี่ยวกับความสําเร็จหรือไม่สําเร็จของWifiP2pManagerการเรียกใช้เมธอด เมื่อเรียกใช้เมธอด WifiP2pManager แต่ละเมธอดจะรับ Listener ที่เฉพาะเจาะจงซึ่งส่งผ่านมาเป็นพารามิเตอร์ได้
  • Intent ที่แจ้งให้คุณทราบเกี่ยวกับเหตุการณ์ที่เฉพาะเจาะจงซึ่งเฟรมเวิร์ก Wi-Fi P2P ตรวจพบ เช่น การเชื่อมต่อขาดหรือพบอุปกรณ์ที่ค้นพบใหม่

คุณมักจะใช้คอมโพเนนต์หลัก 3 รายการนี้ของ API ร่วมกัน ตัวอย่างเช่น คุณสามารถระบุ WifiP2pManager.ActionListener ให้กับการเรียกใช้ discoverPeers() เพื่อให้วิธี ActionListener.onSuccess() และ ActionListener.onFailure() แจ้งเตือนคุณได้ ระบบจะออกอากาศความตั้งใจด้วยหากเมธอด discoverPeers() พบว่ารายการเพียร์มีการเปลี่ยนแปลงWIFI_P2P_PEERS_CHANGED_ACTION

ภาพรวมของ API

คลาส WifiP2pManager มีเมธอดที่ให้คุณโต้ตอบกับฮาร์ดแวร์ Wi-Fi ในอุปกรณ์เพื่อดำเนินการต่างๆ เช่น ค้นหาและเชื่อมต่อกับอุปกรณ์อื่นๆ การดำเนินการที่ทำได้มีดังนี้

ตารางที่ 1 วิธีการของ Wi-Fi P2P

เมธอด คำอธิบาย
initialize() ลงทะเบียนแอปพลิเคชันกับเฟรมเวิร์ก Wi-Fi เรียกใช้ก่อนเรียกใช้วิธีการ Wi-Fi P2P อื่นๆ
connect() เริ่มการเชื่อมต่อแบบ peer-to-peer กับอุปกรณ์ที่มีการกำหนดค่าที่ระบุ
cancelConnect() ยกเลิกการเจรจาต่อรองแบบกลุ่มแบบ peer-to-peer ที่ดำเนินอยู่
requestConnectInfo() ขอข้อมูลการเชื่อมต่อของอุปกรณ์
createGroup() สร้างกลุ่มแบบ peer-to-peer โดยให้อุปกรณ์ปัจจุบันเป็นเจ้าของกลุ่ม
removeGroup() นำกลุ่มแบบ peer-to-peer ในปัจจุบันออก
requestGroupInfo() ขอข้อมูลกลุ่มแบบ peer-to-peer
discoverPeers() เริ่มการค้นพบคู่สนทนา
requestPeers() ขอรายการคู่สนทนาที่ค้นพบในปัจจุบัน

วิธีการ WifiP2pManager ช่วยให้คุณส่งตัวรับฟังได้ เพื่อให้เฟรมเวิร์ก Wi-Fi P2P แจ้งสถานะการโทรให้กิจกรรมของคุณทราบ อินเทอร์เฟซตัวฟังที่ใช้ได้และการเรียกใช้เมธอด WifiP2pManager ที่เกี่ยวข้องซึ่งใช้ตัวฟังจะอธิบายไว้ในตารางที่ 2

ตารางที่ 2 อุปกรณ์รับสัญญาณ P2P ของ Wi-Fi

อินเทอร์เฟซ Listener การดำเนินการที่เกี่ยวข้อง
WifiP2pManager.ActionListener connect(), cancelConnect(), createGroup(), removeGroup() และ discoverPeers()
WifiP2pManager.ChannelListener initialize()
WifiP2pManager.ConnectionInfoListener requestConnectInfo()
WifiP2pManager.GroupInfoListener requestGroupInfo()
WifiP2pManager.PeerListListener requestPeers()

Wi-Fi P2P API จะกำหนด Intent ที่ออกอากาศเมื่อมีเหตุการณ์บางอย่างของ Wi-Fi P2P เกิดขึ้น เช่น เมื่อพบอุปกรณ์คู่ใหม่หรือเมื่อสถานะ Wi-Fi ของอุปกรณ์เปลี่ยนแปลง คุณสามารถลงทะเบียนเพื่อรับ Intent เหล่านี้ในแอปพลิเคชันได้โดยสร้าง Broadcast Receiver ที่จัดการ Intent เหล่านี้

ตารางที่ 3 Intent ของ Wi-Fi P2P

Intent คำอธิบาย
WIFI_P2P_CONNECTION_CHANGED_ACTION ออกอากาศเมื่อสถานะการเชื่อมต่อ Wi-Fi ของอุปกรณ์มีการเปลี่ยนแปลง
WIFI_P2P_PEERS_CHANGED_ACTION ประกาศเมื่อคุณโทรหา discoverPeers() โดยปกติแล้ว คุณจะต้องเรียกใช้ requestPeers() เพื่อรับรายการพาร์ทเนอร์ที่อัปเดตแล้ว หากคุณจัดการ Intent นี้ในแอปพลิเคชัน
WIFI_P2P_STATE_CHANGED_ACTION ประกาศเมื่อเปิดหรือปิดใช้ Wi-Fi P2P ในอุปกรณ์
WIFI_P2P_THIS_DEVICE_CHANGED_ACTION ออกอากาศเมื่อรายละเอียดของอุปกรณ์มีการเปลี่ยนแปลง เช่น ชื่อของอุปกรณ์

สร้างตัวรับสัญญาณออกอากาศสำหรับ Intent ของ Wi-Fi P2P

ตัวรับการออกอากาศช่วยให้คุณรับ Intent ที่ระบบ Android ออกอากาศได้ เพื่อให้แอปพลิเคชันตอบสนองต่อเหตุการณ์ที่คุณสนใจ ขั้นตอนพื้นฐานในการสร้างตัวรับสัญญาณเพื่อจัดการ Intent ของ Wi-Fi P2P มีดังนี้

  1. สร้างคลาสที่ขยายคลาส BroadcastReceiver สําหรับตัวสร้างคลาส คุณจะใช้พารามิเตอร์สําหรับ WifiP2pManager, WifiP2pManager.Channel และกิจกรรมที่จะลงทะเบียนตัวรับการออกอากาศนี้ ซึ่งจะช่วยให้ตัวรับการออกอากาศส่งการอัปเดตไปยังกิจกรรม รวมถึงเข้าถึงฮาร์ดแวร์ Wi-Fi และช่องทางการสื่อสารได้ หากจำเป็น

  2. ใน Broadcast Receiver ให้ตรวจสอบ Intent ที่คุณสนใจในวิธีonReceive() ดําเนินการที่จําเป็นโดยขึ้นอยู่กับความตั้งใจที่ได้รับ ตัวอย่างเช่น หากตัวรับการออกอากาศได้รับWIFI_P2P_PEERS_CHANGED_ACTION Intent คุณสามารถเรียกใช้เมธอด requestPeers() เพื่อดูรายการพาร์ทเนอร์ที่ค้นพบในปัจจุบัน

โค้ดต่อไปนี้แสดงวิธีสร้างตัวรับการออกอากาศทั่วไป ตัวรับการออกอากาศใช้ออบเจ็กต์ WifiP2pManager และกิจกรรมเป็นอาร์กิวเมนต์ และใช้คลาส 2 คลาสนี้เพื่อดำเนินการที่จำเป็นอย่างเหมาะสมเมื่อตัวรับการออกอากาศได้รับ Intent

/**
* 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
           
}
       
}
   
}
}
/**
* 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 ขึ้นไป Intent การออกอากาศต่อไปนี้จะไม่ใช่แบบติดหนึบ

WIFI_P2P_CONNECTION_CHANGED_ACTION
แอปพลิเคชันสามารถใช้ requestConnectionInfo(), requestNetworkInfo() หรือ requestGroupInfo() เพื่อดึงข้อมูลการเชื่อมต่อปัจจุบัน
WIFI_P2P_THIS_DEVICE_CHANGED_ACTION
แอปพลิเคชันสามารถใช้ requestDeviceInfo() เพื่อเรียกข้อมูลการเชื่อมต่อปัจจุบัน

สร้างแอปพลิเคชัน Wi-Fi P2P

การสร้างแอปพลิเคชัน Wi-Fi P2P เกี่ยวข้องกับการสร้างและลงทะเบียนตัวรับสัญญาณออกอากาศสําหรับแอปพลิเคชัน การค้นพบคู่สนทนา การเชื่อมต่อกับคู่สนทนา และการโอนข้อมูลไปยังคู่สนทนา ส่วนต่อไปนี้จะอธิบายวิธีดำเนินการ

การตั้งค่าเบื้องต้น

ก่อนใช้ Wi-Fi P2P API คุณต้องตรวจสอบว่าแอปพลิเคชันเข้าถึงฮาร์ดแวร์ได้และอุปกรณ์รองรับโปรโตคอล Wi-Fi P2P หากรองรับ Wi-Fi P2P คุณจะรับอินสแตนซ์ของ WifiP2pManager, สร้าง และลงทะเบียนตัวรับการออกอากาศ และเริ่มใช้ Wi-Fi P2P API ได้

  1. ขอสิทธิ์ในการใช้ฮาร์ดแวร์ Wi-Fi ในอุปกรณ์และประกาศว่าแอปพลิเคชันของคุณมีเวอร์ชัน SDK ขั้นต่ำที่ถูกต้องในไฟล์ Manifest ของ Android โดยทำดังนี้

    <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" />

    นอกจากสิทธิ์ข้างต้นแล้ว API ต่อไปนี้ยังกำหนดให้ต้องเปิดใช้โหมดตำแหน่งด้วย

  2. ตรวจสอบว่า Wi-Fi P2P เปิดอยู่และรองรับหรือไม่ คุณสามารถตรวจสอบได้ใน Broadcast Receiver เมื่อได้รับ Intent WIFI_P2P_STATE_CHANGED_ACTION แจ้งกิจกรรมของสถานะ Wi-Fi P2P และดำเนินการตามความเหมาะสม

    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
               
    }
           
    }
       
    }
    }
    ...
    }
    @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
       
    }
    }
    ...
    }
  3. ในเมธอด onCreate() ของกิจกรรม ให้รับอินสแตนซ์ของ WifiP2pManager และลงทะเบียนแอปพลิเคชันกับเฟรมเวิร์ก Wi-Fi P2P โดยการเรียกใช้ initialize() เมธอดนี้จะแสดงผล WifiP2pManager.Channel ซึ่งใช้เพื่อเชื่อมต่อแอปพลิเคชันกับเฟรมเวิร์ก Wi-Fi P2P นอกจากนี้ คุณควรสร้างอินสแตนซ์ของ Broadcast Receiver ด้วยออบเจ็กต์ WifiP2pManager และ WifiP2pManager.Channel พร้อมกับการอ้างอิงถึงกิจกรรม ซึ่งจะช่วยให้ตัวรับการออกอากาศแจ้งกิจกรรมที่น่าสนใจให้แอปทราบและอัปเดตกิจกรรมดังกล่าวตามความเหมาะสม นอกจากนี้ คุณยังควบคุมสถานะ Wi-Fi ของอุปกรณ์ได้หากจำเป็น ดังนี้

    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)
       
    }
    }
    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);
       
    ...
    }
  4. สร้างตัวกรอง Intent และเพิ่ม Intent เดียวกับที่ตัวรับการออกอากาศของคุณตรวจสอบ

    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)
    }
    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);
       
    ...
    }
  5. ลงทะเบียนตัวรับการออกอากาศในเมธอด onResume() ของกิจกรรม และยกเลิกการลงทะเบียนในเมธอด onPause() ของกิจกรรม

    /* 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)
       
    }
    }
    /* 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);
    }
  6. เมื่อได้รับ WifiP2pManager.Channel และตั้งค่าตัวรับสัญญาณแล้ว แอปพลิเคชันจะเรียกใช้เมธอด Wi-Fi P2P และรับ Intent ของ Wi-Fi P2P ได้

  7. ติดตั้งใช้งานแอปพลิเคชันโดยใช้ฟีเจอร์ Wi-Fi P2P ด้วยการเรียกใช้เมธอดใน WifiP2pManager

ส่วนถัดไปจะอธิบายวิธีดำเนินการทั่วไป เช่น การค้นหาและการเชื่อมต่อกับอุปกรณ์อื่นๆ

สำรวจแอปเทียบเท่า

โทร discoverPeers() เพื่อตรวจหาอุปกรณ์ที่พร้อมใช้งานซึ่งอยู่ในระยะสัญญาณและพร้อมเชื่อมต่อ การเรียกใช้ฟังก์ชันนี้จะเป็นแบบไม่พร้อมกัน และระบบจะแจ้งให้แอปพลิเคชันทราบถึงความสำเร็จหรือความล้มเหลวด้วย onSuccess() และ onFailure() หากคุณสร้าง WifiP2pManager.ActionListener เมธอด onSuccess() จะแจ้งให้คุณทราบว่ากระบวนการค้นพบสําเร็จเท่านั้น และไม่ระบุข้อมูลใดๆ เกี่ยวกับพาร์ทเนอร์จริงที่ค้นพบ (หากมี) ตัวอย่างโค้ดต่อไปนี้แสดงวิธีตั้งค่า

manager?.discoverPeers(channel, object : WifiP2pManager.ActionListener {

   
override fun onSuccess() {
       
...
   
}

   
override fun onFailure(reasonCode: Int) {
       
...
   
}
})
manager.discoverPeers(channel, new WifiP2pManager.ActionListener() {
   
@Override
   
public void onSuccess() {
       
...
   
}

   
@Override
   
public void onFailure(int reasonCode) {
       
...
   
}
});

หากกระบวนการค้นหาสำเร็จและตรวจพบคู่สนทนา ระบบจะออกอากาศWIFI_P2P_PEERS_CHANGED_ACTION Intent ซึ่งคุณสามารถรับฟังได้ในเครื่องรับออกอากาศเพื่อดูรายการคู่สนทนา เมื่อแอปพลิเคชันของคุณได้รับWIFI_P2P_PEERS_CHANGED_ACTION Intent คุณจะขอรายชื่อพาร์ทเนอร์ที่ค้นพบได้ด้วย requestPeers() โค้ดต่อไปนี้แสดงวิธีตั้งค่า

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
           
}
       
}
       
...
   
}
}
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() ยังเป็นแบบไม่พร้อมกันและสามารถแจ้งกิจกรรมของคุณได้เมื่อรายการคู่สนทนาพร้อมใช้งานด้วย onPeersAvailable() ซึ่งกำหนดไว้ในอินเทอร์เฟซ WifiP2pManager.PeerListListener วิธีการ onPeersAvailable() จะแสดง WifiP2pDeviceList ซึ่งคุณใช้วนดูเพื่อค้นหาคู่สนทนาที่จะเชื่อมต่อได้

เชื่อมต่อกับคู่ค้า

เมื่อได้รับรายการ Peer ที่เป็นไปได้และเลือกอุปกรณ์ที่จะเชื่อมต่อแล้ว ให้เรียกใช้เมธอด connect() เพื่อเชื่อมต่อกับอุปกรณ์ การเรียกใช้เมธอดนี้ต้องใช้ออบเจ็กต์ WifiP2pConfig ที่มีข้อมูลเกี่ยวกับอุปกรณ์ที่จะเชื่อมต่อ WifiP2pManager.ActionListener สามารถแจ้งให้คุณทราบเมื่อเชื่อมต่อสำเร็จหรือไม่สำเร็จ โค้ดต่อไปนี้แสดงวิธีสร้างการเชื่อมต่อกับอุปกรณ์

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
       
}
   
}
)}
//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
   
}
});

โอนข้อมูล

เมื่อเชื่อมต่อแล้ว คุณจะโอนข้อมูลระหว่างอุปกรณ์ด้วยซ็อกเก็ตได้ ขั้นตอนพื้นฐานในการโอนข้อมูลมีดังนี้

  1. สร้าง ServerSocket ซ็อกเก็ตนี้จะรอการเชื่อมต่อจากไคลเอ็นต์ในพอร์ตที่ระบุและบล็อกจนกว่าการเชื่อมต่อจะเกิดขึ้น ดังนั้นให้ดำเนินการนี้ในเธรดเบื้องหลัง
  2. สร้างลูกค้า Socket ไคลเอ็นต์จะใช้ที่อยู่ IP และพอร์ตของซ็อกเก็ตเซิร์ฟเวอร์เพื่อเชื่อมต่อกับอุปกรณ์เซิร์ฟเวอร์
  3. ส่งข้อมูลจากไคลเอ็นต์ไปยังเซิร์ฟเวอร์ เมื่อซ็อกเก็ตไคลเอ็นต์เชื่อมต่อกับซ็อกเก็ตเซิร์ฟเวอร์เรียบร้อยแล้ว คุณจะส่งข้อมูลจากไคลเอ็นต์ไปยังเซิร์ฟเวอร์ด้วยสตรีมไบต์ได้
  4. ซ็อกเก็ตเซิร์ฟเวอร์จะรอการเชื่อมต่อจากไคลเอ็นต์ (ด้วยเมธอด accept()) การเรียกนี้จะบล็อกจนกว่าจะมีไคลเอ็นต์เชื่อมต่อ ดังนั้นให้เรียกใช้การเรียกนี้ในอีกเธรดหนึ่ง เมื่อเชื่อมต่อแล้ว อุปกรณ์เซิร์ฟเวอร์จะรับข้อมูลจากไคลเอ็นต์ได้

ตัวอย่างต่อไปนี้ซึ่งแก้ไขมาจากการสาธิต Wi-Fi P2P จะแสดงวิธีสร้างการสื่อสารผ่านซ็อกเก็ตไคลเอ็นต์-เซิร์ฟเวอร์นี้และโอนรูปภาพ JPEG จากไคลเอ็นต์ไปยังเซิร์ฟเวอร์ที่มีบริการ หากต้องการดูตัวอย่างที่ใช้งานได้จริง ให้คอมไพล์และเรียกใช้ตัวอย่าง

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)
       
}
   
}
}
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);
       
}
   
}
}

ในไคลเอ็นต์ ให้เชื่อมต่อกับซ็อกเก็ตเซิร์ฟเวอร์ด้วยซ็อกเก็ตไคลเอ็นต์และโอนข้อมูล ตัวอย่างนี้จะโอนไฟล์ JPEG ในระบบไฟล์ของอุปกรณ์ไคลเอ็นต์

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
()
   
}
}
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
           
}
       
}
   
}
}