고귀양이의 노트.

package nfc_simple;

import javax.smartcardio.*;

import java.nio.ByteBuffer;
import java.util.*;

public class NFCMain {
    private static final String UNKNOWN_CMD_SW = "0000";
    private static final String SELECT_OK_SW = "9000";
    
    public void run() {
        CardTerminal terminal;
        CardChannel channel;
        
        while (true) {
            // 터미널 초기화
            try {
                terminal = InitializeTerminal();
                
                if(IsCardPresent(terminal)) {                                   // 리더기 위에 카드(핸드폰)가 있을 경우
                    channel = GetCardAndOpenChannel(terminal);
                    
                    String response = selectCardAID(channel);
                    
                    System.out.println(response);
                }
                
                Thread.sleep(2000);
                
            } catch (CardException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    
    public CardTerminal InitializeTerminal() throws CardException { 
        // Get terminal 
        System.out.println("Searching for terminals..."); 
        CardTerminal terminal = null; 
        TerminalFactory factory = TerminalFactory.getDefault(); 
        List<CardTerminal> terminals = factory.terminals().list(); 
      
        //Print list of terminals 
        for(CardTerminal ter:terminals) { 
            System.out.println("Found: "  +ter.getName().toString()); 
            terminal = terminals.get(0);// We assume just one is connected 
        } 
     
        return terminal; 
    }
    
    public boolean IsCardPresent(CardTerminal terminal) throws CardException {
        System.out.println("Waiting for card...");
        
        boolean isCard = false;
        
        while (!isCard) {
            isCard = terminal.waitForCardPresent(0);
            if(isCard)
                System.out.println("Card was found! :-)");
        }
        
        return true;
    }
    
    public CardChannel GetCardAndOpenChannel(CardTerminal terminal) throws CardException {
        Card card = terminal.connect("*");
        CardChannel channel = card.getBasicChannel();
        
        byte[] baReadUID = new byte[5];
        baReadUID = new byte[]{(byte) 0xFF, (byte) 0xCA, (byte) 0x00, (byte) 0x00, (byte) 0x00};
        
        // tag의 uid (unique ID)를 얻은 후 출력
        System.out.println("UID : " + SendCommand(baReadUID, channel));
        
        return channel;
    }
    
    public String selectCardAID(CardChannel channel) {
        
        byte[] baSelectCardAID = new byte[11];
        baSelectCardAID = new byte[]{(byte) 0x00, (byte) 0xA4, (byte) 0x04, (byte) 0x00, (byte)0x05,(byte) 0xF2, (byte) 0x22, (byte) 0x22, (byte) 0x22, (byte) 0x22};
        
        return SendCommand(baSelectCardAID, channel);
    }
    
    public static String SendCommand(byte[] cmd, CardChannel channel) { 
        String response = "";
        byte[] baResp = new byte[258];
         
        ByteBuffer bufCmd = ByteBuffer.wrap(cmd);
        ByteBuffer bufResp = ByteBuffer.wrap(baResp);
         
        int output = 0;
         
        try { 
            output = channel.transmit(bufCmd, bufResp); 
        } catch(CardException ex){ 
            ex.printStackTrace(); 
        } 

        for (int i = 0; i < output; i++) {
            response += String.format("%02X", baResp[i]); 
        }
          
        return response;  
    }
}

<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="com.example.hyunseo.hce_sample">

    <application
        android:allowBackup="true"
        android:icon="@mipmap/ic_launcher"
        android:label="@string/app_name"
        android:supportsRtl="true"
        android:theme="@style/AppTheme">
        <activity android:name=".MainActivity">
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />

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

        <service android:name=".CardService"
            android:exported="true"
            android:permission="android.permission.BIND_NFC_SERVICE">
            <!-- Intent filter indicating that we support card emulation. -->
            <intent-filter>
                <action android:name="android.nfc.cardemulation.action.HOST_APDU_SERVICE"/>
                <category android:name="android.intent.category.DEFAULT"/>
            </intent-filter>
            <!-- Required XML configuration file, listing the AIDs that we are emulating cards
                 for. This defines what protocols our card emulation service supports. -->
            <meta-data android:name="android.nfc.cardemulation.host_apdu_service"
                android:resource="@xml/aid_list"/>
        </service>
    </application>

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

</manifest>

package com.example.hyunseo.hce_sample;

import android.content.Intent;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;
import android.widget.TextView;

import org.w3c.dom.Text;

public class MainActivity extends AppCompatActivity {
    private TextView _tv;
    private Intent _cardService;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        _tv = (TextView) findViewById(R.id._textView);

        _cardService = new Intent(this, CardService.class);
        startService(_cardService);
    }

    @Override
    protected void onDestroy() {
        stopService(_cardService);
    }

    public void onClickUpdate(View v) {
        _tv.setText("Count : " + Counter.GetCurrentCout());
    }
}

package com.example.hyunseo.hce_sample;

import android.content.Intent;
import android.nfc.cardemulation.HostApduService;
import android.os.Bundle;
import android.os.Message;
import android.os.Messenger;
import android.os.RemoteException;
import android.util.Log;

import java.util.Arrays;

public class CardService extends HostApduService {
    private static final String TAG = "CardService";
    // AID for our loyalty card service.
    private static final String SAMPLE_LOYALTY_CARD_AID = "F222222222";
    // ISO-DEP command HEADER for selecting an AID.
    // Format: [Class | Instruction | Parameter 1 | Parameter 2]
    private static final String SELECT_APDU_HEADER = "00A40400";
    // "OK" status word sent in response to SELECT AID command (0x9000)
    private static final byte[] SELECT_OK_SW = HexStringToByteArray("9000");
    // "UNKNOWN" status word sent in response to invalid APDU command (0x0000)
    private static final byte[] UNKNOWN_CMD_SW = HexStringToByteArray("0000");
    private static final byte[] SELECT_APDU = BuildSelectApdu(SAMPLE_LOYALTY_CARD_AID);

    ////////////////////////////////////////////////////////////////////////////////////
    private Messenger _handler;

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        // UI thread 핸들 얻음
        Bundle extras = intent.getExtras();

        // 서비스를 앱 종료시까지 계속 실행상태로
        return START_STICKY;
    }

    // 외부로부터의 APDU명령을 받았을때 호출
    @Override
    public byte[] processCommandApdu(byte[] commandApdu, Bundle extras) {

        if (Arrays.equals(SELECT_APDU, commandApdu)) {
            Log.i(TAG, "Application selected");

            Counter.AddOne();

            return SELECT_OK_SW;
        } else {
            return UNKNOWN_CMD_SW;
        }
    }

    // 연결을 잃었을때 호출됨
    @Override
    public void onDeactivated(int reason) {
        Log.i(TAG, "Deactivated: " + reason);
    }

    public static byte[] BuildSelectApdu(String aid) {
        // Format: [CLASS | INSTRUCTION | PARAMETER 1 | PARAMETER 2 | LENGTH | DATA]
        return HexStringToByteArray(SELECT_APDU_HEADER + String.format("%02X",
                aid.length() / 2) + aid);
    }

    public static byte[] HexStringToByteArray(String s) throws IllegalArgumentException {
        int len = s.length();
        if (len % 2 == 1) {
            throw new IllegalArgumentException("Hex string must have even number of characters");
        }
        byte[] data = new byte[len / 2]; // Allocate 1 byte per 2 hex characters
        for (int i = 0; i < len; i += 2) {
            // Convert each character into a integer (base-16), then bit-shift into place
            data[i / 2] = (byte) ((Character.digit(s.charAt(i), 16) << 4)
                    + Character.digit(s.charAt(i+1), 16));
        }
        return data;
    }
}

package com.example.hyunseo.hce_sample;


public class Counter {
    private static int _cnt = 0;

    public static void AddOne() {_cnt++;}
    public static int GetCurrentCout() {return _cnt;}
}

<?xml version="1.0" encoding="utf-8"?>
<host-apdu-service xmlns:android="http://schemas.android.com/apk/res/android"
    android:description="@string/service_name"
    android:requireDeviceUnlock="false">

    <aid-group android:description="@string/card_title" android:category="other">
        <aid-filter android:name="F222222222"/>
    </aid-group>
</host-apdu-service>

MainActivity.java

package com.example.hyunseo.testingapp;

import android.app.ProgressDialog;
import android.os.Handler;
import android.os.Message;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;
import android.widget.*;


public class MainActivity extends AppCompatActivity implements View.OnClickListener {
    private Button m_bCreateSocket;
    private Button m_bSend;
    private EditText m_etInputIP;
    private EditText m_etInputPort;
    private EditText m_etSendData;
    private ProgressDialog m_pdIsLoading;

    private SocketManager m_hSocketManager;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        m_etInputIP = (EditText) findViewById(R.id.editText_inputIP);
        m_etInputPort = (EditText) findViewById(R.id.editText_inputPort);
        m_etSendData = (EditText) findViewById(R.id.editText_sendData);
        m_pdIsLoading = new ProgressDialog(this);

        // 클릭 이벤트 리스너 등록
        m_bCreateSocket.setOnClickListener(this);
        m_bSend.setOnClickListener(this);
    }

    private Handler m_Handler = new Handler() {
        public void handleMessage(Message msg) {
            switch(msg.what) {
                case 0: // 소켓 생성 완료
                    // 로딩화면 제거
                    m_pdIsLoading.dismiss();
                    break;
                case 1: // 데이터 수신 완료
                    // 수신 데이터 토스트로 띄움.
                    Toast.makeText(MainActivity.this, "server responded : " + msg.obj, Toast.LENGTH_SHORT).show();
                    break;
            }
        }
    };

    public void onClick(View v) {
        switch (v.getId()) {
            case R.id.button_CreateSocket:
                String IP = m_etInputIP.getText().toString();
                int Port = Integer.parseInt(m_etInputPort.getText().toString());

                m_pdIsLoading.setProgressStyle(ProgressDialog.STYLE_SPINNER);
                m_pdIsLoading.setMessage("Loading..");
                m_pdIsLoading.show();

                m_hSocketManager = new SocketManager(IP, Port, m_Handler);
                break;

            case R.id.button_Send:
                m_hSocketManager.sendData(m_etSendData.getText().toString());
                break;
        }
    }
}

SocketManager.java

package com.example.hyunseo.testingapp;

import android.os.Handler;
import android.os.Message;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;
import java.nio.charset.CharsetDecoder;
import java.util.Iterator;


public class SocketManager {
    private String IP;
    private int Port;

    private SocketChannel m_hSocketChannel;
    private Selector m_hSelector;

    private readDataThread m_readData;
    private sendDataThread m_sendData;

    private Handler m_handler;

    public SocketManager(String ip, int port, Handler h) {
        this.IP = ip;
        this.Port = port;
        this.m_handler = h;

        // thread objects의 작업 할당 및 초기화
        m_readData = new readDataThread();
        m_readData.start();
    }

    // m_createSocket thread 안에서 실행
    private void setSocket(String ip, int port) throws IOException {
        // selector 생성
        m_hSelector = Selector.open();
        // 채널 생성
        m_hSocketChannel = SocketChannel.open(new InetSocketAddress(ip, port));
        // 논블로킹 모드 설정
        m_hSocketChannel.configureBlocking(false);
        // 소켓 채널을 selector에 등록
        m_hSocketChannel.register(m_hSelector, SelectionKey.OP_CONNECT | SelectionKey.OP_READ | SelectionKey.OP_WRITE);
    }

    public void sendData(String data) {
        m_sendData = new sendDataThread(m_hSocketChannel, data);
        m_sendData.start();
    }

    private void read(SelectionKey key) throws Exception {
        // SelectionKey로부터 소켓채널을 얻어온다.
        SocketChannel sc = (SocketChannel) key.channel();
        // ByteBuffer를 생성한다.
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        int read = 0;

        // 요청한 클라이언트의 소켓채널로부터 데이터를 읽어들인다.
        read = sc.read(buffer);
        buffer.flip();

        String data = new String();
        CharsetDecoder decoder = Charset.forName("UTF-8").newDecoder();
        data = decoder.decode(buffer).toString();

        // 메시지 얻어오기
        Message msg = m_handler.obtainMessage();
        // 메시지 ID 설정
        msg.what = 1;
        // 메시지 정보 설정3 (Object 형식)
        msg.obj = data;
        m_handler.sendMessage(msg);

        // 버퍼 메모리를 해제한다.
        clearBuffer(buffer);
    }

    private void clearBuffer(ByteBuffer buffer) {
        if (buffer != null) {
            buffer.clear();
            buffer = null;
        }
    }

    /*********** inner thread classes **************/
    public class sendDataThread extends Thread {
        private SocketChannel sdt_hSocketChannel;
        private String data;

        public sendDataThread(SocketChannel sc, String d) {
            sdt_hSocketChannel = sc;
            data = d;
        }

        public void run() {
            try {
                // 데이터 전송.
                sdt_hSocketChannel.write(ByteBuffer.wrap(data.getBytes()));
            } catch (Exception e1) {

            }
        }
    }

    public class readDataThread extends Thread {

        public readDataThread() {

        }

        public void run() {
            try {
                setSocket(IP, Port);
            } catch (IOException e) {
                e.printStackTrace();
            }

            // 소켓 생성 완료를 메인UI스레드에 알림.
            m_handler.obtainMessage();
            m_handler.sendEmptyMessage(0);

            // 데이터 읽기 시작.
            try {
                while(true) {
                    // 셀렉터의 select() 메소드로 준비된 이벤트가 있는지 확인한다.
                    m_hSelector.select();

                    // 셀렉터의 SelectoedSet에 저장된 준비된 이벤트들(SelectionKey)을 하나씩 처리한다.
                    Iterator it = m_hSelector.selectedKeys().iterator();

                    while (it.hasNext()) {
                        SelectionKey key = (SelectionKey) it.next();

                        if (key.isReadable()) {
                            // 이미 연결된 클라이언트가 메시지를 보낸경우...
                            try {
                                read(key);
                            } catch (Exception e) {

                            }
                        }
                        // 이미 처리한 이벤트므로 반드시 삭제해준다.
                        it.remove();
                    }

                }
            } catch (Exception e) {
            }
        }
    }
}