SSDP協定的Android實作以及使用

前面一篇部落格裡面已經介紹過SSDP協定原理，本篇部落格将實作實作Android上的SSDP協定。

關鍵技術分析：1、發送廣播；需要發送送廣播，是以需要使用MulticastSocket、SocketAddress、InetAddress，需要掌握。

    2、SSDP資料報格式；标準的SSDP Server解析的時候對于分段的字段選用的特征碼是"\r\n"，需要特别注意。

    3、通路權限；需要網際網路，要在Mainfest中添加聯網的相關權限。

以下是我的源碼：

1、SSDPConstants.java

public class SSDPConstants {

/* New line definition */

public static final String NEWLINE = "\r\n";

public static final String ADDRESS = "239.255.255.250";

public static final int PORT = 1900;

public static final String SL_MSEARCH = "M-SEARCH * HTTP/1.1";

public static final String SL_OK = "HTTP/1.1 200 OK";

public static final String ST_Product = "ST:urn:schemas-upnp-org:device:Server:1";

public static final String Found = "ST=urn:schemas-upnp-org:device:";

public static final String Root = "ST:urn:schemas-upnp-org:device:DZBA_HomeDP:1";

}

2、SSDPSearchMsg .java

public class SSDPSearchMsg {

static final String HOST = "Host:" + SSDP.ADDRESS + ":" + SSDP.PORT;

static final String MAN = "Man:\"ssdp:discover\"";

static final String NEWLINE = "\r\n";

int mMX = 5; /* seconds to delay response */

String mST; /* Search target */

public SSDPSearchMsg(String ST) {

mST = ST;

public int getmMX() {

return mMX;

public void setmMX(int mMX) {

this.mMX = mMX;

public String getmST() {

return mST;

public void setmST(String mST) {

this.mST = mST;

@Override

public String toString() {

StringBuilder content = new StringBuilder();

content.append(SSDP.SL_MSEARCH).append(NEWLINE);

content.append(HOST).append(NEWLINE);

content.append(MAN).append(NEWLINE);

content.append("MX:" + mMX).append(NEWLINE);

content.append(mST).append(NEWLINE);

content.append(NEWLINE);

return content.toString();

3、SSDPSocket .java

public class SSDPSocket {

SocketAddress mSSDPMulticastGroup;

MulticastSocket mSSDPSocket;

InetAddress broadcastAddress;

public SSDPSocket() throws IOException {

mSSDPSocket = new MulticastSocket(58000); // Bind some random port for receiving datagram

broadcastAddress = InetAddress.getByName(SSDPConstants.ADDRESS);

mSSDPSocket.joinGroup(broadcastAddress);

/* Used to send SSDP packet */

public void send(String data) throws IOException {

DatagramPacket dp = new DatagramPacket(data.getBytes(), data.length(), broadcastAddress, SSDPConstants.PORT);

mSSDPSocket.send(dp);

/* Used to receive SSDP packet */

public DatagramPacket receive() throws IOException {

byte[] buf = new byte[1024];

DatagramPacket dp = new DatagramPacket(buf, buf.length);

mSSDPSocket.receive(dp);

return dp;

public void close() {

if (mSSDPSocket != null) {

mSSDPSocket.close();

4、SSDP .java

public class SSDP {

public static final String ST = "ST";

public static final String LOCATION = "LOCATION";

public static final String NT = "NT";

public static final String NTS = "NTS";

/* Definitions of start line */

public static final String SL_NOTIFY = "NOTIFY * HTTP/1.1";

@SuppressWarnings("resource")

public static String parseHeaderValue(String content, String headerName) {

Scanner s = new Scanner(content);

s.nextLine(); // Skip the start line

while (s.hasNextLine()) {

String line = s.nextLine();

int index = line.indexOf(‘:‘);

String header = line.substring(0, index);

if (headerName.equalsIgnoreCase(header.trim())) {

return line.substring(index + 1).trim();

return null;

public static String parseHeaderValue(DatagramPacket dp, String headerName) {

return parseHeaderValue(new String(dp.getData()), headerName);

public static String parseStartLine(String content) {

return s.nextLine();

public static String parseStartLine(DatagramPacket dp) {

return parseStartLine(new String(dp.getData()));

5、MainActivity .java

public class MainActivity extends Activity implements OnClickListener {

protected void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

WifiManager wm = (WifiManager) getSystemService(Context.WIFI_SERVICE);

WifiManager.MulticastLock multicastLock = wm.createMulticastLock("multicastLock");

multicastLock.setReferenceCounted(true);

multicastLock.acquire();

setContentView(R.layout.activity_main);

((Button) this.findViewById(R.id.btnSendSSDPSearch)).setOnClickListener(this);

public void onClick(View v) {

switch (v.getId()) {

case R.id.btnSendSSDPSearch:

new Thread(new Runnable() {

public void run() {

SendMSearchMessage();

}).start();

default:

break;

private void SendMSearchMessage() {

// SSDPSearchMsg searchContentDirectory = new SSDPSearchMsg(SSDPConstants.ST_ContentDirectory);

// SSDPSearchMsg searchAVTransport = new SSDPSearchMsg(SSDPConstants.ST_AVTransport);

SSDPSearchMsg searchProduct = new SSDPSearchMsg(SSDPConstants.Root);

SSDPSocket sock = null;

try {

sock = new SSDPSocket();

for (int i = 0; i < 2; i++) {

// sock.send(searchContentDirectory.toString());

// sock.send(searchAVTransport.toString());

sock.send(searchProduct.toString());

// String s = "M-SEARCH * HTTP/1.1 \n HOST= 239.255.255.250:1900 \n MAN= \"ssdp:discover\" \n MX: 3 \n ST= upnp:rootdevice";

// sock.send(s);

Log.i("-------------", "發送的資料為：\n" + searchProduct.toString());

while (true) {

DatagramPacket dp = sock.receive(); // Here, I only receive the same packets I initially sent above

String c = new String(dp.getData()).trim();

String ip = new String(dp.getAddress().toString()).trim();

Log.i("------------", "接收到的資料為：\n" + c + "數據來源IP：" + ip);

} catch (IOException e) {

Log.e("M-SEARCH", e.getMessage());

界面xml很簡單，隻有一個按鈕

Mainfest.xml:

<?xml version="1.0" encoding="utf-8"?>

<manifest xmlns:android="http://schemas.android.com/apk/res/android"

    package="com.example.ssdp"

    android:versionCode="1"

    android:versionName="1.0" >

    <uses-sdk

        android:minSdkVersion="8"

        android:targetSdkVersion="18" />

    <uses-permission android:name="android.permission.INTERNET" />

    <uses-permission android:name="android.permission.CHANGE_WIFI_MULTICAST_STATE" />

    <uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />

    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />

    <application

        android:allowBackup="true"

        android:icon="@drawable/ic_launcher"

        android:label="@string/app_name"

        android:theme="@style/AppTheme" >

        <activity

            android:name="com.example.ssdp.MainActivity"

            android:label="@string/app_name" >

            <intent-filter>

                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />

            </intent-filter>

        </activity>

    </application>

</manifest>

使用須知：需要有Server端運作，http://download.csdn.net/detail/zhu530548851/7451201下載下傳源碼，該源碼是js的。

将Server放于Linux系統目錄下，進入test目錄，執行node server.js即可。

需要Linux安裝有nodejs:sudo apt-get install nodejs

這樣在運作Android用戶端就可以從Log中看到來自于Server的資訊了。

Android源碼在此：http://download.csdn.net/detail/zhu530548851/7451179

個人辛勤勞動成果，如有轉載，請注明出處，謝謝！