TCP 프로토콜 기반 소켓 통신 (1) 분류 안드로이드 기본 입문 튜토리얼

이 섹션 소개:

이전 섹션의 개념 수업은 지루했지만 항상 보람찬 일이 있었죠? TCP 프로토콜을 기반으로 하는 소켓에 대해 공부하면서 이 섹션을 시작하겠습니다. 통신을 위해서는 먼저 소켓 통신의 모델인 소켓의 개념과 소켓 구현 단계, 소켓 서비스로서의 개념을 이해해보자. 의뢰인과 의뢰인은 각자 하고 싶은 일을 해야 합니다! 좋아, 이 소켓을 더 얕은 곳에서 더 깊은 곳으로 디버깅해 봅시다!

---

소켓이란 무엇입니까?

---

2.소켓 통신 모델:

소켓 통신 구현 단계 분석:

1단계: ServerSocket 및 소켓 생성

2단계 : 연결된 소켓을 엽니다. 입력/출력 스트림

3단계: 프로토콜에 따라 소켓 읽기/쓰기

4단계: 입력 및 출력 스트림을 닫고 소켓

자, 간단하게 작성해 보겠습니다. 예를 들어, 클라이언트는 서버를 시작한 후 버튼을 클릭한 후 서버에 연결합니다. 그리고 소켓을 통해 서버에 대한 연결을 나타내는 문자열 문자열을 서버에 보냅니다~

---

3. 소켓 서버 작성:

서버가 수행해야 할 작업은 다음과 같습니다:

1단계 : ServerSocket 객체 생성, 리스닝 포트 바인딩

2단계: accept() 메서드를 호출하여 클라이언트의 요청을 모니터링

3단계: 연결이 설정된 후 클라이언트가 보낸 요청 정보를 읽습니다. 입력 스트림

4단계 : 출력 스트림을 통해 클라이언트에 응답 정보 보내기

5단계: 관련 리소스 닫기

코드 구현:

Eclipse에서 직접 Java 프로젝트를 생성한 후 붙여넣기 Java 코드를 그 안에 넣으세요!

public class SocketServer {
	public static void main(String[] args) throws IOException {
		//1.创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
		ServerSocket serverSocket = new ServerSocket(12345);
		InetAddress address = InetAddress.getLocalHost();
		String ip = address.getHostAddress();
		Socket socket = null;
		//2.调用accept()等待客户端连接
		System.out.println("~~~服务端已就绪，等待客户端接入~，服务端ip地址: " + ip);
		socket = serverSocket.accept();
		//3.连接后获取输入流，读取客户端信息
		InputStream is=null;
		InputStreamReader isr=null;
		BufferedReader br=null;
		OutputStream os=null;
		PrintWriter pw=null;
		is = socket.getInputStream();     //获取输入流
		isr = new InputStreamReader(is,"UTF-8");
		br = new BufferedReader(isr);
		String info = null;
		while((info=br.readLine())!=null){//循环读取客户端的信息
			System.out.println("客户端发送过来的信息" + info);
		}
		socket.shutdownInput();//关闭输入流
		socket.close();
	}
}

그런 다음 코드를 실행하면 콘솔에 다음이 인쇄됩니다.

자, 이제 Android 클라이언트가 옵니다!

---

4. 소켓 클라이언트 작성:

클라이언트는 다음 작업을 수행해야 합니다:

1단계: 소켓 개체를 만들고 연결해야 하는 서버의 주소와 포트 번호를 지정합니다

2단계 : 링크가 설정된 후 출력 스트림을 통해 서버에 요청 정보 보내기

3단계: 출력 스트림을 통해 서버 응답 정보 얻기

4단계: 관련 리소스 닫기

코드 구현 :

MainActivity .java：

public class MainActivity extends AppCompatActivity implements View.OnClickListener {

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        Button btn_accept = (Button) findViewById(R.id.btn_accept);
        btn_accept.setOnClickListener(this);
    }

    @Override
    public void onClick(View v) {
        new Thread() {
            @Override
            public void run() {
                try {
                    acceptServer();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }.start();
    }

    private void acceptServer() throws IOException {
        //1.创建客户端Socket，指定服务器地址和端口
        Socket socket = new Socket("172.16.2.54", 12345);
        //2.获取输出流，向服务器端发送信息
        OutputStream os = socket.getOutputStream();//字节输出流
        PrintWriter pw = new PrintWriter(os);//将输出流包装为打印流
        //获取客户端的IP地址
        InetAddress address = InetAddress.getLocalHost();
        String ip = address.getHostAddress();
        pw.write("客户端：~" + ip + "~ 接入服务器！！");
        pw.flush();
        socket.shutdownOutput();//关闭输出流
        socket.close();
    }
}

Android는 메인 스레드(UI 스레드)에서 네트워크 작업을 허용하지 않기 때문에 이를 직접 수행해야 합니다. 다른 스레드를 열어 소켓에 연결하세요!

실행 결과:

버튼을 클릭하면 서버 콘솔에 다음이 인쇄됩니다.

---

5. 강화 버전 사례: Xiaozhu 단순 채팅방

버튼만 클릭하면 서버가 일련의 정보를 반환합니다. 다음에는 해보죠. 매우 간단한 채팅방을 구축하려면 스레드 풀을 사용하여 소켓 링크 모음을 저장해야 합니다. 스레드를 바이트 단위로 작성하고, 코드의 세부 사항을 경험해 보세요!

구현 렌더링:

먼저 서버를 실행합니다:

그런 다음 두 개의 시뮬레이터에서 프로그램을 실행합니다.

다음으로 코드를 작성해 보겠습니다.

첫 번째는 서버 측입니다. ServerSocket을 생성한 후 루프를 통해 소켓을 읽고 쓰는 작업입니다. 새로운 클라이언트가 접근하면, 컬렉션에 소켓을 추가하고 스레드 풀에 새로운 스레드를 생성하세요.

또한 정보를 읽는 방법에서는 입력 문자열이 bye 문자열인지 판단하여 컬렉션에서 소켓을 제거합니다. 제거하고 닫으세요!

Server.java:

public class Server {
	//定义相关的参数,端口,存储Socket连接的集合,ServerSocket对象
	//以及线程池
	private static final int PORT = 12345;
	private List mList = new ArrayList();
	private ServerSocket server = null;
	private ExecutorService myExecutorService = null;
	
	
	public static void main(String[] args) {
		new Server();
	}

	public Server()
	{
		try
		{
			server = new ServerSocket(PORT);
			//创建线程池
			myExecutorService = Executors.newCachedThreadPool();
			System.out.println("服务端运行中...\n");
			Socket client = null;
			while(true)
			{
				client = server.accept();
				mList.add(client);
				myExecutorService.execute(new Service(client));
			}
			
		}catch(Exception e){e.printStackTrace();}
	}
	
	class Service implements Runnable
	{
		private Socket socket;
		private BufferedReader in = null;
		private String msg = "";
		
		public Service(Socket socket) {
			this.socket = socket;
			try
			{
				in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
				 msg = "用户:" +this.socket.getInetAddress() + "~加入了聊天室"  
	                        +"当前在线人数:" +mList.size();  
				this.sendmsg();
			}catch(IOException e){e.printStackTrace();}
		}
		
		
		
		@Override
		public void run() {
			try{
				while(true)
				{
					if((msg = in.readLine()) != null)
					{
						if(msg.equals("bye"))
						{
							System.out.println("~~~~~~~~~~~~~");
							mList.remove(socket);
                            in.close();
                            msg = "用户:" + socket.getInetAddress()  
                                    + "退出:" +"当前在线人数:"+mList.size();  
                            socket.close();  
                            this.sendmsg();  
                            break;
						}else{
							msg = socket.getInetAddress() + "   说: " + msg;  
                            this.sendmsg(); 
						}
					}
				}
			}catch(Exception e){e.printStackTrace();}
		}
		
		//为连接上服务端的每个客户端发送信息
		public void sendmsg()
		{
			System.out.println(msg);
			int num = mList.size();
			for(int index = 0;index < num;index++)
			{
				Socket mSocket = mList.get(index);  
                PrintWriter pout = null;  
                try {  
                    pout = new PrintWriter(new BufferedWriter(  
                            new OutputStreamWriter(mSocket.getOutputStream(),"UTF-8")),true);  
                    pout.println(msg);  
                }catch (IOException e) {e.printStackTrace();}  
			}
		}
		
	}
}

클라이언트 입장에서 클라이언트의 어려움은 또 다른 스레드를 생성하는 것입니다. Android에서는 직접 스레드를 허용하지 않기 때문입니다. 메인 스레드에서 네트워크 작업을 수행하고, 메인 스레드 외부의 스레드가 UI를 작동하도록 허용하지 않는 방법은 직접 새 스레드를 만드는 것입니다. 스레드를 사용하고 Hanlder를 통해 UI를 업데이트하는 것은 실제 개발에서는 직접 수행하지 않는 것이 좋습니다. ! !

레이아웃 파일:activity_main.xml:

MainActivity.java:

public class MainActivity extends AppCompatActivity implements Runnable {

    //定义相关变量,完成初始化
    private TextView txtshow;
    private EditText editsend;
    private Button btnsend;
    private static final String HOST = "172.16.2.54";
    private static final int PORT = 12345;
    private Socket socket = null;
    private BufferedReader in = null;
    private PrintWriter out = null;
    private String content = "";
    private StringBuilder sb = null;

    //定义一个handler对象,用来刷新界面
    public Handler handler = new Handler() {
        public void handleMessage(Message msg) {
            if (msg.what == 0x123) {
                sb.append(content);
                txtshow.setText(sb.toString());
            }
        }

        ;
    };


    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        sb = new StringBuilder();
        txtshow = (TextView) findViewById(R.id.txtshow);
        editsend = (EditText) findViewById(R.id.editsend);
        btnsend = (Button) findViewById(R.id.btnsend);

        //当程序一开始运行的时候就实例化Socket对象,与服务端进行连接,获取输入输出流
        //因为4.0以后不能再主线程中进行网络操作,所以需要另外开辟一个线程
        new Thread() {

            public void run() {
                try {
                    socket = new Socket(HOST, PORT);
                    in = new BufferedReader(new InputStreamReader(socket.getInputStream(), "UTF-8"));
                    out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(
                            socket.getOutputStream())), true);
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }.start();

        //为发送按钮设置点击事件
        btnsend.setOnClickListener(new View.OnClickListener() {

            @Override
            public void onClick(View v) {
                String msg = editsend.getText().toString();
                if (socket.isConnected()) {
                    if (!socket.isOutputShutdown()) {
                        out.println(msg);
                    }
                }
            }
        });
        new Thread(MainActivity.this).start();
    }

    //重写run方法,在该方法中输入流的读取
    @Override
    public void run() {
        try {
            while (true) {
                if (socket.isConnected()) {
                    if (!socket.isInputShutdown()) {
                        if ((content = in.readLine()) != null) {
                            content += "\n";
                            handler.sendEmptyMessage(0x123);
                        }
                    }
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

---

이 섹션 요약:

자, 이 섹션에서는 TCP 기반의 소켓 통신에 대해 설명하고, 소켓에 대해서는 기사에서 소개합니다. 커뮤니케이션 모델이 구현되었습니다. 간단한 소켓 통신 예제 및 향상된 버전: Piggy Chat Room, 방금 관련된 사람들에게 유용할 것이라고 믿습니다. 소켓 프로그래밍이 편리함을 선사합니다~, 감사합니다~