java实现简单socket通信_javasocket代码资源-CSDN文库

共8个文件

class：2个

java：2个

classpath：1个

5星 · 超过95%的资源需积分: 50 94 浏览量 2018-06-01 23:33:40 上传评论 7 收藏 10KB ZIP 举报

Java实现的简单Socket通信是网络编程中的基础技术，主要用于设备间的双向数据传输。在这个场景中，我们有两个窗口，一个作为服务器端，另一个作为客户端，它们通过TCP协议进行通信。TCP是一种面向连接的、可靠的传输协议，它确保了数据的顺序传输和错误检查。在Java中，Socket类和ServerSocket类是进行TCP通信的核心。ServerSocket类用于创建服务器端的套接字，监听特定端口上的连接请求。以下是一个简单的ServerSocket实例化过程： ```java ServerSocket serverSocket = new ServerSocket(8888); // 创建服务器端Socket，8888为监听端口号 ``` 当客户端尝试连接时，服务器端通过调用`accept()`方法接收连接请求，并返回一个新的Socket对象，用于与客户端进行数据交换： ```java Socket clientSocket = serverSocket.accept(); // 接受客户端连接 ``` 客户端则使用Socket类来建立到服务器的连接，并指定服务器的IP地址和端口号： ```java Socket socket = new Socket("localhost", 8888); // 连接到本地主机的8888端口 ``` 在连接建立后，双方可以通过Socket的输入流和输出流进行数据交换。InputStream和OutputStream是Java的标准I/O类，它们可以被Socket的getInputStream()和getOutputStream()方法获取： ```java OutputStream outToServer = socket.getOutputStream(); // 获取到服务器的输出流 InputStream inFromServer = socket.getInputStream(); // 获取来自服务器的输入流 // 写入数据到服务器 outToServer.write("Hello, Server!".getBytes()); // 读取服务器返回的数据 byte[] buffer = new byte[1024]; int bytesRead = inFromServer.read(buffer); String received = new String(buffer, 0, bytesRead); ``` 在实际应用中，为了实现两个窗口间持续的聊天功能，通常会使用多线程。每个Socket连接都会在一个独立的线程中处理，以便同时处理多个客户端的请求。服务器端创建新线程来处理每个客户端的连接，客户端也可以在一个单独的线程中读写数据，避免阻塞主线程。标签中的“p2p”（peer-to-peer）是指对等网络通信，虽然这个示例没有明确提及P2P，但可以将其扩展为多个客户端之间直接通信的模型。在这种情况下，每个节点既是服务器又是客户端，可以接收其他节点的连接并发送数据。在提供的文件列表中，“CHAT”可能是包含实现这个简单聊天应用的源代码或日志的文件。查看这些文件可以帮助理解具体的实现细节，包括如何设置数据传输的格式、异常处理以及如何结束连接等。总结来说，Java的Socket通信允许两个应用程序通过TCP协议交换数据，这在许多网络应用中都起着关键作用。通过创建ServerSocket监听连接，Socket建立连接，以及利用I/O流进行数据传输，我们可以实现窗口间的通信。对于更复杂的P2P系统，还需要考虑网络拓扑和对等节点之间的交互。

资源推荐

资源详情

资源评论

收起资源包目录

CHAT.zip （8个子文件）

CHAT

chat.properties 52B

src

yan

chat

SeverChatMain.java 3KB

ClintChatMain.java 3KB

bin

yan

chat

ClintChatMain.class 4KB

SeverChatMain.class 4KB

.classpath 301B

.settings

org.eclipse.jdt.core.prefs 598B

.project 380B

package cn.yan.chat; import java.awt.BorderLayout; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.KeyEvent; import java.awt.event.KeyListener; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.FileReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.ServerSocket; import java.net.Socket; import java.util.Properties; import javax.swing.JButton; import javax.swing.JFrame; import javax.swing.JPanel; import javax.swing.JScrollPane; import javax.swing.JTextArea; import javax.swing.JTextField; public class SeverChatMain extends JFrame implements ActionListener,KeyListener { public static void main(String[] args) { new SeverChatMain(); } private JTextArea jta; private JScrollPane jsp; private JPanel jp; private JTextField jtf; private JButton jb; private BufferedWriter bw = null; private static int serverPort; static { Properties pro=new Properties(); try { pro.load(new FileReader("chat.properties")); serverPort=Integer.parseInt(pro.getProperty("serverPort")); } catch (IOException e) { e.printStackTrace(); } } public SeverChatMain() { jta = new JTextArea(); jta.setEditable(false); jsp = new JScrollPane(jta); jp = new JPanel(); jtf = new JTextField(10); jb = new JButton("发送"); jp.add(jtf); jp.add(jb); this.add(jsp, BorderLayout.CENTER); this.add(jp, BorderLayout.SOUTH); this.setTitle("QQ聊天服务端"); this.setSize(300, 300); this.setLocation(600, 600); this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); this.setVisible(true); jb.addActionListener(this); jtf.addKeyListener(this); try { ServerSocket serverSocket = new ServerSocket(serverPort); Socket socket = serverSocket.accept(); // 读取socket输入流 BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream())); // 将内容写入socket bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); String line = null; while ((line = br.readLine()) != null) { jta.append(line+System.lineSeparator()); } serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } } @Override public void actionPerformed(ActionEvent e) { sendDataToSocket(); } private void sendDataToSocket() { String text = jtf.getText(); text = "服务端对客户端说：" + text; jta.append(text + System.lineSeparator()); try { bw.write(text); bw.newLine(); bw.flush(); jtf.setText(""); } catch (IOException e1) { e1.printStackTrace(); } } @Override public void keyReleased(KeyEvent e) { if (e.getKeyCode() == KeyEvent.VK_ENTER) { sendDataToSocket(); } } @Override public void keyPressed(KeyEvent e) { } @Override public void keyTyped(KeyEvent e) { } }

评论收藏

内容反馈