stm32无线遥控器设计-控制端windows.zip_stm32 web_stm32控制windows_无线遥控器作业_网页控

package com.socket; import java.io.BufferedReader; import java.io.ByteArrayInputStream; import java.io.DataInputStream; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.SocketException; import java.nio.ByteBuffer; import java.nio.channels.DatagramChannel; import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.charset.Charset; import java.sql.SQLException; import java.util.Set; import com.SQL.SQLOperationJava; public class UDPSocket extends Thread{ //端口号 private static int port = 12347; private static String sendbuff = null; private static DatagramSocket serverIP; private static DatagramPacket recvPacket ; private static SQLOperationJava sqlOperationJava = null; private static int connCounts = 0; //========================================================== private static Selector selector = null; private static DatagramChannel channel = null; private static DatagramSocket socket = null; private static ByteBuffer receiveBuffer = null; private static InetSocketAddress client = null; private static DatagramChannel dc = null; private static InetSocketAddress clientSend = null; private static DatagramChannel dcSend = null; final int PACKAGE_SIZE = 1; //睡眠时间结束后结束当前连接的UDP private static int timeSleep = 10000; /* * 循环中接受客户端的请求 * 非阻塞 */ public UDPSocket() throws SocketException { super(); //System.out.println("init"); //serverIP = new DatagramSocket(port); sqlOperationJava = new SQLOperationJava(); try { selector = Selector.open(); channel = DatagramChannel.open(); channel.configureBlocking(false); socket = channel.socket(); socket.bind(new InetSocketAddress(port)); channel.register(selector, SelectionKey.OP_READ); receiveBuffer = ByteBuffer.allocate(1024); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } //运行线程函数 public void run() { closeUDP(); } public void recvIP() throws IOException, SQLException{ System.out.println("Recv start--- "); /*recvPacket = new DatagramPacket(recvBuf , recvBuf.length); serverIP.receive(recvPacket); //接受信息 //String recvStr = new String(recvPacket.getData() , 0 ,recvPacket.getLength()); sqlOperationJava.insertData(recvPacket.getAddress().toString().substring(1),recvPacket.getPort()); //System.out.println(recvPacket.getAddress().toString().substring(1)+" : "+recvPacket.getPort()); //sqlOperationJava.insertData(ipaddr.toString(), recvPacket.getPort()); //重置接受数组长度 //recvPacket.setLength(1024); */ int n = selector.select(); if(n > 0){ Set<SelectionKey> readyKeys = selector.selectedKeys(); for(SelectionKey key : readyKeys){ readyKeys.remove(key); if(key.isReadable()){ dc = (DatagramChannel)key.channel(); client = (InetSocketAddress)dc.receive(receiveBuffer); //接收来自任意一个Client的数据报 if(dc!=null) dcSend = dc; if(client!=null) clientSend = client; if(dc != null && client != null) { connCounts = 1; } else connCounts = 0; key.interestOps(SelectionKey.OP_READ); System.out.println("client ----> IP: " + client.getAddress().getHostAddress() + ", port: " + client.getPort()); sqlOperationJava.insertData(client.getAddress().getHostAddress(),client.getPort()); receiveBuffer.clear(); /* String echo = "server reply!"; ByteBuffer buffer = Charset.defaultCharset () .encode(echo); dc.send(buffer,client);*/ }//if } } System.out.println("Recv end--- "); } public void sendData(String sendbuff) throws IOException { //System.out.println("test0"+sendbuff); if(sendbuff!=null && dcSend != null && clientSend != null) { ByteBuffer buffer = Charset.defaultCharset ().encode(sendbuff); //确保数据发送 dcSend.send(buffer,clientSend); dcSend.send(buffer,clientSend); dcSend.send(buffer,clientSend); sendbuff = null; //recvPacket.setData(buff.getBytes()); //serverIP.send(recvPacket); } } public void closeUDP() { while(true) { try { sleep(timeSleep); clientSend=null; //if(dcSend != null) // dcSend.close(); connCounts = 0; } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } public void close() { serverIP.close(); sqlOperationJava.close(); } public void setSendbuff(String sendbuff) { UDPSocket.sendbuff = sendbuff; } public String getSendbuff() { return sendbuff; } public void setRecvPacket(DatagramPacket recvPacket) { UDPSocket.recvPacket = recvPacket; } public DatagramPacket getRecvPacket() { return recvPacket; } public void setServerIP(DatagramSocket serverIP) { UDPSocket.serverIP = serverIP; } public DatagramSocket getServerIP() { return serverIP; } public int getConnCounts() { return connCounts; } }