实时通信java代码的简单介绍

java实现串口通信代码

public static void process() {

成都创新互联公司专业为企业提供十堰郧阳网站建设、十堰郧阳做网站、十堰郧阳网站设计、十堰郧阳网站制作等企业网站建设、网页设计与制作、十堰郧阳企业网站模板建站服务，10年十堰郧阳做网站经验，不只是建网站，更提供有价值的思路和整体网络服务。

try {

Enumeration portList = CommPortIdentifier.getPortIdentifiers();

while (portList.hasMoreElements())

{

CommPortIdentifier portId = (CommPortIdentifier) portList.nextElement();

if (portId.getPortType() == CommPortIdentifier.PORT_SERIAL)//如果端口类型是串口则判断名称

{

if(portId.getName().equals("COM1")){//如果是COM1端口则退出循环

break;

}else{

portId=null;

}

SerialPort serialPort = (SerialPort)portId.open("Serial_Communication", 1000);//打开串口的超时时间为1000ms

serialPort.setSerialPortParams(9600,SerialPort.DATABITS_8,SerialPort.STOPBITS_1,SerialPort.PARITY_NONE);//设置串口速率为9600，数据位8位，停止位1们，奇偶校验无

InputStream in = serialPort.getInputStream();//得到输入流

OutputStream out = serialPort.getOutputStream();//得到输出流

//进行输入输出操作

//操作结束后

in.close();

out.close();

serialPort.close();//关闭串口

} catch (PortInUseException e) {

e.printStackTrace();

} catch (UnsupportedCommOperationException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

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

使用7z格式压缩上传

下载1：

下载2： att.newsmth.net/att.php?p.75.25665.766.7z

Java版源代码下载：

（有些网友对C++如何实现感兴趣，推荐一下Poco带的WebSocket功能，把Java源代码翻译成C++就行了）

1. 说明：

utf8版本，支持各种语言版本的windows系统

程序内嵌数据库

用户帐号非明文存储

在Firefox/Chrome浏览器测试通过，建议使用Chrome，Firefox不支持mp3的消息提示音

2. 现有功能

抖动窗口

两种状态，登录/离线

3.可扩展的功能

使用Windows域用户帐号，无需注册

收发离线信息

查看历史信息

新消息提示

群聊

共享文件

4. （可能）存在的问题

并发性未作充分测试

添加好友的确认

5. 适用的场景

学校

小公司

6.使用

解压后双击执行start.bat，将自动进入初始界面，如下图

默认使用80端口，若80端口已被占用，修改start.bat中的setserver_port=80

双击左上角图标，弹出对话框，可以选择注册

注册成功

搜索好友，如不提供搜索条件，则返回所有已注册用户

添加好友

添加好友提示

聊天

如何用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实现两台计算机的通信源代码

一个简单的聊天程序

参考一下；

//客户端的

import java.io.*;

import java.net.*;

import java.awt.*;

import javax.swing.*;

import java.awt.event.*;

public class ChatClient {

public static void main(String[] args) {

ChatClient cc=new ChatClient();

cc.receive();

}

JTextField jtf;

JTextArea jta;

Socket s;

PrintWriter out;

BufferedReader in;

public ChatClient(){

JFrame frame=new JFrame("ChatClient");

frame.setSize(400,300);

jta=new JTextArea();

jta.setEditable(false);

jtf=new JTextField();

jtf.addActionListener(new ActionListener(){

public void actionPerformed(ActionEvent arg0) {

send();

}

});

frame.getContentPane().add(new JScrollPane(jta));

frame.getContentPane().add(jtf,"South");

frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

frame.setVisible(true);

try {

s=new Socket("127.0.0.1",9000);

in=new BufferedReader(new InputStreamReader(s.getInputStream()));

out=new PrintWriter(s.getOutputStream());

} catch (UnknownHostException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

public void receive(){

while(true){

try {

String text=in.readLine();

this.jta.append(text+"\n");

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

return;

}

public void send(){

String text=this.jtf.getText();

this.jtf.setText("");

out.println(text);

out.flush();

}

//服务器端的

import java.net.*;

import java.io.*;

import java.util.*;

public class ChatServer {

public static void main(String[] args) throws Exception {

ServerSocket ss=new ServerSocket(9000);

List list=new ArrayList();

while(true){

Socket s=ss.accept();

list.add(s);

Thread t=new ServerThread(s,list);

t.start();

}

class ServerThread extends Thread{

Socket s;

List list;

BufferedReader in;

PrintWriter out;

public ServerThread(Socket s, List list) {

this.s = s;

this.list = list;

try {

in=new BufferedReader(new InputStreamReader(s.getInputStream()));

out=new PrintWriter(s.getOutputStream());

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

public void run(){

while(true){

try {

String str=in.readLine();

if (str==null) return;

Iterator it=list.iterator();

while(it.hasNext()){

Socket socket=(Socket)(it.next());

PrintWriter o=new PrintWriter(socket.getOutputStream());

o.println(str);

o.flush();

}

} catch (IOException e) {

// TODO Auto-generated catch block

//e.printStackTrace();

return;

}

JAVA代码,帮忙加点注释，分不多了

/**

* 在该类中创建了服务器端的ServerSocket，

* 当有客户发出连接服务器的请求时，

* 生成与客户端进行通信的Socket对象。

public class MultiServer {

public static void main(String args[]) throws IOException {

System.out.println("建立并等等待连接......");

// 创建服务器端 ServerSocket 监听5500端口

ServerSocket serverSocket = new ServerSocket(5500);

// 初始化是个socket对象

Socket connectToClient = null;

while (true) {

// 等待客户端的连接获得客户端Socket

connectToClient = serverSocket.accept();

new ServerThread(connectToClient);

}

你这while方法没break，你确定没问题？

Java语言写段简单，但又有技术含量的即时通讯代码，不胜感激之情溢于满天下

这里有一个简单的模拟通讯要先运行服务器端再运行客户端否则会报错：

服务器端代码：

package com.test3;

import java.net.*;

import java.io.*;

import javax.swing.*;

import java.awt.*;

import java.awt.event.*;

public class Server2 extends JFrame implements ActionListener , KeyListener {

JTextArea jta=null;

JScrollPane jsp=null;

JTextField jtf=null;

JButton jb=null;

JPanel jp=null;

InputStreamReader isr=null;

BufferedReader br=null;

PrintWriter pw=null;

Socket s;

String jtatext="";

public static void main(String[] args) {

// TODO Auto-generated method stub

Server2 sv2=new Server2();

}

public Server2(){

jta=new JTextArea();

jta.setEditable(false);

jsp=new JScrollPane(jta);

jtf=new JTextField(10);

jtf.addKeyListener(this);

jb=new JButton("发送");

jb.addActionListener(this);

jp=new JPanel();

jp.add(jtf);

jp.add(jb);

this.add(jsp,"Center");

this.add(jp,"South");

this.setSize(300,300);

this.setLocationRelativeTo(this);

this.setTitle("服务器端");

this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

this.setVisible(true);

try{

ServerSocket ss=new ServerSocket(9999);

s=ss.accept();

isr=new InputStreamReader(s.getInputStream());

br=new BufferedReader(isr);

pw=new PrintWriter(s.getOutputStream(),true);

while(true){

String info=br.readLine();

jta.append("客户端对服务器说： "+info+"\r\n");

// this.jta.setText(jtatext);

}

}catch(Exception e){

e.printStackTrace();

}

@Override

public void actionPerformed(ActionEvent e) {

if(e.getSource()==jb){

try {

pw.println(jtf.getText());

jta.append("服务器对客户端说： "+jtf.getText()+"\r\n");

// jta.setText(jtatext);

jtf.setText("");

} catch (Exception e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

@Override

public void keyTyped(KeyEvent e) {}

@Override

public void keyPressed(KeyEvent e) {

if(e.getKeyCode()==KeyEvent.VK_ENTER){

try {

pw.println(jtf.getText());

jta.append("服务器对客户端说： "+jtf.getText()+"\r\n");

jtf.setText("");

} catch (Exception e1) {

e1.printStackTrace();

}

@Override

public void keyReleased(KeyEvent e) {}

}

客户端代码：

package com.test3;

import java.net.*;

import java.io.*;

import javax.swing.*;

import java.awt.*;

import java.awt.event.*;

public class Client2 extends JFrame implements ActionListener ,KeyListener {

JTextArea jta=null;

JScrollPane jsp=null;

JTextField jtf=null;

JButton jb=null;

JPanel jp=null;

String jtatext="";

Socket s;

PrintWriter pw=null;

InputStreamReader isr=null;

BufferedReader br=null;

public static void main(String[] args) {

// TODO Auto-generated method stub

Client2 sv2=new Client2();

}

public Client2(){

jta=new JTextArea();

jta.setEditable(false);

jsp=new JScrollPane(jta);

jtf=new JTextField(10);

jtf.addKeyListener(this);

jb=new JButton("发送");

jb.addActionListener(this);

jp=new JPanel();

jp.add(jtf);

jp.add(jb);

this.add(jsp,"Center");

this.add(jp,"South");

this.setSize(300,300);

this.setLocationRelativeTo(this);

this.setTitle("客户端");

this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);

this.setVisible(true);

try {

s=new Socket("127.3.3.3",9999);

isr=new InputStreamReader(s.getInputStream());

br=new BufferedReader(isr);

pw=new PrintWriter(s.getOutputStream(),true);

while(true){

String info=br.readLine();

jta.append("服务器对客户端说： "+info+"\r\n");

}

} catch (Exception e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

@Override

public void actionPerformed(ActionEvent e) {

if(e.getSource()==jb){

try {

pw.println(this.jtf.getText());

jta.append("客户端对服务器说： "+jtf.getText()+"\r\n");

jtf.setText("");

} catch (Exception e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

public void keyTyped(KeyEvent e) {}

public void keyPressed(KeyEvent e) {

if(e.getKeyCode()==KeyEvent.VK_ENTER){

try {

pw.println(this.jtf.getText());

jta.append("客户端对服务器说： "+jtf.getText()+"\r\n");

jtf.setText("");

} catch (Exception e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

public void keyReleased(KeyEvent e) {}

}

本文标题：实时通信java代码的简单介绍
当前链接：http://hbruida.cn/article/phhoip.html

实时通信java代码的简单介绍

java实现串口通信代码

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

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

如何使用java实现两台计算机的通信 源代码

JAVA代码,帮忙加点注释，分不多了

Java语言写段简单，但又有技术含量的即时通讯代码，不胜感激之情溢于满天下

其他资讯

如何使用java实现两台计算机的通信源代码