首页 > 代码库 > socket 开发一
socket 开发一
其实web 开发的底层就是socket 编程
数据是通过流读取
服务端
public class WeatherServer { public static void main(String[] args) throws IOException { // 创建socket 服务，应用服务端口建议在１万以上 ServerSocket server = null; Socket socket = null; DataInputStream di=null ; DataOutputStream ds=null ; try { server = new ServerSocket(12345); // 按受客户端链接 socket = server.accept(); //为了好处理字符串 // 接受客户端请求 di=new DataInputStream(socket.getInputStream()); // 向服务端发送请求 ds=new DataOutputStream(socket.getOutputStream()); //客户端向服务端发送的天气所在城市 String cityName =di.readUTF(); System.out.println("from client...."+cityName); //服务端向客户端返回天气情况 String result ="晴"; ds.writeUTF("晴"); System.out.println("to client...."+result); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { di.close(); ds.close(); //服务端一般是不关闭资源的，由客户端关闭 //socket.close(); } }}
客户端代码：
public class WeatherClient { public static void main(String[] args) throws UnknownHostException, IOException { Socket client = null; DataInputStream di = null; DataOutputStream ds = null; client = new Socket("127.0.0.1", 12345); try { // 接受客户端请求 di = new DataInputStream(client.getInputStream()); // 向服务端发送请求 ds = new DataOutputStream(client.getOutputStream()); String cityName ="北京"; ds.writeUTF(cityName); String result =di.readUTF(); System.out.println("接受服务端.."+result); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { di.close() ; ds.close(); client.close(); } }}
其实服务端开发要有可持续能力，保证线程一直在运行，那么上面的代码就可以改成这样：
public class WeatherServerV2 { public static void main(String[] args) throws IOException { // 创建socket 服务，应用服务端口建议在１万以上 ServerSocket server = null; Socket socket = null; DataInputStream di=null ; DataOutputStream ds=null ; while(true){ try { server = new ServerSocket(12345); // 按受客户端链接 socket = server.accept(); //为了好处理字符串 // 接受客户端请求 di=new DataInputStream(socket.getInputStream()); // 向服务端发送请求 ds=new DataOutputStream(socket.getOutputStream()); //客户端向服务端发送的天气所在城市 String cityName =di.readUTF(); System.out.println("from client...."+cityName); //服务端向客户端返回天气情况 String result ="晴"; ds.writeUTF("晴"); System.out.println("to client...."+result); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { di.close(); ds.close(); //服务端一般是不关闭资源的，由客户端关闭 //socket.close(); } } }}
同样的道理，服务端不仅要有持续运行能力，还要有处理并发的能力，我们可以把客户端也改成死循环
public class WeatherClientVersion2 { public static void main(String[] args) throws UnknownHostException, IOException { Socket client = null; DataInputStream di = null; DataOutputStream ds = null; client = new Socket("127.0.0.1", 12345); while(true){ try { // 接受客户端请求 di = new DataInputStream(client.getInputStream()); // 向服务端发送请求 ds = new DataOutputStream(client.getOutputStream()); String cityName ="北京"; ds.writeUTF(cityName); String result =di.readUTF(); System.out.println("接受服务端.."+result); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { di.close() ; ds.close(); client.close(); } } } }
socket 开发一
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。