soceket发来的数显示显示全是乱码,错在哪里了?
时间:2023-12-14 14:07:02
import java.io.*; import java.net.*; import java.sql.*; public class acnu{ public static void main(String args[]) throws IOException{ acnu(); //stnu(); //ReceiveFiles(); } public static void ReceiveFiles() throws IOException { int i = 0; ServerSocket server = new ServerSocket(800); System.out.println("server将永远等待连接的到来"); Socket socket = server.accept(); InputStream inputStream = socket.getInputStream(); byte[] bytes = new byte[1024]; String path_temp = File.separator "home" File.separator "lishulin" File.separator "666" File.separator "166" File.separator String.valueOf(i ) ".xls"; OutputStream outs = new BufferedOutputStream(new FileOutputStream(path_temp)); System.out.println("服务器正在接收文件..."); inputStream = socket.getInputStream(); while (inputStream.read(bytes) != -1) { outs.write(bytes); } outs.flush(); server.close(); socket.close(); inputStream.close(); outs.close(); System.out.println("接收服务器后"); } /** *@breif: server accept number */ public static void acnu() throws IOException{ var ss = new ServerSocket(800); while(true){ System.out.println("\n"); System.out.println("等待Socket发数..."); Socket s = ss.accept(); var in = new BufferedReader(new InputStreamReader(s.getInputStream())); String sv = null; while((sv = in.readLine())!= null){ System.out.println("Socket发来的报告文件名为:" sv); } in.close(); s.close(); } } public static void stnu(int price){ try{ Class.forName("com.mysql.jdbc.Driver"); Connection conn=DriverManager.getConnection("jdbc:mysql://localhost:3306/aa?useUnicode=true&characterEncoding=utf8","root","jian8182"); Statement stmt=conn.createStatement(); String sql ="insert into u values(" price ");"; var rs=stmt.execute(sql); //String sql ="show tables;"; //String sql ="desc u;"; //String sql ="select * from u;"; //ResultSet rs=stmt.executeQuery(sql); //var rs=stmt.executeQuery(sql);//watch databases; /** for(int i=0;i<5;i ){ stmt.executeUpdata(sql); } */ //String sql2 = "use aa;"; //ResultSet rs2 = stmt.executeQuery(sql2); //String sql3 = "desc test;"; //ResultSet rs3 = stmt.executeQuery(sql2); /** while(rs.next()){ System.out.println(rs.getString(1)); } */ }catch(Exception e){ e.printStackTrace(); } } }