做的成功的地方网站,分销网站建设,义乌论坛,九江市建设局官方网站解析服务器端代码 代码是放在app/lib下的src下的main/java#xff0c;而与之前放在app/src/main下路径不同
Main函数
Main函数里只放着创建MyServer类的一行
public static void main(String args[]){new MyServer();}
MyServer构造函数
1.获取本机IP地址
//获取本机IP地… 解析服务器端代码 代码是放在app/lib下的src下的main/java而与之前放在app/src/main下路径不同
Main函数
Main函数里只放着创建MyServer类的一行
public static void main(String args[]){new MyServer();}
MyServer构造函数
1.获取本机IP地址
//获取本机IP地址InetAddress addr InetAddress.getLocalHost();System.out.println(local host: addr);
2.创建serverSocket创建服务器套接字并绑定到一个端口上
//创建server socketServerSocket serverSocket new ServerSocket(9999);System.out.println(listen port 9999);3.accept方法监听等待
//等待客户端连接while(true){System.out.println(waiting client connect);//从连接请求队列中取出一个客户的连接请求然后创建与客户连接的Socket对象并将它返回// 如果队列中没有连接请求accept()方法就会一直等待直到接收到了连接请求才返回Socket socket serverSocket.accept();//连接成功返回socket对象System.out.println(accept client connect socket);new Thread(new Service(socket)).start();}
4.监听成功创建线程进行通信上一步while循环内最后一行
创建线程进行通信
线程构造函数内new数据传输通道 class Service implements Runnable{private Socket socket;private BufferedReader in null;public Service(Socket socket){this.socket socket;try{//InputStreamReader把字节流转化成字符流//BufferedReader用于读取字符流。它继承自Reader类提供了按行读取文件的功能in new BufferedReader(new InputStreamReader(socket.getInputStream()));}catch (IOException ex){ex.printStackTrace();}}重写的run函数内用一个while来不断读入客户端传来的流用BufferedReader
Overridepublic void run() {System.out.println(wait client message );try {while ((content in.readLine()) ! null) {//从socket连接读取到bye标识客户端发出断开连接请求if(content.equals(bye)){System.out.println(disconnect from client,close socket);//关闭socket输入输出流socket.shutdownInput();socket.shutdownOutput();socket.close(); //关闭socket连接break;}else {//从socket连接读取到的不是断开连接请求则像客户端发信息this.sendMessge(socket);}}} catch (Exception ex) {ex.printStackTrace();}}
如何sendMessage用PrintWriter
public void sendMessge(Socket socket) {PrintWriter pout null;try{String message hello,client!;System.out.println(messge to client: message);//OutputStreamWriter将字符流转换为字节流//BufferedWriter是缓冲字符输出流//PrintWriter字符类型的打印输出流pout new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),utf-8)),true);//利用输出流输出数据pout.println(message);}catch (IOException ex){ex.printStackTrace();}}
解析客户端代码
1.与服务器的连接
NetConn netConn new NetConn(handler);
2.与服务器的信息交流
其中的writer在与服务器进行连接会把它进行赋值它是获得了socket输出流的PrintWriter把信息给到服务器。注接收服务器的信息是在netConn线程的run方法里用了一个while
new Thread(){Overridepublic void run(){Log.i(TAG, send message to server);writer.println(hello,server);}}.start();NetConn是一个线程
在重写的 run 方法里
1.创建socket并连接对象
//创建socket对象socket new Socket();//connect,要保证服务器已启动socket.connect(new InetSocketAddress(10.0.2.2,9999),5000);
2.获取socket的输入输出流
//获取socket输入输出流in new BufferedReader(new InputStreamReader(socket.getInputStream(),utf-8));writer new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream(),utf-8)),true);Log.i(TAG,connect to server);3.再建一个线程接收服务器的数据
//接收服务器返回的数据Thread receiveServerMsg new Thread(){Overridepublic void run(){String fromserver null;try{while((fromserver in.readLine())!null){//发送消息给UI线程Message msg new Message();msg.what 1;msg.obj fromserver;toClientHandler.sendMessage(msg);}}catch (IOException ex){ex.printStackTrace();}}};
感觉hander像个快递员把在服务器接收数据线程里接收到的东西打包成message通过sendMessage函数发给UI线程就是那些Activity进行相应操作。
以下是MainActivity内的Handler
handler new Handler(Looper.getMainLooper()){//当数据处理子线程更新数据后发送消息给UI线程UI线程更新UIOverridepublic void handleMessage(Message msg){if(msg.what 1){txt.setText(msg.obj.toString());}}};
