1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
|
import gnu.io.*;
import java.io.*;
import gnu.io.SerialPort;
public class rs232 {
private OutputStream outStream; //flux d'écriture du port
private InputStream in;//flux de lecture du port
private CommPortIdentifier portId; //identifiant du port
private RXTXPort sPort; //le port série
private String s; //String de retour d'info
private int vitesse=9600;
private int NbBits=SerialPort.DATABITS_8;
private String NomPort="COM1";
private int Parite=SerialPort.PARITY_NONE;
private int Stop=SerialPort.STOPBITS_1;
private int Controle=SerialPort.FLOWCONTROL_NONE;
private RXTXCommDriver w32Driver = new RXTXCommDriver();
private EcoutePort EcoutePort1;
public rs232(){
}
//recupération du nom du port
public String SetPort(String port){
NomPort=port;
s="";
try {
portId = CommPortIdentifier.getPortIdentifier(NomPort);
s="port OK" ;
} catch (NoSuchPortException e) {
s="port innexistant";
}
return s;
}
//renvoi du nom du port
public String GetPort(){
return portId.toString();
}
//recuperation de la vitesse de transmission
public void SetVitesse(int v){
vitesse=v;
}
//retour de la vitesse de transmission
public int GetVitesse(){
return vitesse;
}
//recupertion du nombre de bits de donées
public String SetNbBits(int b){
s="";
if (b==5){
NbBits=RXTXPort.DATABITS_5;
s="5 bits de donnée";
}
else if (b==6){
NbBits=RXTXPort.DATABITS_6;
s="6 bits de donnée";
}
else if (b==7){
NbBits=RXTXPort.DATABITS_7;
s="7 bits de donnée";
}
else if (b==8){
NbBits=RXTXPort.DATABITS_8;
s="8 bits de donnée";
}
else {
s="Nombre de bits de donnée incompatible";
}
// System.out.println(s);
return s;
}
//retour du nombre de bits de données
public int getNbBits(){
int b=0;
if ( NbBits==RXTXPort.DATABITS_5){
b=5 ;
}
else if (NbBits==RXTXPort.DATABITS_6){
b=6 ;
}
else if ( NbBits==RXTXPort.DATABITS_7){
b=7 ;
}
else if ( NbBits==RXTXPort.DATABITS_8){
b=8 ;
}
return b;
}
//recuperation de la parite
public String SetParite(String parite){
s="";
if (parite.equals("AUCUNE")){
Parite=RXTXPort.PARITY_NONE;
s="Pas de parité";
}
else if (parite.equals("PAIRE")){
Parite=RXTXPort.PARITY_EVEN;
s="Parité paire";
}
else if (parite.equals("IMPAIRE")){
Parite=RXTXPort.PARITY_ODD;
s="Parité impaire";
}
else if (parite.equals("MARQUE")){
Parite=RXTXPort.PARITY_MARK;
s="Parité marquée";
}
else if (parite.equals("ESPACE")){
Parite=RXTXPort.PARITY_SPACE;
s="Parité espace";
}
else {
s="Parité inconnue";
}
//System.out.println(s);
return s;
}
//retour de la parite
public String GetParite(){
s="";
if (Parite==RXTXPort.PARITY_NONE){
s="AUCUNE";
}
else if (Parite==RXTXPort.PARITY_EVEN){
s="PAIRE";
}
else if ( Parite==RXTXPort.PARITY_ODD){
s="IMPAIRE";
}
else if ( Parite==RXTXPort.PARITY_MARK){
s="MARQUE";
}
else if ( Parite==RXTXPort.PARITY_SPACE){
s="ESPACE";
}
return s;
}
//recuperation du nombre de bits de stop
public String SetStop(String stop){
s="";
if (stop.equals("1")){
Stop=RXTXPort.STOPBITS_1;
s="1 bit de stop";
}
else if (stop.equals("2")){
Stop=RXTXPort.STOPBITS_2;
s="2 bits de stop";
}
else if (stop.equals("1,5")){
Stop=RXTXPort.STOPBITS_1_5;
s="bit de stop 1,5";
}
else {
s="bit de stop inconnu";
}
// System.out.println(s);
return s;
}
//retour du nombre de bits de stop
public String GetStop(){
s="";
if (Stop==RXTXPort.STOPBITS_1){
s="1";
}
else if (Stop==RXTXPort.STOPBITS_2){
s="2";
}
else if (Stop==RXTXPort.STOPBITS_1_5){
s="1,5";
}
return s;
}
//recuperation du controle
public void SetControle(String controle){
if (controle.equals("matériel")){
Controle=SerialPort.FLOWCONTROL_RTSCTS_IN;
}
else if (controle.equals("Xon/Xoff")){
Controle=SerialPort.FLOWCONTROL_XONXOFF_IN;
}
else {
Controle=SerialPort.FLOWCONTROL_NONE;
}
}
//retour du controle
public String GetControle(){
String c = null;
if (Controle==SerialPort.FLOWCONTROL_NONE){
c="aucun";
}
if (Controle==SerialPort.FLOWCONTROL_RTSCTS_IN){
c="matériel";
}
if (Controle==SerialPort.FLOWCONTROL_XONXOFF_IN){
c="Xon/Xoff";
}
return c;
}
//ouvrir le port et les flux
public void OuvrirPort(){
w32Driver.initialize();
//ouverture du port
try {
sPort = (RXTXPort) portId.open("java_rs232", 2000);
}
catch (PortInUseException e) {
System.err.println(e);
}
if (sPort != null) {
//règle les paramètres de la connexion
try {
sPort.setFlowControlMode(Controle);
sPort.setSerialPortParams(vitesse,
NbBits,
Stop,
Parite);
//récupération du flux de lecture et écriture du port
outStream = sPort.getOutputStream();
in = sPort.getInputStream();
EcoutePort1 = new EcoutePort(in);
(new Thread(EcoutePort1)).start();
}
catch (UnsupportedCommOperationException e) {
System.err.println(e);
}
}
}
// retour de la chaine recu
public String GetCRecu(){
String c=EcoutePort1.Recu();
return c;
}
//effacer la chaine recu
public void EffacerCRecu(){
EcoutePort1.EffacerRecu();
}
// ecrire un caractere
public void EcrireChar(char envoie){
try {
//demande de poids
outStream.write((int) envoie);
outStream.close();
} catch (IOException e) {
}
}
//ecrire un tableau de bytes
public boolean EcrireBytes(byte[] envoie){
boolean b=false;
try {
outStream.write(envoie);
outStream.close();
b=true;
} catch (IOException e) {
}
return b;
}
//fermer le port
public void FermerPort(){
try {
outStream.close();
} catch (IOException e) {
}
EcoutePort1.stopThread();
sPort.close();
}
}
//thread d'ecoute du port
class EcoutePort implements Runnable{
private boolean running=true;
private InputStream in;
private String CaractRecu;
private String SRecu=new String();
public EcoutePort(InputStream in){
this.in =in;
}
@Override
public void run(){
while (running){
byte[] buffer = new byte[1024];
int len = -1;
try
{
while ( ( len = this.in.read(buffer)) > -1 )
{
CaractRecu=new String(buffer,0,len);
SRecu=SRecu.concat(CaractRecu);
byte[] RetourTrame=CaractRecu.getBytes();
for (int t=0;t<RetourTrame.length;t++){
System.out.println((int)RetourTrame[t]& 0xff);
}
try {
// pause
Thread.sleep(100);
}
catch (InterruptedException ex) {}
}
}
catch ( IOException e )
{
e.printStackTrace();
}
}
}
//arrete le thread
public void stopThread(){
this.running=false;
}
//efface les caractere recu
public void EffacerRecu(){
SRecu="";
}
//renvoi les caractere recu
public String Recu(){
return SRecu;
}
} |
