java程式獲取MindWave Mobile 2腦波耳機資料+二次開發
初始程式碼包下載：連結：https://pan.baidu.com/s/1nEb5kmk8PabkFmK3bO8Fww
提取碼：r5pu
解壓後用eclipse開啟該專案
在src中建立名字為lib的package，
講這三個.jar檔案複製到lib下
匯入jar檔案方法如下：
大致的目錄結構如下：
然後修改brainkeyboard.java程式碼為：
import java.net.ConnectException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Timer;
import java.util.TimerTask;
import neurosky.ThinkGearSocket;
import processing.core.PApplet;
import processing.core.PFont;
import processing.core.PImage;
public class brainkeyboard extends PApplet {
/*可讀取的引數 int delta, int theta, int low_alpha, int high_alpha,
int low_beta, int high_beta, int low_gamma, int mid_gamma
*/
ThinkGearSocket neuroSocket;
static int attention = 0;
static int mytheta=0;
static int mydelta=0;
static int mylow_alpha=0;
static int myhigh_alpha=0;
static int mylow_beta=0,myhigh_beta=0;
int blinkSt = 0;
int blink = 0;
int k=0;
/*------------------------------------*/
String[] letter = {"A","B","C","D","E","F","G","H","I","J","K","L"," "," ","M","N","O","P","Q","R","S","T","U","V","W","X","Y","Z","-","-"};
/*------------------------------------*/
String input = " ";
String lockinput=" ";
int t=0;
PFont font;
PImage bg;
int i=30,j=110;
/*------------------------------------*/
public void setup()
{
size (550, 300);
ThinkGearSocket neuroSocket = new ThinkGearSocket(this);
try
{
neuroSocket.start();
}
catch (ConnectException e) {
e.printStackTrace();
}
fill(0);
font = createFont("Courier",48);
textFont(font);
bg=loadImage("1.jpg");
}
/*------------------------------------*/
public void draw() {
background(120);
fill(255, 255, 0);
textSize(12);
text("Attention: " + attention,100, 10);
strokeJoin(ROUND);
stroke(50,100,150);
strokeWeight(3);
fill(255);
rect(30,30,500,50);
// ----------------------------------------
if (blinkSt>0)
{
if(letter[k]=="-"){
input = input.substring(0,input.length()-1);
}
else{
input = input+letter[k];
lockinput = input;
fill(0);
textSize(18);
text(input, 40, 48, 195, 30);
textSize(48);
}
}
//-----------------------------------------------------
fill(255, 255, 0);
textSize(12);
text("Blink: " + blinkSt, 10, 10);
blinkSt=0;
fill(0);
textSize(18);
text(lockinput, 40, 48, 500, 30);
textSize(48);
//------------------------------------------------------
image(bg,30,110);
noFill();
stroke(255);
rect(i,j,50,50);
// 自己加的兩行
// print( "i:"+i +" " + "j:"+ j + " " + "k:"+ k + " " +"Blinkst:" + blinkSt);
// ---------------------------------------------
if(attention > 40)
{
t=50;
println(" Attention: " + attention);
// attention=0;
}
if(t ==50){
if(i<450){
i=i+50;
}
else{
i=30;
if(j<200)
{
j=j+50;
}
else{
j=110;
}
}
// -------------------------------------
if(k<29)
{
k =k+1;
}
else
{k=0;}
t=0;
}
t++;
}
/*------------------------------------*/
public void blinkEvent(int blinkStrength)
{
blinkSt = blinkStrength;
// blink = 1;
}
/*------------------------------------*/
public void attentionEvent(int attentionLevel)
{
attention = attentionLevel;
}
public void eegEvent(int delta, int theta, int low_alpha, int high_alpha, int low_beta, int high_beta, int low_gamma, int mid_gamma)
{
mytheta=theta;
mydelta=delta;
myhigh_alpha=high_alpha;
mylow_alpha=low_alpha;
mylow_beta=low_beta;
myhigh_beta=high_beta;
}
/*------------------------------------*/
public void stop() {
neuroSocket.stop();
super.stop();
}
//定時
static Timer timer =new Timer(true);
// 注意，javax.swing包中也有一個Timer類，如果import中用到swing包,要注意名字的衝突。
static TimerTask task = new TimerTask() {
public void run() {
//每次需要執行的程式碼放到這裡面。
System.out.println("專注度："+attention+" theta:"+mytheta+" mydelta:"+mydelta
+" mylow_alpha："+mylow_alpha+" myhigh_alpha："+myhigh_alpha+" mylow_beta："+mylow_beta+" myhigh_beta："+myhigh_beta);
System.out.println( System.currentTimeMillis());
try {
PreparedStatement ps=conn.prepareStatement("insert into biao values(?,?,?,?,?,?,?)");
ps.setInt(1, attention );
ps.setInt(2, mytheta);
ps.setInt(3, mydelta);
ps.setInt(4, mylow_alpha);
ps.setInt(5, myhigh_alpha);
ps.setInt(6,mylow_beta );
ps.setInt(7, myhigh_beta);
ps.execute();
System.out.println("zhou");
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
};
// JDBC 驅動名及資料庫 URL
static final String JDBC_DRIVER = "com.mysql.cj.jdbc.Driver";
//"jdbc:mysql://localhost:3306/RUNOOB";
static final String DB_URL =
"jdbc:mysql://localhost:3306/zhou?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&&allowPublicKeyRetrieval=true";
// 資料庫的使用者名稱與密碼，需要根據自己的設定
static final String USER = "root";
static final String PASS = "123456";
static Connection conn = null;
static public void main(String args[]) {
try{
// 註冊 JDBC 驅動
Class.forName(JDBC_DRIVER);
// 開啟連結
System.out.println("連線資料庫...");
conn = DriverManager.getConnection(DB_URL,USER,PASS);
}catch(SQLException se){
// 處理 JDBC 錯誤
se.printStackTrace();
}catch(Exception e){
// 處理 Class.forName 錯誤
e.printStackTrace();
}
timer.schedule(task,10000,1000);
PApplet.main(new String[] { "--bgcolor=#ECE9D8", "brainkeyboard" });
}
}
功能：讀取腦波耳機中的α、β、attention等資料值存放到mysql資料庫，1秒鐘更新一次
資料如下：
ThinkGear.jar原始碼如下：
| /* |
| * |
| * This provides a simple socket connector to the NeuroSky MindWave ThinkGear connector. |
| * For more info visit http://crea.tion.to/processing/thinkgear-java-socket |
| * |
| * No warranty or any stuffs like that. |
| * |
| * Have fun! |
| * Andreas Borg |
| * [email protected] |
| * |
| * |
| * (c) 2010 |
| * |
| * This library is free software; you can redistribute it and/or |
| * modify it under the terms of the GNU Lesser General Public |
| * License as published by the Free Software Foundation; either |
| * version 2.1 of the License, or (at your option) any later version. |
| * |
| * This library is distributed in the hope that it will be useful, |
| * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
| * Lesser General Public License for more details. |
| * |
| * You should have received a copy of the GNU Lesser General |
| * Public License along with this library; if not, write to the |
| * Free Software Foundation, Inc., 59 Temple Place, Suite 330, |
| * Boston, MA 02111-1307 USA |
| * |
| * @author Andreas Borg, [email protected] |
| * @modified June, 2011 |
| * @version 1.0 |
| * |
| * |
| * This library is following the same design as the one developed by Jorge C. S. Cardoso for the MindSet device. |
| * The MindWave device can communicate to a socket over JSON instead of the serial port. That makes it easier and tidier |
| * to talk between the device and Java. For instructions on how to use the callback listeners please refer to |
| * |
| * http://jorgecardoso.eu/processing/MindSetProcessing/ |
| * |
| * |
| * Data is passed back to the application via the following callback methods: |
| * |
| * |
| * public void attentionEvent(int attentionLevel) |
| * Returns the current attention level [0, 100]. |
| * Values in [1, 20] are considered strongly lowered. |
| * Values in [20, 40] are considered reduced levels. |
| * Values in [40, 60] are considered neutral. |
| * Values in [60, 80] are considered slightly elevated. |
| * Values in [80, 100] are considered elevated. |
| * |
| * public void meditationEvent(int meditationLevel) |
| * Returns the current meditation level [0, 100]. |
| * The interpretation of the values is the same as for the attentionLevel. |
| * |
| * |
| * public void poorSignalEvent(int signalLevel) |
| * Returns the signal level [0, 200]. The greater the value, the more noise is detected in the signal. |
| * 200 is a special value that means that the ThinkGear contacts are not touching the skin. |
| * |
| * |
| * public void eegEvent(int delta, int theta, int low_alpha, int high_alpha, int low_beta, int high_beta, int low_gamma, int mid_gamma) </code><br> |
| * Returns the EEG data. The values have no units. |
| * |
| * |
| * |
| * public void rawEvent(int []) |
| * Returns the the current 512 raw signal samples [-32768, 32767]. |
| * |
| * |
| */ |
| package neurosky; |
| import java.io.BufferedReader; |
| import java.io.IOException; |
| import java.io.InputStream; |
| import java.io.InputStreamReader; |
| import java.io.OutputStream; |
| import java.io.PrintWriter; |
| import java.lang.reflect.Method; |
| import java.net.ConnectException; |
| import java.net.Socket; |
| import java.net.SocketException; |
| import java.net.UnknownHostException; |
| import java.util.Iterator; |
| import org.json.JSONException; |
| import org.json.JSONObject; |
| import processing.core.PApplet; |
| public class ThinkGearSocket implements Runnable{ |
| public PApplet parent; |
| public Socket neuroSocket; |
| public OutputStream outStream; |
| public InputStream inStream; |
| public BufferedReader stdIn; |
| private Method attentionEventMethod = null; |
| private Method meditationEventMethod = null; |
| private Method poorSignalEventMethod = null; |
| private Method blinkEventMethod = null; |
| private Method eegEventMethod = null; |
| private Method rawEventMethod = null; |
| public String appName=""; |
| public String appKey=""; |
| private Thread t; |
| private int raw[] = new int[512]; |
| private int index = 0; |
| public final static String VERSION = "1.0"; |
| private boolean running = true; |
| public ThinkGearSocket(PApplet _parent, String _appName,String _appKey){ |
| this(_parent); |
| appName = _appName;//these were mentioned in the documentation as required, but test prove they are not. |
| appKey = _appKey; |
| } |
| public ThinkGearSocket(PApplet _parent){ |
| parent = _parent; |
| try { |
| attentionEventMethod = |
| parent.getClass().getMethod("attentionEvent", new Class[] { |
| int.class |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("attentionEvent() method not defined. "); |
| } |
| try { |
| meditationEventMethod = |
| parent.getClass().getMethod("meditationEvent", new Class[] { |
| int.class |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("meditationEvent() method not defined. "); |
| } |
| try { |
| poorSignalEventMethod = |
| parent.getClass().getMethod("poorSignalEvent", new Class[] { |
| int.class |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("poorSignalEvent() method not defined. "); |
| } |
| try { |
| blinkEventMethod = |
| parent.getClass().getMethod("blinkEvent", new Class[] { |
| int.class |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("blinkEvent() method not defined. "); |
| } |
| try { |
| eegEventMethod = |
| parent.getClass().getMethod("eegEvent", new Class[] { |
| int.class, int.class, int.class, int.class, int.class, int.class, int.class, int.class |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("eegEvent() method not defined. "); |
| } |
| try { |
| rawEventMethod = |
| parent.getClass().getMethod("rawEvent", new Class[] { |
| int[].class |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("rawEvent() method not defined. "); |
| } |
| } |
| public boolean isRunning(){ |
| return running; |
| } |
| /** |
| * return the version of the library. |
| * |
| * @return String |
| */ |
| public static String version() { |
| return VERSION; |
| } |
| public void start() throws ConnectException{ |
| try { |
| neuroSocket = new Socket("127.0.0.1",13854); |
| } catch (ConnectException e) { |
| //e.printStackTrace(); |
| System.out.println("Oi plonker! Is ThinkkGear running?"); |
| running = false; |
| throw e; |
| } catch (UnknownHostException e) { |
| e.printStackTrace(); |
| } catch (IOException e) { |
| e.printStackTrace(); |
| } |
| try { |
| inStream = neuroSocket.getInputStream(); |
| outStream = neuroSocket.getOutputStream(); |
| stdIn = new BufferedReader(new InputStreamReader(neuroSocket.getInputStream())); |
| running = true; |
| } catch (IOException e) { |
| e.printStackTrace(); |
| } |
| if(appName !="" && appKey !=""){ |
| JSONObject appAuth = new JSONObject(); |
| try { |
| appAuth.put("appName", appName); |
| } catch (JSONException e1) { |
| // TODO Auto-generated catch block |
| e1.printStackTrace(); |
| } |
| try { |
| appAuth.put("appKey", appKey); |
| } catch (JSONException e1) { |
| // TODO Auto-generated catch block |
| e1.printStackTrace(); |
| } |
| //throws some error |
| sendMessage(appAuth.toString()); |
| System.out.println("appAuth"+appAuth); |
| } |
| JSONObject format = new JSONObject(); |
| try { |
| format.put("enableRawOutput", true); |
| } catch (JSONException e) { |
| // TODO Auto-generated catch block |
| System.out.println("raw error"); |
| e.printStackTrace(); |
| } |
| try { |
| format.put("format", "Json"); |
| } catch (JSONException e) { |
| // TODO Auto-generated catch block |
| System.out.println("Json error"); |
| e.printStackTrace(); |
| } |
| //System.out.println("format "+format); |
| sendMessage(format.toString()); |
| t = new Thread(this); |
| t.start(); |
| } |
| @SuppressWarnings("deprecation") |
| public void stop(){ |
| if(running){ |
| t.interrupt(); |
| try { |
| neuroSocket.close(); |
| inStream.close(); |
| outStream.close(); |
| stdIn.close(); |
| stdIn = null; |
| } catch (IOException e) { |
| // TODO Auto-generated catch block |
| e.printStackTrace(); |
| //System.out.println("Socket close issue"); |
| } |
| } |
| running = false; |
| } |
| public void sendMessage(String msg){ |
| PrintWriter out = new PrintWriter(outStream, true); |
| //System.out.println("sendmsg"); |
| out.println(msg); |
| } |
| @Override |
| public void run() { |
| if(running && neuroSocket.isConnected()){ |
| String userInput; |
| try { |
| while ((userInput = stdIn.readLine()) != null) { |
| String[] packets = userInput.split("/\r/"); |
| for(int s=0;s<packets.length;s++){ |
| if(((String) packets[s]).indexOf("{")>-1){ |
| JSONObject obj = new JSONObject((String) packets[s]); |
| parsePacket(obj); |
| } |
| //String name = obj.get("name").toString(); |
| } |
| } |
| } |
| catch(SocketException e){ |
| //System.out.println("For some reason stdIn throws error even if closed"); |
| //maybe it takes a cycle to close properly? |
| //e.printStackTrace(); |
| } |
| catch (IOException e) { |
| // TODO Auto-generated catch block |
| e.printStackTrace(); |
| } catch (JSONException e) { |
| // TODO Auto-generated catch block |
| //e.printStackTrace(); |
| } |
| parent.delay(50); |
| }else{ |
| running = false; |
| } |
| } |
| private void triggerAttentionEvent(int attentionLevel) { |
| if (attentionEventMethod != null) { |
| try { |
| attentionEventMethod.invoke(parent, new Object[] { |
| attentionLevel |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("Disabling attentionEvent() because of an error."); |
| e.printStackTrace(); |
| attentionEventMethod = null; |
| } |
| } |
| } |
| private void triggerMeditationEvent(int meditationLevel) { |
| if (meditationEventMethod != null) { |
| try { |
| meditationEventMethod.invoke(parent, new Object[] { |
| meditationLevel |
| } |
| ); |
| //println("Attention: " + attention); |
| } |
| catch (Exception e) { |
| System.err.println("Disabling meditationEvent() because of an error."); |
| e.printStackTrace(); |
| meditationEventMethod = null; |
| } |
| } |
| } |
| private void triggerPoorSignalEvent(int poorSignalLevel) { |
| if (poorSignalEventMethod != null) { |
| try { |
| poorSignalEventMethod.invoke(parent, new Object[] { |
| poorSignalLevel |
| } |
| ); |
| //println("Attention: " + attention); |
| } |
| catch (Exception e) { |
| System.err.println("Disabling meditationEvent() because of an error."); |
| e.printStackTrace(); |
| poorSignalEventMethod = null; |
| } |
| } |
| } |
| private void triggerBlinkEvent(int blinkStrength) { |
| if (blinkEventMethod != null) { |
| try { |
| blinkEventMethod.invoke(parent, new Object[] { |
| blinkStrength |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("Disabling blinkEvent() because of an error."); |
| e.printStackTrace(); |
| blinkEventMethod = null; |
| } |
| } |
| } |
| private void triggerEEGEvent(int delta, int theta, int low_alpha, int high_alpha, int low_beta, int high_beta, int low_gamma, int mid_gamma) { |
| if (eegEventMethod != null) { |
| try { |
| eegEventMethod.invoke(parent, new Object[] { |
| delta, theta, low_alpha, high_alpha, low_beta, high_beta, low_gamma, mid_gamma |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("Disabling eegEvent() because of an error."); |
| e.printStackTrace(); |
| eegEventMethod = null; |
| } |
| } |
| } |
| private void triggerRawEvent(int []values) { |
| if (rawEventMethod != null) { |
| try { |
| rawEventMethod.invoke(parent, new Object[] { |
| values |
| } |
| ); |
| } |
| catch (Exception e) { |
| System.err.println("Disabling rawEvent() because of an error."); |
| e.printStackTrace(); |
| rawEventMethod = null; |
| } |
| } |
| } |
| private void parsePacket(JSONObject data){ |
| Iterator itr = data.keys(); |
| while(itr.hasNext()) { |
| Object e = itr.next(); |
| String key = e.toString(); |
| try{ |
| if(key.matches("poorSignalLevel")){ |
| triggerPoorSignalEvent(data.getInt(e.toString())); |
| } |
| if(key.matches("rawEeg")){ |
| int rawValue = (Integer) data.get("rawEeg"); |
| raw[index] = rawValue; |
| index++; |
| if (index == 512) { |
| index = 0; |
| int rawCopy[] = new int[512]; |
| parent.arrayCopy(raw, rawCopy); |
| triggerRawEvent(rawCopy); |
| } |
| } |
| if(key.matches("blinkStrength")){ |
| triggerBlinkEvent(data.getInt(e.toString())); |
| } |
| if(key.matches("eSense")){ |
| JSONObject esense = data.getJSONObject("eSense"); |
| triggerAttentionEvent(esense.getInt("attention")); |
| triggerMeditationEvent(esense.getInt("meditation")); |
| } |
| if(key.matches("eegPower")){ |
| JSONObject eegPower = data.getJSONObject("eegPower"); |
| triggerEEGEvent(eegPower.getInt("delta"), eegPower.getInt("theta"), eegPower.getInt("lowAlpha"), eegPower.getInt("highAlpha"),eegPower.getInt("lowBeta"), eegPower.getInt("highBeta"),eegPower.getInt("lowGamma"), eegPower.getInt("highGamma")); |
| //System.out.println(key); |
| } |
| } |
| catch(Exception ex){ |
| ex.printStackTrace(); |
| } |
| } |
| // |
| } |
| } |