Java의 단방향 통신을 위한 예제 코드에 대한 자세한 설명

이 글은 주로 Java 네트워크 프로그래밍에서 소켓을 통한 단방향 통신 방법과 관련 예제를 소개합니다. 간단하지만 도움이 필요한 친구들이 참고할 수 있는 입문 프로그램입니다.

         네트워크 프로그래밍에서 클라이언트가 서버에 메시지를 보내기만 하면 되고 서버는 클라이언트에 메시지를 보낼 필요가 없는 경우 이를 단일 회선 통신이라고 합니다. 클라이언트 소켓과 서버 소켓이 성공적으로 연결되면 출력 스트림을 통해 데이터가 전송되고, 서버가 입력 스트림을 통해 데이터를 수신하는 것으로 추정할 수 있습니다. 다음은 간단한 단방향 통신의 예입니다.

                                                                                 . 코드는 다음과 같습니다.

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class MyTcp {
	private BufferedReader reader;
	private ServerSocket server;
	private Socket socket;
	void getserver() {
		try {
			server = new ServerSocket(8998);
			System.out.println("服务器套接字已经创建成功");
			while(true) {
				System.out.println("等待客户机的连接");
				socket = server.accept();
				reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
				getClienMessage();
			}
		}catch(Exception e) {
			e.printStackTrace();
		}
		
	}
	private void getClienMessage() {
		try {
			while (true) {
				System.out.println("客户机："+ reader.readLine());
			}
		}catch(Exception e) {
			e.printStackTrace();
		}
		try {
			if(reader !=null) {
				reader.close();
			}
			if(socket !=null) {
				socket.close();
			}
		}catch(IOException e) {
			e.printStackTrace();
		}
	}
	public static void main(String[] args) {
		MyTcp tcp = new MyTcp();
		tcp.getserver();
	}
}

실행 결과:

서버 소켓이 성공적으로 생성되었습니다.

클라이언트 연결을 기다리는 중

이제 클라이언트 프로그램을 살펴보겠습니다.

 예 2:

사용자가 텍스트 상자에 입력한 정보를 서버로 보내고, 텍스트 상자에 입력한 정보를 클라이언트의 텍스트 필드에 표시하는 클라이언트 프로그램입니다. 코드는 다음과 같습니다:

import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.PrintWriter;
import java.net.Socket;

import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.border.BevelBorder;

public class MyClien extends JFrame{
	private PrintWriter writer;
	Socket socket;
	private JTextArea ta = new JTextArea();
	private JTextField tf = new JTextField();
	Container cc;
	public MyClien(String title) {
		super(title);
		setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
		cc = this.getContentPane();
		final JScrollPane scrollPane = new JScrollPane();
		scrollPane.setBorder(new BevelBorder(BevelBorder.RAISED));
		getContentPane().add(scrollPane, BorderLayout.CENTER);
		scrollPane.setViewportView(ta);
		cc.add(tf,"South");
		tf.addActionListener(new ActionListener() {
			public void actionPerformed(ActionEvent e) {
				writer.println(tf.getText());
				ta.append(tf.getText()+ '\n');
				ta.setSelectionEnd(ta.getText().length());
				tf.setText("");
			}
		});
	}
		private void connect() {
			ta.append("尝试连接\n");
			try {
				socket = new Socket("127.0.0.1",8998);
				writer = new PrintWriter(socket.getOutputStream(),true);
				ta.append("完成连接\n");
			}catch(Exception e) {
				e.printStackTrace();
			}
		}
		public static void main(String[] args) {
			MyClien clien = new MyClien("向服务器传送数据");
			clien.setSize(200,200);
			clien.setVisible(true);
			clien.connect();
		}
	}

서버 측 작업 결과:

서버 소켓이 성공적으로 생성되었습니다

클라이언트 연결을 기다리는 중

클라이언트: 혁명은 아직 성공하지 못했습니다. 동지들은 여전히 ​​열심히 노력해야 합니다. !

클라이언트 실행 결과:

연결 시도

연결 완료

혁명은 아직 성공하지 못했습니다. 동지들은 여전히 ​​열심히 노력해야 합니다!

참고: 여러 네트워크 응용 프로그램이 컴퓨터에 설치된 경우 지정된 포트 번호가 사용되었을 가능성이 높습니다. 이전에 잘 실행되던 네트워크 프로그램이 갑자기 실행되지 않는 상황이 발생할 수도 있습니다. 이 상황은 다른 프로그램이 포트를 점유하고 있기 때문일 수도 있습니다. 이때, 프로그램이 사용하는 포트를 보려면 netstat -an 명령을 사용하십시오.

​​​​

여기서 또 다른 매우 중요한 점이 있습니다. 이 기사에서는 두 가지 소스 코드를 언급하는데, 하나는 서버 측 프로그램이고 다른 하나는 클라이언트 측 프로그램입니다. 실행 시에는 서버 프로그램을 먼저 실행한 후 클라이언트 프로그램을 실행하고 두 코드의 포트 번호가 동일해야 합니다.

위 내용은 Java의 단방향 통신을 위한 예제 코드에 대한 자세한 설명의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!