花了两个小时时间去看书写例子,遇到不少蛋疼的问题,把例子贴出来,以免忘记
服务器端:
import java.io.*; import java.net.*; public class mYServer { public static void main(String[] args) { ServerSocket serverSocket = null; Socket socket = null; OutputStream os = null; InputStream is = null; //监听端口号 int port = 8898; try { //建立连接 serverSocket = new ServerSocket(port); //获得连接 socket = serverSocket.accept(); //接收客户端发送内容 is = socket.getInputStream(); byte[] b = new byte[1024]; int n = is.read(b); //输出 System.out.println("客户端发送内容为:" + new String(b,0,n)); //向客户端发送反馈内容 os = socket.getOutputStream(); os.write(b, 0, n); } catch (Exception e) { e.printStackTrace(); }finally{ try{ //关闭流和连接 os.close(); is.close(); socket.close(); serverSocket.close(); }catch(Exception e){} } } }
import java.io.*; import java.net.*; public class mYClient { public static void main(String[] args) { Socket socket = null; InputStream is = null; OutputStream os = null; //服务器端IP地址 String serverIP = "127.0.0.1"; //服务器端端口号 int port = 8898; //发送内容 String data = "成功了"; try { //建立连接 socket = new Socket(serverIP,port); //发送数据 os = socket.getOutputStream(); os.write(data.getBytes()); //接收数据 is = socket.getInputStream(); byte[] b = new byte[1024]; int n = is.read(b); //输出反馈数据 System.out.println("服务器反馈:" + new String(b,0,n)); } catch (Exception e) { e.printStackTrace(); //打印异常信息 }finally{ try { //关闭流和连接 is.close(); os.close(); socket.close(); } catch (Exception e2) {} } } }
原文地址:http://blog.csdn.net/xiaomuzi0802/article/details/42122623