android開發學習——Socket發送和接收


client -- server發送過程中,涉及的輸入流輸出流: 

 
需要注意的是:先運行服務器端,再進行客戶端。
 
 http://blog.csdn.net/qq7342272/article/details/9698413  (值得推薦的好文)
 
public class SocketServer {

    public static void main(String[] args) {
SocketServer socketServer
= new SocketServer(); socketServer.startServer(); } public void startServer() { ServerSocket serverSocket = null; Socket socket = null; try {
//1.建立一個服務器端,綁定指定端口 serverSocket
= new ServerSocket(9898); System.out.println("server started.."); while (true) {
//2.等待客戶端的連接。如果有客戶端接入,則執行下面的代碼;沒有客戶端接入,在這里阻塞。 socket
= serverSocket.accept();
// 如果有客戶端接入,在此方法執行客戶端和服務器數據傳輸的操作。 manageConnection(socket); } }
catch (Exception e) { e.printStackTrace(); } finally { try { socket.close(); serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } public void manageConnection(final Socket socket) { new Thread(new Runnable() { @Override public void run() { BufferedReader reader = null; BufferedWriter writer =null; try { System.out.println("client " + socket.hashCode() + " connedted");
//3.從網絡->內存 in 獲得輸入流 reader
= new BufferedReader(new InputStreamReader(socket.getInputStream()));
//3.從內存->網絡 out 獲得輸出流 writer
= new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); String receivedMsg;
//4.得到客戶端發來的消息
while ((receivedMsg = reader.readLine()) != null) { System.out.println("client " + socket.hashCode() + ": " + receivedMsg);
//4.向客戶端寫出消息 writer.write(
"server reply: " + receivedMsg + "\n"); writer.flush(); } } catch (IOException e) { e.printStackTrace(); } finally {
//5.關閉資源
try { reader.close(); writer.close(); } catch (IOException e) { e.printStackTrace(); } } } }).start(); } }
public class SocketClient {

    public static void main(String[] args) {
        SocketClient client = new SocketClient();
        client.start();
    }
    
    public void start() {
        BufferedReader inputReader = null;
        BufferedReader reader = null;
        BufferedWriter writer = null;
        Socket socket = null;
        try {
//1.建立客戶端socket連接,指定服務器位置及端口 socket
= new Socket("127.0.0.1", 9898);
//2.從網絡->內存 in reader
= new BufferedReader(new InputStreamReader(socket.getInputStream()));
//2.從內存->網絡 out writer
= new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
inputReader
= new BufferedReader(new InputStreamReader(System.in)); startServerReplyListener(reader); String inputContent; int count = 0;
while (!(inputContent = inputReader.readLine()).equals("bye")) {
//3.向客戶端發送消息 writer.write(inputContent);
if (count % 2 ==0) { writer.write("\n"); } count++; writer.flush(); } } catch (Exception e) { e.printStackTrace(); } finally {
//4.關閉資源
try { reader.close(); writer.close(); inputReader.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } public void startServerReplyListener(final BufferedReader reader) { new Thread(new Runnable() { @Override public void run() { try { String response;
//3.得到客戶端發來的消息
while ((response = reader.readLine()) != null) { System.out.println(response); } } catch (IOException e) { e.printStackTrace(); } } }).start(); } }

 

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM