包含即使通java的词条

admin 2023-01-21 19:39:09 324

今天给各位分享即使通java的知识，其中也会对进行解释，如果能碰巧解决你现在面临的问题，别忘了关注本站，现在开始吧！

本文目录一览：

1、怎样用java web和websocket实现网页即时通讯
2、如何用java语言对即时通讯软件进行加密
3、我在用java做一个简单的即时通讯工具，自学的所以很多都不会，希望可以帮帮我

怎样用java web和websocket实现网页即时通讯

原理

WebSocket protocol 。

现很多网站为了实现即时通讯，所用的技术都是轮询(polling)。轮询是在特定的的时间间隔（如每1秒），由浏览器对服务器发出HTTP request，然后由服务器返回最新的数据给客户端的浏览器。这种传统的HTTP request 的模式带来很明显的缺点 – 浏览器需要不断的向服务器发出请求，然而HTTP request 的header是非常长的，里面包含的有用数据可能只是一个很小的值，这样会占用很多的带宽。

而比较新的技术去做轮询的效果是Comet – 用了AJAX。但这种技术虽然可达到全双工通信，但依然需要发出请求。

在 WebSocket API，浏览器和服务器只需要做一个握手的动作，然后，浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。在此WebSocket 协议中，为我们实现即时服务带来了两大好处：

1. Header

互相沟通的Header是很小的-大概只有 2 Bytes

2. Server Push

服务器的推送，服务器不再被动的接收到浏览器的request之后才返回数据，而是在有新数据时就主动推送给浏览器。

一、项目简介

WebSocket是HTML5一种新的协议，它实现了浏览器与服务器全双工通信，这里就将使用WebSocket来开发网页聊天室，前端框架会使用AmazeUI，后台使用Java，编辑器使用UMEditor。

二、涉及知识点

网页前端（HTML+CSS+JS）和Java

三、软件环境 Tomcat 7 JDK 7 Eclipse JavaEE 现代浏览器

四、效果截图

效果1

效果2

五、项目实战

1. 新建项目

打开Eclipse JavaEE，新建一个名为Chat的Dynamic Web Project，然后导入处理JSON格式字符串所需要的包，把commons-beanutils-1.8.0.jar、commons-collections-3.2.1.jar、commons-lang-2.5.jar、commons-logging-1.1.1.jar、ezmorph-1.0.6.jar和json-lib-2.4-jdk15.jar这几个包放在WebContent/WEB-INF/lib目录下，最后把项目发布到Tomcat服务器上，到此空项目就搭建完成了。

2. 编写前端页面

在WebContent目录下新建一个名为index.jsp的页面，这里使用了AmazeUI框架，它是一个跨屏自适应的前端框架，消息输入框使用了UMEditor，它是一个富文本在线编辑器，能让我们的消息内容多姿多彩。

首先从 AmazeUI官网下载压缩包，然后解压把assets文件夹拷贝到WebContent目录下，这样我们就能使用AmazeUI了。

再从 UEditer官网下载Mini版的JSP版本压缩包，解压后把整个目录拷贝到WebContent目录下，接下来就可以编写前端代码了，代码如下（你可以按照自己的喜好编写）：

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293 %@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%!DOCTYPE htmlhtml lang="zh"headmeta charset="utf-8"meta http-equiv="X-UA-Compatible" content="IE=edge"meta name="viewport" content="width=device-width, initial-scale=1, maximum-scale=1, user-scalable=no"titleShiYanLou Chat/title!-- Set render engine for 360 browser --meta name="renderer" content="webkit"!-- No Baidu Siteapp--meta http-equiv="Cache-Control" content="no-siteapp" /link rel="alternate icon" href="assets/i/favicon.ico"link rel="stylesheet" href="assets/css/amazeui.min.css"link rel="stylesheet" href="assets/css/app.css"!-- umeditor css --link href="umeditor/themes/default/css/umeditor.css" rel="stylesheet"style.title { text-align: center;}.chat-content-container { height: 29rem; overflow-y: scroll; border: 1px solid silver;}/style/headbody !-- title start -- div class="title" div class="am-g am-g-fixed" div class="am-u-sm-12" h1 class="am-text-primary"ShiYanLou Chat/h1 /div /div /div !-- title end -- !-- chat content start -- div class="chat-content" div class="am-g am-g-fixed chat-content-container" div class="am-u-sm-12" ul id="message-list" class="am-comments-list am-comments-list-flip"/ul /div /div /div !-- chat content start -- !-- message input start -- div class="message-input am-margin-top" div class="am-g am-g-fixed" div class="am-u-sm-12" form class="am-form" div class="am-form-group" script type="text/plain" id="myEditor" style="width: 100%;height: 8rem;"/script /div /form /div /div div class="am-g am-g-fixed am-margin-top" div class="am-u-sm-6" div id="message-input-nickname" class="am-input-group am-input-group-primary" span class="am-input-group-label"i class="am-icon-user"/i/span input id="nickname" type="text" class="am-form-field" placeholder="Please enter nickname"/ /div /div div class="am-u-sm-6" button id="send" type="button" class="am-btn am-btn-primary" i class="am-icon-send"/i Send /button /div /div /div !-- message input end -- !--[if (gte IE 9)|!(IE)]!-- script src="assets/js/jquery.min.js"/script !--![endif]-- !--[if lte IE 8 ] script src=""/script ![endif]-- !-- umeditor js -- script charset="utf-8" src="umeditor/umeditor.config.js"/script script charset="utf-8" src="umeditor/umeditor.min.js"/script script src="umeditor/lang/zh-cn/zh-cn.js"/script script $(function() { // 初始化消息输入框 var um = UM.getEditor('myEditor'); // 使昵称框获取焦点 $('#nickname')[0].focus(); }); /script/body/html

编写完成之后启动Tomcat服务器，然后访问，会看到如下界面。

3. 编写后台代码

新建一个com.shiyanlou.chat的包，在包中创建一个名为ChatServer的类，从JavaEE 7开始就统一了WebSocket的API，因此无论是什么服务器，用Java写的代码都是一样的，代码如下：

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950 package com.shiyanlou.chat;import java.text.SimpleDateFormat;import java.util.Date;import javax.websocket.OnClose;import javax.websocket.OnError;import javax.websocket.OnMessage;import javax.websocket.OnOpen;import javax.websocket.Session;import javax.websocket.server.ServerEndpoint;import net.sf.json.JSONObject;/** * 聊天服务器类 * @author shiyanlou * */@ServerEndpoint("/websocket")public class ChatServer { private static final SimpleDateFormat DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm"); // 日期格式化 @OnOpen public void open(Session session) { // 添加初始化操作 } /** * 接受客户端的消息，并把消息发送给所有连接的会话 * @param message 客户端发来的消息 * @param session 客户端的会话 */ @OnMessage public void getMessage(String message, Session session) { // 把客户端的消息解析为JSON对象 JSONObject jsonObject = JSONObject.fromObject(message); // 在消息中添加发送日期 jsonObject.put("date", DATE_FORMAT.format(new Date())); // 把消息发送给所有连接的会话 for (Session openSession : session.getOpenSessions()) { // 添加本条消息是否为当前会话本身发的标志 jsonObject.put("isSelf", openSession.equals(session)); // 发送JSON格式的消息 openSession.getAsyncRemote().sendText(jsonObject.toString()); } } @OnClose public void close() { // 添加关闭会话时的操作 } @OnError public void error(Throwable t) { // 添加处理错误的操作 }}

4. 前后台交互

后台写完了，前台要用WebSocket连接后台，需要新建一个WebSocket对象，然后就可以和服务器端进行交互，从浏览器发送消息给服务器端，同时要验证输入框的内容是否为空，然后接受服务端发送的消息，把它们动态地添加到聊天内容框中，在

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354 var um = UM.getEditor('myEditor');$('#nickname')[0].focus();// 新建WebSocket对象，最后的/websocket对应服务器端的@ServerEndpoint("/websocket")var socket = new WebSocket('ws://${pageContext.request.getServerName()}:${pageContext.request.getServerPort()}${pageContext.request.contextPath}/websocket'); // 处理服务器端发送的数据 socket.onmessage = function(event) { addMessage(event.data); }; // 点击Send按钮时的操作 $('#send').on('click', function() { var nickname = $('#nickname').val(); if (!um.hasContents()) { // 判断消息输入框是否为空 // 消息输入框获取焦点 um.focus(); // 添加抖动效果 $('.edui-container').addClass('am-animation-shake'); setTimeout("$('.edui-container').removeClass('am-animation-shake')", 1000); } else if (nickname == '') { // 判断昵称框是否为空 //昵称框获取焦点 $('#nickname')[0].focus(); // 添加抖动效果 $('#message-input-nickname').addClass('am-animation-shake'); setTimeout("$('#message-input-nickname').removeClass('am-animation-shake')", 1000); } else { // 发送消息 socket.send(JSON.stringify({ content : um.getContent(), nickname : nickname })); // 清空消息输入框 um.setContent(''); // 消息输入框获取焦点 um.focus(); } }); // 把消息添加到聊天内容中 function addMessage(message) { message = JSON.parse(message); var messageItem = 'li class="am-comment ' + (message.isSelf ? 'am-comment-flip' : 'am-comment') + '"' + 'a href="javascript:void(0)" img src="assets/images/' + (message.isSelf ? 'self.png' : 'others.jpg') + '" alt="" width="48" height="48"//a' + 'divheaderdiv' + 'a href="javascript:void(0)"' + message.nickname + '/a time' + message.date + '/time/div/header' + 'div' + message.content + '/div/div/li'; $(messageItem).appendTo('#message-list'); // 把滚动条滚动到底部 $(".chat-content-container").scrollTop($(".chat-content-container")[0].scrollHeight); }

到这步，简单的网页聊天室就完成了，你可以多开几个窗口或在局域网中邀请小伙伴们来一起测试。

六、小结

本次项目课使用WebSocket实现了简单的网页聊天室，其实WebSocket不仅可以应用于浏览器，也可以应用于桌面客户端。

如何用java语言对即时通讯软件进行加密

一、Java软件加密基本思路

对于应用软件的保护笔者从两个方面进行考虑，第一是阻止盗版使用软件，第二是阻止竞争对手对软件反编译，即阻止对软件的逆向工程。

1、阻止盗版

在软件运行时对自身存在的合法性进行判断，如果认为自身的存在和运行是被授权的、合法的，就运行；否则终止运行。这样即使软件可以被随意复制，只要盗版用户没有相应的授权信息就无法使用软件。

2、阻止反编译

对编译产生的Class文件加密处理，并在运行时进行解密，解密者无法对软件进行反编译。

二、Java软件加密的总体流程

为了保护用Java语言开发的软件，我们设计并实现了一个实用、高强度的加密算法。以下称需要保护的Java软件为“受保护程序”，称对“受保护程序”进行加密保护的软件为“加密程序”。对软件加密保护的流程如图1所示。

三、加密算法分析设计

1、用户信息提取器设计

为了防止用户发布序列号而导致“一次发行，到处都是”的盗版问题，提取用户机器中硬件相关的、具有唯一性的信息——用户计算机的硬盘分区C的序列号，并要求用户将此信息与用户名一起返回，之后用“序列号生成器”根据用户返回信息生成一个唯一合法的软件注册序列号发回用户，用户即可使用此号码注册使用软件。

这个信息提取器使用Winclows 32汇编以一个独立的小程序方式实现，程序代码如图2所示。

2、序列号生成器与序列号合法性判断函数的设计

序列号生成器与序列号合法性判断函数中运用RSA加密算法。在序列号生成器中是使用私钥将用户返回的信息（硬盘序列号，用户名）进行加密得到相应的注册序列号；在序列号合法性判断函数中使用私钥将用户输入的注册序列号解密，再与（硬盘序列号，用户名）进行比较，一致则调用程序装载器将程序其他部分解密装入内存，初始化删环境并运行程序主体；否则退出。

RSA加密算法的实现需要使用大数运算库，我们使用MIRACL大数库来实现RSA计算，序列号生成器的主要代码如下：

char szlnputString[]=”机器码和用户名组成的字符串”;

char szSerial[256]=[0];//用于存放生成的注册码

bign，d，c，m; //MIRACL中的大数类型

mip→IBASE=16; //以16进制模式

n= mlrvar(0); //初始化大数

d= mirvar(0);

c= mirvar(0); //C存放输入的字符串大数

m= mlrva(o);

bytes to big( len, szlnputString,c);

//将输入字符串转换成大数形式并存入变量c中

cinstr(n,”以字符串形成表示的模数”);//初始化模数

cinstr(d,”以字符串形成表示的公钥”)：//初始化公钥

powmod(c,d,n,m); //计算m=cdmod n

cotstr(m,szSerial)；//m的16进制字符串即为注册码

序列号合法性检测函数的主要代码如下：

char szlnputStringL]=”机器码和用户名组成的字符串”;

char szSerial[ 256]=”用户输入的序列号”

bign,e,c,m; //MIRACL中的大数类型

mip→IBASE=16; //以16进制模式

cinstr(m,szSerial); //将序列号的16进制转成大数形式

cinstr(n,”模数n的字符串形式”);//初始化模数n

cinstr(e,”字符串形式的公钥”);//初始化公钥

if compare(m,n)==-1） //mn时才进行解密

{

powmod(m,e,n,c);//计算m=me mod n

big_to _bytes(0,c,szSerial,0); //转为字符串

return lstrcmp( szlnputString,szSerial);

}

3、强耦合关系的设计

如果在序列号合法性检测函数中简单地使用图3所示流程：

解密者可以使用以下几种手段进行攻击：

（1）修改“判断合法性子函数”的返回指令，让它永远返回正确值，这样可以使用任意的序列号，安装／使用软件。

（2）修改判断后的跳转指令，使程序永远跳到正确的分支运行，效果和上一种一样。

（3）在“判断合法性子函数”之前执行一条跳转指令，绕过判断，直接跳转到“正常执行”分支运行，这样可以不用输入序列号安装／使用软件。

为阻止以上攻击手段，笔者在程序中增加了“序列号合法性检测函数”与程序其他部分“强耦合”（即增强其与程序其他部分的关联度，成为程序整体密不可分的一部分，一旦被修改程序将无法正常工作）的要求（见图1），并且设置一个“完整性检测函数”用于判断相关的代码是否被修改过。当然，基于同样的原因，“完整性检测函数”也必须与程序其他部分存在“强耦合”关系。

强耦合关系通过以下方式建立：

在程序其他部分的函数（例如函数A）中随机的访问需要强耦合的“序列号合法性检测函数”和“完整性检测函数”，在调用时随机的选择使用一个错误的序列号或是用户输入的序列号，并根据返回结果选择执行A中正常的功能代码还是错误退出的功能代码，流程如图4所示。

经过这种改进，如果破解者通过修改代码的方式破解将因“完整性检测”失败导致程序退出；如果使用SMC等技术绕过“序列号合法性判断函数”而直接跳至序列号正确时的执行入口，在后续的运行中，将因为随机的耦合调用失败导致程序退出。破解者要破解软件将不得不跟踪所有进行了耦合调用的函数，这显然是一个艰巨的任务。

4、完整性检测函数的设计

我们使用CRC算法算出需进行完整性检测的文件的校验码，并用RSA加密算法的公钥（不同于序列号合法性检测中的公钥／私钥对）将其加密存放在特定的文件中，在检测时先用CRC算法重新生成需进行完

整性检测的文件的校验码，并用私钥将保存的校验码解密，两者相比较，相等则正常运行；否则退出。

5、程序加载器的设计

与编译成机器码执行的程序不同，Java程序只能由Java虚拟机解释执行，因此程序加载器的工作包括：初始化Java虚拟机；在内存中解密当前要运行的class文件；使解密后的c:lass文件在虚拟机中运行，在

需要时解密另一个class文件。图5是用于初始化JVM的代码：

以上介绍了我们设计的针对Java软件的加密保护方法，其中综合运用了多种加密技术，抗破解强度高；使用纯软件保护技术，成本低。经笔者在Windows系列平台上进行测试，运行稳定，效果良好。

在研宄开发过程中，我们还总结出加密保护软件的一些经验：

1、对关键代码和数据要静态加密，再动态解密执行；要结合具体的工作平台使用反跟踪／调试技术；

2、要充分利用系统的功能，如在Windows下使用DLL文件或驱动程序形式能得到最大的丰又限，可以充分利用系统具有的各种功能；

3、如果可能应该将关键代码存放在不可禚复制的地方；

4、序列号要与机器码等用户信息相关以阻止盐复布序列号；

5、加密流程的合理性比加密算法本身的强度更重要。

我在用java做一个简单的即时通讯工具，自学的所以很多都不会，希望可以帮帮我

package service_client_for_many;

import java.awt.BorderLayout;

import java.awt.Font;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.IOException;

import java.net.ServerSocket;

import java.net.Socket;

import java.util.Vector;

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 MutilServer implements ActionListener {

private JFrame frame;

/** 边界布局的主面板 */

private JPanel panelMain;

private JPanel panelDown;

private JTextArea ta;

private JTextField txt;

private JButton but;

private JScrollPane jsp;

private Font font;

/**

* 当前服务器使用端口

private int port = 6666;

/**

* 远程客户端的IP

private String clientIp;

/**

* 记录所有正在工作的服务员的登记表

private VectorWaiter dengJiBiao;

public MutilServer() {

frame = new JFrame("双工多人服务器");

panelMain = new JPanel(new BorderLayout());

panelDown = new JPanel();

ta = new JTextArea();

txt = new JTextField(20);

but = new JButton("发送");

jsp = new JScrollPane(ta);

// 粘贴界面

panelDown.add(txt);

panelDown.add(but);

panelMain.add(jsp, BorderLayout.CENTER);

panelMain.add(panelDown, BorderLayout.SOUTH);

// 字体

font = new Font("宋体", Font.BOLD, 18);

txt.setFont(font);

ta.setFont(font);

but.setFont(font);

// 文本域只读

ta.setEditable(false);

// 按钮添加监听

but.addActionListener(this);

frame.add(panelMain);

frame.setBounds(100, 300, 400, 400);

frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// 关闭窗体时结束程序

frame.setAlwaysOnTop(true);// 永远在所有窗体最上

frame.setVisible(true);

// 创建登记表

dengJiBiao = new VectorWaiter();

// 光标给消息文本框

txt.requestFocus();

createServer();

}

/**

* 显示文本到文本域,并且追加一个换行

* @param msg

* 要显示的文本

public void showTxt(String msg) {

ta.append(msg + "\n");

}

public static void main(String[] args) {

new MutilServer();

}

// 动作监听

public void actionPerformed(ActionEvent e) {

if (e.getSource() == but) {// 发送

txt.requestFocus();

String str = txt.getText().trim();

if(str.length()==0){

showTxt("不可以发送空消息");

return;

}

if(dengJiBiao.size()==0){

showTxt("当前木有客户连接,无法发送信息");

return;

}

str ="服务器消息:"+str;

//找到所有登记表中的服务员,实现群发

for (int i = 0; i dengJiBiao.size(); i++) {

Waiter w = dengJiBiao.get(i);//得到当前循环的服务员

w.send(str);

}

// 清空文本框,得到焦点

txt.setText("");

}

/**

* 启动网络服务器

public void createServer() {

showTxt("正在启动服务器,使用本机" + port + "端口...");

try {

ServerSocket server = new ServerSocket(port);

showTxt("服务器启动成功,开始监听网络连接...");

while (true) {

Socket jiaoYi = server.accept();

// 每得到一个交易,就是来了一个客户端.需要交给一个新的服务员去维护处理

new Waiter(jiaoYi, dengJiBiao, this);

}

} catch (IOException e) {

showTxt("服务器启动失败,可能端口被占用");

}

package service_client_for_many;

import java.awt.BorderLayout;

import java.awt.Font;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.Socket;

import java.net.UnknownHostException;

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 MyClient implements ActionListener{

private JFrame frame;

/** 边界布局的主面板 */

private JPanel panelMain;

private JPanel panelDown;

private JTextArea ta;

private JTextField txt;

private JButton but;

private JScrollPane jsp;

private Font font;

/**

* 服务器IP

private String ip = "192.168.10.239";

/**

* 服务器端口

private int port = 6666;

private BufferedReader br;

private BufferedWriter bw;

public MyClient() {

frame = new JFrame("双工客户端1");

panelMain = new JPanel(new BorderLayout());

panelDown = new JPanel();

ta = new JTextArea();

txt = new JTextField(20);

but = new JButton("发送");

jsp = new JScrollPane(ta);

// 粘贴界面

panelDown.add(txt);

panelDown.add(but);

panelMain.add(jsp, BorderLayout.CENTER);

panelMain.add(panelDown, BorderLayout.SOUTH);

// 字体

font = new Font("宋体", Font.BOLD, 18);

txt.setFont(font);

ta.setFont(font);

but.setFont(font);

// 文本域只读

ta.setEditable(false);

//按钮添加监听

but.addActionListener(this);

frame.add(panelMain);

frame.setBounds(500, 200, 400, 400);

frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// 关闭窗体时结束程序

frame.setAlwaysOnTop(true);// 永远在所有窗体最上

frame.setVisible(true);

// 光标给消息文本框

txt.requestFocus();

linkServer();

}

/** 显示文本到文本域,并且追加一个换行

* @param msg 要显示的文本

public void showTxt(String msg) {

ta.append(msg+"\n");

}

public static void main(String[] args) {

new MyClient();

}

//动作监听

public void actionPerformed(ActionEvent e) {

if (e.getSource() == but) {// 发送

if (bw == null) {

showTxt("当前没有客户端连接,无法发送消息");

return;

}

String s = txt.getText().trim();// 得到文本框要发送的文字,去掉两端空格

if (s.length() == 0) {

showTxt("不可以发送空消息");

return;

}

showTxt("我说:" + s);

try {

bw.write(s + "\n");// 发送网络消息给对方

bw.flush();// 清空缓冲

} catch (IOException e1) {

showTxt("信息:" + s + " 发送失败");

}

// 清空文本框,得到焦点

txt.setText("");

txt.requestFocus();

}

/**

* 连接服务器

public void linkServer(){

showTxt("准备连接服务器"+ip+":"+port);

try {

Socket jiaoYi = new Socket(ip,port);

showTxt("连接服务器成功,开始进行通讯");

// 得到输入和输出

br = new BufferedReader(new InputStreamReader(

jiaoYi.getInputStream()));

bw = new BufferedWriter(new OutputStreamWriter(

jiaoYi.getOutputStream()));

String s = null;

while ((s = br.readLine()) != null) {

showTxt( s);

}

} catch (UnknownHostException e) {

showTxt("连接服务器失败,网络连通错误");

} catch (IOException e) {

showTxt("与服务器通讯失败,已经断开连接");

}

showTxt("关闭");

}

package service_client_for_many;

import java.awt.BorderLayout;

import java.awt.Font;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.Socket;

import java.net.UnknownHostException;

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 MyClient2 implements ActionListener{

private JFrame frame;

/** 边界布局的主面板 */

private JPanel panelMain;

private JPanel panelDown;

private JTextArea ta;

private JTextField txt;

private JButton but;

private JScrollPane jsp;

private Font font;

/**

* 服务器IP

private String ip = "192.168.10.239";

/**

* 服务器端口

private int port = 6666;

private BufferedReader br;

private BufferedWriter bw;

public MyClient2() {

frame = new JFrame("双工客户端2");

panelMain = new JPanel(new BorderLayout());

panelDown = new JPanel();

ta = new JTextArea();

txt = new JTextField(20);

but = new JButton("发送");

jsp = new JScrollPane(ta);

// 粘贴界面

panelDown.add(txt);

panelDown.add(but);

panelMain.add(jsp, BorderLayout.CENTER);

panelMain.add(panelDown, BorderLayout.SOUTH);

// 字体

font = new Font("宋体", Font.BOLD, 18);

txt.setFont(font);

ta.setFont(font);

but.setFont(font);

// 文本域只读

ta.setEditable(false);

//按钮添加监听

but.addActionListener(this);

frame.add(panelMain);

frame.setBounds(900, 200, 400, 400);

frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);// 关闭窗体时结束程序

frame.setAlwaysOnTop(true);// 永远在所有窗体最上

frame.setVisible(true);

// 光标给消息文本框

txt.requestFocus();

linkServer();

}

/** 显示文本到文本域,并且追加一个换行

* @param msg 要显示的文本

public void showTxt(String msg) {

ta.append(msg+"\n");

}

public static void main(String[] args) {

new MyClient2();

}

//动作监听

public void actionPerformed(ActionEvent e) {

if (e.getSource() == but) {// 发送

if (bw == null) {

showTxt("当前没有客户端连接,无法发送消息");

return;

}

String s = txt.getText().trim();// 得到文本框要发送的文字,去掉两端空格

if (s.length() == 0) {

showTxt("不可以发送空消息");

return;

}

showTxt("我说:" + s);

try {

bw.write(s + "\n");// 发送网络消息给对方

bw.flush();// 清空缓冲

} catch (IOException e1) {

showTxt("信息:" + s + " 发送失败");

}

// 清空文本框,得到焦点

txt.setText("");

txt.requestFocus();

}

/**

* 连接服务器

public void linkServer(){

showTxt("准备连接服务器"+ip+":"+port);

try {

Socket jiaoYi = new Socket(ip,port);

showTxt("连接服务器成功,开始进行通讯");

// 得到输入和输出

br = new BufferedReader(new InputStreamReader(

jiaoYi.getInputStream()));

bw = new BufferedWriter(new OutputStreamWriter(

jiaoYi.getOutputStream()));

String s = null;

while ((s = br.readLine()) != null) {

showTxt(s);

}

} catch (UnknownHostException e) {

showTxt("连接服务器失败,网络连通错误");

} catch (IOException e) {

showTxt("与服务器通讯失败,已经断开连接");

}

showTxt("关闭");

}

package service_client_for_many;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.IOException;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.net.Socket;

import java.util.Vector;

/**

* 服务员,线程类

* 在客户端连接后创建启动

* 负责当前客户端的所有数据收发

* 并且在业务需要时,将结果与服务器(老板)进行报告

public class Waiter extends Thread{

private Socket sc;

private VectorWaiter dengJiBiao ;

private MutilServer server;

/**

* 客户端IP

private String ip;

private BufferedReader br;

private BufferedWriter bw;

/** 创建一个的新的服务员,负责当前传递的客户端连接(交易)

* 启动新线程

* @param sc 负责的交易

* @param dengJiBiao所有正在工作的服务员(所有交易)

* @param server 老板,也就是服务器

public Waiter(Socket sc, VectorWaiter dengJiBiao,

MutilServer server) {

this.sc = sc;

this.dengJiBiao = dengJiBiao;

this.server = server;

//初始化连接的准备工作

ip = sc.getInetAddress().getHostAddress();

// 得到输入和输出

try {

br = new BufferedReader(new InputStreamReader(

sc.getInputStream()));

bw = new BufferedWriter(new OutputStreamWriter(

sc.getOutputStream()));

} catch (IOException e) {

this.server.showTxt("与客户端:"+ip+"建立通讯失败");

e.printStackTrace();

return;//无效客户,不再继续

}

this.server.showTxt("客户端:"+ip+"连接服务器成功");

//启动线程

this.start();

}

//线程

public void run(){

//开始时,登记开工

dengJiBiao.addElement(this);

System.out.println(this.getClass().getName());

try {

String s = null;

while ((s = br.readLine()) != null) {

server.showTxt("客户"+ip+"说:" + s);

//当前客户发来的信息,其它客户也要能看得见.需要实现转发

//从登记表找到所有正在干活的服务员

for (int i = 0; i dengJiBiao.size(); i++) {

Waiter w = dengJiBiao.get(i);

//排除掉当前服务员自己

if(w!=this)

w.send("客户"+ip+"说:" + s);

}

} catch (Exception e) {

server.showTxt("客户"+ip+"已经离开");

}

//结束时,登记下班

dengJiBiao.removeElement(this);

}

/** 发送信息给当前服务员负责的客户端

* @param msg

public void send(String msg){

try {

bw.write(msg+"\n");

bw.flush();

} catch (Exception e) {

server.showTxt("给客户:"+ip+"发送信息"+msg+"失败");

}

一个服务器类·两个客户端类，一个线程类负责收发

即使通java的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于、即使通java的信息别忘了在本站进行查找喔。

标签：即使通java