这篇文章给大家分享的是有关java socket如何实现聊天小程序的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。
十载的建德网站建设经验，针对设计、前端、开发、售后、文案、推广等六对一服务，响应快，48小时及时工作处理。营销型网站的优势是能够根据用户设备显示端的尺寸不同，自动调整建德建站的显示方式，使网站能够适用不同显示终端，在浏览器中调整网站的宽度，无论在任何一种浏览器上浏览网站，都能展现优雅布局与设计，从而大程度地提升浏览体验。成都创新互联公司从事“建德网站设计”,“建德网站推广”以来，每个客户项目都认真落实执行。
package demo04;
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.ScrollPaneConstants;
public class ownServer {
public static void main(String[] args) {
// TODO Auto-generated method stub
new Server().launch();
}
}
class Server{
JFrame frame;
JTextArea taArea;
JTextField tfField;
JButton sbButton;
DataInputStream read ;
DataOutputStream write;
ServerSocket scServerSocket;
Socket socket;
public void launch() {
CreateUI();
CreateNetWork();
new ServerWrite().start();
new ServerRead().start();
}
public void CreateUI() {
frame = new JFrame("MM Server");
JPanel Panle = new JPanel();
taArea = new JTextArea(15,25);
taArea.setLineWrap(true);
taArea.setWrapStyleWord(true);
taArea.setEditable(true);
JScrollPane qScroller=newJScrollPane(taArea);
qScroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
qScroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_ALWAYS);
tfField = new JTextField(20);
sbButton = new JButton("发送");
Panle.add(qScroller);
Panle.add(tfField);
Panle.add(sbButton);
frame.getContentPane().add(BorderLayout.CENTER,Panle);
frame.setSize(400,400);
frame.setVisible(true);
}
public void close()
{
try
{
write.close();
read.close();
socket.close();
scServerSocket.close();
}
catch (Exception e)
{
System.exit(-1);
}
}
public void CreateNetWork() {
try {
scServerSocket =new ServerSocket(7780);
socket= scServerSocket.accept();
read = new DataInputStream(socket.getInputStream());
write = new DataOutputStream(socket.getOutputStream());
System.out.print("网络连接");
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
class ServerRead extends Thread{
public void run() {
while (true) {
try {
String message = read.readUTF();
taArea.append("对方："+message+ "\n");
} catch (Exception e1) {
// TODO: handle exception
JOptionPane.showMessageDialog(taArea, "提示: 服务端已经断开连接");
//e.printStackTrace();
//System.exit(-1);
return ;
}
}
}
}
class ServerWrite extends Thread{
public void run() {
tfField.addActionListener(new ServerListen());
sbButton.addActionListener(new ServerListen());
}
}
class ServerListen implements ActionListener{
@Override
public void actionPerformed(ActionEvent e) {
try {
String str = tfField.getText();
tfField.setText("");
taArea.append("我: " + str + "\n");
write.writeUTF(str);
} catch (Exception e2) {
// TODO: handle exception
e2.printStackTrace();
}
}
}
}客户端
package demo04;
import java.awt.BorderLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.net.Socket;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
import javax.swing.ScrollPaneConstants;
public class ownClient {
public static void main(String[] args) {
// TODO Auto-generated method stub
new Client().launch();
}
}
class Client{
JTextArea taArea;
JTextField tfField;
JButton sbButton;
DataInputStream read = null;
DataOutputStream write = null;
Socket socket;
public void launch() {
CreateUI();
CreatNetWork();
new ClientRead().start();;
new ClientWrite().start();;
}
public void CreateUI() {
JFrame frame = new JFrame("MM Client");
JPanel Panle = new JPanel();
taArea = new JTextArea(15,25);
taArea.setLineWrap(true);
taArea.setWrapStyleWord(true);
taArea.setEditable(true);
JScrollPane qScroller = new JScrollPane(taArea);
qScroller.setVerticalScrollBarPolicy(ScrollPaneConstants.VERTICAL_SCROLLBAR_ALWAYS);
qScroller.setHorizontalScrollBarPolicy(ScrollPaneConstants.HORIZONTAL_SCROLLBAR_ALWAYS);
tfField = new JTextField(20);
sbButton = new JButton("发送");
Panle.add(qScroller);
Panle.add(tfField);
Panle.add(sbButton);
frame.getContentPane().add(BorderLayout.CENTER,Panle);
frame.setSize(400,400);
frame.setVisible(true);
}
public void CreatNetWork() {
// TODO Auto-generated method stub
try {
socket = new Socket("127.0.0.1",7780);
write = new DataOutputStream(socket.getOutputStream());
read = new DataInputStream(socket.getInputStream());
System.out.print("已建立网络连接");
} catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
}
}
class ClientRead extends Thread{
public void run() {
while (true) {
try {
String message= read.readUTF();
taArea.append("对方："+message+ "\n");
} catch (Exception e1) {
// TODO: handle exception
JOptionPane.showMessageDialog(taArea, "提示: 客户端已经断开连接");
//e.printStackTrace();
//System.exit(-1);
return ;
}
}
}
}
class ClientWrite extends Thread{
public void run() {
tfField.addActionListener(new ClientListen());
sbButton.addActionListener(new ClientListen());
}
}
class ClientListen implements ActionListener{
@Override
public void actionPerformed(ActionEvent e) {
try {
String str = tfField.getText();
tfField.setText("");
taArea.append("我: " + str + "\n");
write.writeUTF(str);
} catch (Exception e2) {
// TODO: handle exception
e2.printStackTrace();
}
}
}
}感谢各位的阅读！关于“java socket如何实现聊天小程序”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！
