socket示例
?
先贴代码：一、服务器端线程import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.EOFException;import java.io.IOException;import java.net.Socket;import java.net.SocketException;import java.util.ArrayList;import java.util.List;/** * PolyLink 服务器端线程 * @author Administrator * */public class PolyLinkServerThread implements Runnable { Socket client; DataInputStream input; DataOutputStream output; public PolyLinkServerThread(Socket client) throws IOException { this.client = client; input = new DataInputStream(client.getInputStream()); output = new DataOutputStream(client.getOutputStream()); output.flush(); client.setSoTimeout(3000); } public void run() { try { //开始接收 List<Integer> list = new ArrayList<Integer>(); while(true){ int num = 0; try{ num = input.readInt(); }catch(SocketException e){ break; }catch(EOFException e){//如果读到文件末尾会发生这个异常,看JAVA的API break; }catch(Exception e){ break; } list.add(num); } int []intArr = new int[list.size()]; for(int i=0;i<list.size();i++){ intArr[i] = list.get(i); } String recieveMessage =StringUtil.asciiToString(intArr); //开始发送回执信息 String returnMessage = validateMessage(recieveMessage); int[]ascii = StringUtil.stringToAscii(returnMessage); for(int i:ascii){ output.writeInt(i); } input.close(); output.close(); client.close(); }catch (Exception e) { e.printStackTrace(); } } /** * 根据接受的消息返回一个需要返回消息的字符串 * @return */ public String validateMessage(String recieveMessage){ System.out.println("服务器端接收到的消息为："+recieveMessage); return "根据接收信息格式不同生成不同的回执信息"; }}二、服务端import java.net.ServerSocket;import java.net.Socket;/** * PolyLink服务器 * @author Administrator * */public class PloyLinkServer { public final static int PORT = 8989; /** * 启动PloyLinkServer服务 * @param args */ public static void startPloyLinkServer() { ServerSocket serverSocket = null; Socket socket = null; try { serverSocket = new ServerSocket(PORT); while (true) { socket = serverSocket.accept(); PolyLinkServerThread lpst = new PolyLinkServerThread(socket); ThreadPool.setProducerPool(lpst); } }catch (Exception ex) { ex.printStackTrace(); } } public static void main(String []args) throws InterruptedException{ startPloyLinkServer(); }}三、客户端import java.io.DataInputStream;import java.io.DataOutputStream;import java.io.EOFException;import java.io.IOException;import java.io.OutputStream;import java.net.Socket;import java.net.UnknownHostException;import java.util.ArrayList;import java.util.List;/** * PolyLink客户端 * @author Administrator * */public class PolyLinkClient{ public Socket socket = null; OutputStream netOut = null; DataOutputStream out = null; DataInputStream in = null; public PolyLinkClient() throws UnknownHostException, IOException{ socket = new Socket("192.163.35.114", 8989); socket.setSoTimeout(10000); netOut = socket.getOutputStream(); out = new DataOutputStream(netOut); in = new DataInputStream(socket.getInputStream()); } /** * 给服务器发报文,并返回接收报文 */ public String sendMessageByASCII(String message){ String recieveMessage = ""; try { //开始发送 int[]ascii = StringUtil.stringToAscii(message); out.flush(); for(int i:ascii){ out.writeInt(i); } //开始接收 List<Integer> list = new ArrayList<Integer>(); while(true){ int num = 0; try{ num = in.readInt(); }catch(EOFException e){ break; }catch(Exception e){ break; } list.add(num); } int []intArr = new int[list.size()]; for(int i=0;i<list.size();i++){ intArr[i] = list.get(i); } recieveMessage =StringUtil.asciiToString(intArr); in.close(); out.close(); socket.close(); }catch (UnknownHostException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return recieveMessage; } public static void main(String []args) throws InterruptedException, UnknownHostException, IOException{ PolyLinkClient p = new PolyLinkClient(); String sendMssage = "8d431f27280a4a7b8c1a0d2f29bdb9a4TART:START:66667890"+"TART:START:66667890\r\nRECV-IP:192.168.17.33\r\nRECV-PORT:1234\r\nPAYLOAD-TYPE:TS\r\n\r\n"; String recieveMessage = p.sendMessageByASCII(sendMssage); System.out.println("客户端接受的消息为:"+recieveMessage); }}四、线程池import java.util.concurrent.ArrayBlockingQueue;import java.util.concurrent.ThreadPoolExecutor;import java.util.concurrent.TimeUnit;/** * 线程池 * @author Administrator * */public class ThreadPool { /** * 构造一个线程池.核心线程一个，最大线程数100.线程队列容纳10个。超出最大线程数的处理策略为重蹈覆添加该线程,知道添加成功为止 */ private static ThreadPoolExecutor producerPool = new ThreadPoolExecutor(1, 100, 0, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10), new ThreadPoolExecutor.CallerRunsPolicy()); /** * 把PolyLinkServerThread线程放到了线程池中,具体的线程执行由线程池操作 * @param thread */ public static void setProducerPool(PolyLinkServerThread lpst) { producerPool.execute(lpst); }} 五。ascii转换函数 /** * 字符串转ascii码,包含中文 * @param str * @return */ public static int[] stringToAscii(String str) { char[] chars = str.toCharArray(); int intArr[]= new int[chars.length]; for (int i=0;i<chars.length;i++) {// 输出结果 intArr[i] = (int)chars[i]; } return intArr; }代码编写过程中遇到错误多多，以前都是做个示例，没这么多错误哇。。。错误一、java.net.SocketException: Connection reset这个是由于client端发数据的时候发完没有关闭in,out，server造成的。还有服务器端的读取in.readInt()函数也造成这个错误。另外，服务器端读取的时候，in.available()这个函数是非常非常不靠谱的。因为socket发送时候网络上的岩石,available()这个函数不能正确的反映出可读的字节数量、正确的做法是用eofException这个异常来判断读取结束。错误二、Exception。。。closed by peer当服务端接受了客户端的数据以后，会向客户端发送数据，但是这个时候客户端已经关闭了！⊙﹏⊙b汗！。此时就要这样output.flush();client.setSoTimeout(3000);用一下out，然后客户端等待一会儿。不知道为什吗，output.flush();这个必须要。+_+问题三、就是要深入的研究一下这个线程池ThreadPool。。啦啦啦这个以后再弄了?