`
- 浏览:
181969 次
- 性别:
- 来自:
深圳
-
[/size]java socket 实现及时通讯
对于Java Socket编程而言,有两个概念,一个是ServerSocket,一个是Socket。服务端和客户端之间通过Socket建立连接,之后它们就可以进行通信了。首先ServerSocket将在服务端监听某个端口,当发现客户端有Socket来试图连接它时,它会accept该Socket的连接请求,同时在服务端建立一个对应的Socket与之进行通信。这样就有两个Socket了,客户端和服务端各一个。
对于Socket之间的通信其实很简单,服务端往Socket的输出流里面写东西,客户端就可以通过Socket的输入流读取对应的内容。Socket与Socket之间是双向连通的,所以客户端也可以往对应的Socket输出流里面写东西,然后服务端对应的Socket的输入流就可以读出对应的内容。
下面是及时通讯实现的程序
1.新建socket server服务器端
/**//*
*服务端
*/
package edu.jlu.fuliang;
import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
public class Server extends JFrame implements Runnable {
private ServerSocket server;
private Socket connection;
private OutputStream output;
private InputStream input;
private Thread outThread;
private JTextArea display;
private JTextField text1;
private JButton startButton;
public static void main(String args[]) {
Server s = new Server();
s.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
}
public Server() {
super("Server");
startButton = new JButton("Start the server");
text1 = new JTextField(20);
display = new JTextArea(7, 30);
display.setEditable(false);
Container container = getContentPane();
container.setLayout(new BorderLayout());
container.add(startButton,BorderLayout.NORTH);
container.add(new JScrollPane(display),BorderLayout.CENTER);
container.add(text1,BorderLayout.SOUTH);
/**//*
* 给开始按钮添加监听器。
*/
startButton.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e) {
display.setText("启动服务器 ");
startButton.setEnabled(false);
try {
//端口设为5000,最大连接请求为100个
server = new ServerSocket(5000, 100);
connection = server.accept();
output = connection.getOutputStream();
input = connection.getInputStream();
output.write("连接成功! ".getBytes());
outThread = new Thread(Server.this);
outThread.start();
} catch (IOException ee) {
}
}
});
/**//*
/*给文本域添加键盘监听器,按回车发送信息。
*/
text1.addKeyListener(new KeyAdapter(){
public void keyPressed(KeyEvent ke) {
if(ke.getKeyCode() == KeyEvent.VK_ENTER){
byte writeBytes[] = new byte[50];
String s = "Server:" + text1.getText();
text1.setText("");
writeBytes = s.getBytes();
display.append(s+"\n");
try {
output.write(writeBytes);
} catch (IOException ee) {
}
if (s.trim().equals("Server: exit")) {
outThread.stop();
quit();
}
}
}
});
setSize(300, 400);
setResizable(false);
setVisible(true);
}
public void run() {
while (true) {
byte readBytes[] = new byte[50];
try {
input.read(readBytes);//读去对方发送的消息
} catch (IOException e) {
}
String s = new String(readBytes);
display.append(s+"\n");
if (s.trim().equals("Client: exit"))
break;
}
quit();
}
public void quit() {
try {
output.close();
input.close();
connection.close();
} catch (IOException e) {
}
startButton.setEnabled(true);
}
}
2.建立socket客户端
package edu.jlu.fuliang;
import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.KeyAdapter;
import java.awt.event.KeyEvent;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.RandomAccessFile;
import java.net.Socket;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JMenu;
import javax.swing.JMenuBar;
import javax.swing.JMenuItem;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
public class Client extends JFrame implements Runnable {
private Socket client;
private OutputStream output;
private InputStream input;
private Thread outThread;
private JTextArea display;
private JTextField text1;
private JButton startButton;
private JMenu loginMenu = new JMenu("登录");
private JMenuItem register = new JMenuItem("注册");
private JMenuItem login = new JMenuItem("登录");
private JMenuBar bar = new JMenuBar();
private Register registerDlg ;
private Login loginDlg;
private RandomAccessFile file;
public static void main(String args[]) {
Client c = new Client();
c.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
}
public Client() {
super("Client");
startButton = new JButton("Connect to server");
text1 = new JTextField(20);
display = new JTextArea(7, 30);
display.setEditable(false);
loginMenu.add(register);
loginMenu.add(login);
bar.add(loginMenu);
setJMenuBar(bar);
Container container = getContentPane();
container.setLayout(new BorderLayout());
container.add(startButton,BorderLayout.NORTH);
container.add(new JScrollPane(display),BorderLayout.CENTER);
container.add(text1,BorderLayout.SOUTH);
try {
file = new RandomAccessFile(new File("E://login.txt"),"rw");
} catch (IOException e1) {
e1.printStackTrace();
}
registerDlg = new Register(this,file);
loginDlg = new Login(this,file);
startButton.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e) {
display.setText("连接服务器");
startButton.setEnabled(false);
try {
client = new Socket("127.0.0.1", 5000);
output = client.getOutputStream();
input = client.getInputStream();
outThread = new Thread(Client.this);
outThread.start();
} catch (IOException ee) {
}
}
});
text1.addKeyListener(new KeyAdapter(){
public void keyPressed(KeyEvent ke) {
if(ke.getKeyCode() == KeyEvent.VK_ENTER){
byte writeBytes[] = new byte[50];
String s = loginDlg.getLoginName()+": " + text1.getText();
text1.setText("");
writeBytes = s.getBytes();
display.append(s+"\n");
try {
output.write(writeBytes);
} catch (IOException ee) {
}
if (s.trim().equals(loginDlg.getLoginName()+": exit")) {
outThread.stop();
quit();
}
}
}
});
register.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e) {
registerDlg.setVisible(true);
}
});
login.addActionListener(new ActionListener(){
public void actionPerformed(ActionEvent e) {
loginDlg.setVisible(true);
}
});
setSize(300, 400);
setResizable(false);
setVisible(true);
}
public void run() {
while (true) {
byte readBytes[] = new byte[1024];
try {
input.read(readBytes);
} catch (IOException e) {
}
String s = new String(readBytes);
display.append(s+"\n");
if (s.trim().equals("Server: exit"))
break;
}
quit();
}
public void quit() {
try {
output.close();
input.close();
client.close();
} catch (IOException e) {
}
startButton.setEnabled(true);
}
}
3.注册弹窗口
package edu.jlu.fuliang;
import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.RandomAccessFile;
import javax.swing.JButton;
import javax.swing.JDialog;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JTextField;
public class Register extends JDialog{
private String nickName;
private JTextField textField;
private JButton registerButton;
private RandomAccessFile file;////保存注册信息的文件
public Register(JFrame f,RandomAccessFile file){
super(f,"注册",false);
this.file = file;
JPanel panel = new JPanel();
panel.add(new JLabel("昵称:"));
textField = new JTextField(10);
panel.add(textField);
Container container = getContentPane();
container.setLayout(new BorderLayout());
container.add(panel,BorderLayout.NORTH);
registerButton = new JButton("注册");
container.add(registerButton,BorderLayout.SOUTH);
setVisible(false);
setBounds(100,200,200,200);
registerButton.addActionListener(new RegisterListener());
}
/**//*
* 注册监听器,当单击登注册按钮时,触发该事件
* 并向文件中写入注册信息。
*/
private class RegisterListener implements ActionListener{
public void actionPerformed(ActionEvent e) {
try {
file.seek(file.length());
String str = textField.getText();
textField.setText("");
file.writeUTF(str);
Register.this.setVisible(false);
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}
4.登陆弹出窗口
package edu.jlu.fuliang;
import java.awt.BorderLayout;
import java.awt.Container;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.RandomAccessFile;
import javax.swing.JButton;
import javax.swing.JDialog;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JTextField;
public class Login extends JDialog{
private JTextField textField;
private JButton loginButton;
private RandomAccessFile file;//保存注册信息的文件
private String loginName = "guest";//保存登录者的名字,为登陆为guest;
public Login(JFrame f,RandomAccessFile file){
super(f,"登陆",false);
this.file = file;
JPanel panel = new JPanel();
panel.add(new JLabel("昵称:"));
textField = new JTextField(10);
panel.add(textField);
Container container = getContentPane();
container.setLayout(new BorderLayout());
container.add(panel,BorderLayout.NORTH);
loginButton = new JButton("登陆");
container.add(loginButton,BorderLayout.SOUTH);
setVisible(false);
setBounds(100,200,200,200);
loginButton.addActionListener(new LoginListener());
}
public String getLoginName(){
return loginName;
}
/**//*
* 登录监听器,当单击登陆按钮时,触发该事件
* 从文件中读取并查找是否注册过,如果没有找
* 到则弹出未注册警告。否则弹出欢迎对话框表
* 示欢迎
*/
private class LoginListener implements ActionListener{
public void actionPerformed(ActionEvent e) {
boolean flag = false;
try {
String name = textField.getText().trim();
textField.setText("");
file.seek(0);
while(file.getFilePointer() < file.length()){
String nik = file.readUTF();
if(nik.equals(name)){
flag = true;
loginName = name;
break;
}
}
if(!flag){
String warning="没有找到你的账号请先注册!";
JOptionPane.showMessageDialog(Login.this,warning,"警告",JOptionPane.WARNING_MESSAGE);
}else{
String welcome="欢迎来聊天!";
JOptionPane.showMessageDialog(Login.this,welcome,"欢迎",JOptionPane.WARNING_MESSAGE);
}
Login.this.setVisible(false);
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
}
- 大小: 183.8 KB
分享到:
Global site tag (gtag.js) - Google Analytics
相关推荐
当前主流的聊天程序有QQ和微信,这些及时聊天程序让我们非常方便地随时联系,缩短了人们之间的距离,同时也提高了人们的工作效率。但这两类聊天程序都需要连接外网,有时公司也希望能够在内网实现及时沟通,这就要求...
本文程序的主要功能包括发送消息、互动、私聊等提供及时聊天。在VC6.0的环境下,创建了多用户间信息交换,群聊私聊互动功能。需要注意的是程序只实现了聊天程序的主体功能,在此基础上加以改进,可以美化对话框,...
一款基于Socket通信的及时通讯聊天系统,功能包含:发帖(评论、喝彩、倒喝彩、分享)、聊天。服务器端数据库采用Sqlite(默认数据库存放在E盘根目录下.rar,太多无法一一验证是否可用,程序如果跑不起来需要自调,...
基于linux的socket多人聊天室程序,采用posix多线程控制技术。客户端和服务器采用协议机制通信,服务器端在用户上线和下线时及时更新在线人数,并打印上下线信息(用户名)。客户端登陆需要输入用户名,若用户名已...
基于Javaswing和socket实现的仿QQ在线聊天程序源码(含服务端+客户端).zip基于Javaswing和socket实现的仿QQ在线聊天程序源码(含服务端+客户端).zip基于Javaswing和socket实现的仿QQ在线聊天程序源码(含服务端+客户端)...
MFC+Socket开发的通讯程序,能够及时通讯与反馈,对大家在这方面研发有很大的帮助!
基于TCP/IP的Socket通信程序,实现了类似于QQ的信息发送、群聊私聊等功能
当前主流的聊天程序有QQ和微信,这些及时聊天程序让我们非常方便地随时联系,缩短了人们之间的距离,同时也提高了人们的工作效率。但这两类聊天程序都需要连接外网,有时公司也希望能够在内网实现及时沟通,这就要求...
课程设计基于PyQt5+Python开发的远程医疗云监控系统源码+运行说明(多线程+Socket通信).tar课程设计基于PyQt5+Python开发的远程医疗云监控系统源码+运行说明(多线程+Socket通信).tar课程设计基于PyQt5+Python开发的...
一种基于Java企业内部及时通讯软件设计 摘要:基于Socket的局域网通讯软件能为企业局域网提供一种安全、快速的通信机制, 使用Java Swing 技术设计系统界面,以Derby作为数据库服务器,用Socket编程技术实现网络通讯...
node-socket-imNode+Express+Socket.IO+ioredis 服务端多实例消息共享及时通信项目应用:实时数据接收IM消息群聊客户端浏览器信息采集、用户在线情况、浏览记录跟踪程序打点远程调试,类似开源项目socketlog后台项目...
纯Java语言开发,采用Swing,实现客户端的JFrame界面。...程序涉及Socket,多线程,文件访问等技术。本系统实现了用户注册,登录,编辑个性签名,修改头像,修改昵称,添加好友,删除好友,聊天,聊天记录等功能。
Linux服务端与客户端通信源代码,socket套接字开发入门,网络开发入门程序,下载后有问题可及时联系,确保你的下载的代码能运行,博客中有相关注释和原理解析。
接收用户的聊天信息是由多线程技术实现的,因为客户端必须时时关注更新服务器上是否有最新消息,在本程序中设定的是3秒刷新服务器一次,如果间隔时间太短将会增加客户端与服务器端的通信负担,而间隔时间长就会让人...
通信程序设计是本系统的关键部分,需要充分了解用户需求,确定系统结构,选择合适的软件开发平台和工具,并采用自顶向下、逐步求精的设计方法划分软件的功能模块和功能单元,以提高软件开发的效率。通信程序需要实现...
Socket是网络上运行的两个程序间双向通讯的一端,它既可以接受请求,也可以发送请求,利用它可以较为方便的编写网络上数据的传递。在Java中,有专门的Socket类来处理用户的请求和响应。利用Socket类的方法,就可以...
getWanWork作socket服务(socket 数据交互方式是二进制数据格式)。 redis缓存,特定模块用sqllite缓存模块数据。 mysql、mongodb 数据库。 JWT进行用户验证。 使用 http 进行发送文件 双端: 带有双端app源码...
关于服务器端向Android客户端的推送,主要有三种方式:轮询,应用程序应当阶段性的与服务器进行连接并查询是否有新的消息到达,你必须自己实现与服务器之间的通信,例如消息排队等。而且你还要考虑轮询的频率,如果...
扫描器是一种自动检测远程或本地主机安全性弱点的程序,通过使用扫描器你可以不留痕迹的发现远程服务器的各种TCP端口的分配。这就能让我们间接的或直观的了解到远程主机所存在的安全问题。为了保证网络中计算机的...
用于服务端查看好友在线状态同时作为服务器,还要能够监控用户的聊天记录,用于监控用户不能发送一些不利言论,从而将其用户及时作封号处理。阻止其传播一些不健康的言论。 §2.2.2客户端要求: 用户在登录界面输入...