handletcp.java

来自「java短信猫收发」· Java 代码 · 共 62 行

package topeak.localestar;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class HandleTCP implements Runnable {

	private ServerSocket serverSocket=null;
	
	private DataInputStream bufferedReader;

	private DataOutputStream bufferedWriter;
	
	public void run() {
		// TODO Auto-generated method stub
		try {
			serverSocket=new ServerSocket(55555);
			Socket s=null;
			HandleModem modem=new HandleModem();
			while(true){
				StringBuffer sms=null;
				s=serverSocket.accept();
				bufferedReader=new DataInputStream(s.getInputStream());
				String read;
				byte chars[] = new byte[2048];
				bufferedReader.read(chars);
				read = new String(chars);
				System.out.println("read: "+read.trim());
				modem.write("AT+CMGD=1");
				modem.readWait();
				//#,手机号,短信内容
				//forexample: #,1123654789632,hello
				if(read.startsWith("#,")){
					sms=new StringBuffer();
					String[] str=read.split(",");
					sms.append(str[2].trim());
					sms.append((char)0x1A);
					modem.write("AT+CMGS=+86"+str[1].trim());
					modem.readWait();
					modem.writeSpecial(sms.toString());
					modem.readWait();
				}
				s.close();
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

	public static void main(String [] args){
		HandleTCP tcp=new HandleTCP();
		tcp.run();
	}
}